skills.rest
gAmUssA
gAmUssACOMMUNITY
Explore all skills by this author →
Website𝕏@gamussaGitHub

flink-sql

Develop Apache Flink SQL, Table API, and UDF templates for streaming pipelines.

2|1|Updated Mar 4, 2026
Search Tags:#troubleshooting#streaming#sql#flink#udf#table-api#confluent-cloud
One-click install
npx skills add https://github.com/gAmUssA/flink-sql-skill --skill flink-sql
Or copy as Structured Prompt for Agent▼
Please help me install this Agent Skill.
Skill: flink-sql
Source: https://github.com/gAmUssA/flink-sql-skill/tree/main
Command: npx skills add https://github.com/gAmUssA/flink-sql-skill --skill flink-sql

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) and references (resource) components.

What problem does it solve?

This skill consolidates Flink SQL, Table API, and UDF development patterns for OSS Flink and Confluent Cloud, helping teams accelerate design and implementation of streaming pipelines by reusing best practices and templates.

Core Features & Use Cases

  • Unified SQL patterns for windowed aggregations, joins, and pattern detection (MATCH_RECOGNIZE).
  • Table API and UDF development templates for Java and Python, plus deployment workflows to Confluent Cloud.
  • Comprehensive references with practical examples, guides, and troubleshooting to support production-grade streaming apps.
  • Design guidance for event-time processing, watermarks, and changelog handling across heterogeneous environments.

Quick Start

Clone this repository and load SKILL.md with its references into Claude Code or Claude.ai Projects to activate Flink skills.

Frequently Asked Questions about flink-sql

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I write Flink SQL for windowed aggregations and pattern detection?▼

Flink SQL for windowed aggregations and pattern detection uses specific patterns like MATCH_RECOGNIZE. This skill provides concrete examples and design patterns to implement robust streaming pipelines for both OSS Flink and Confluent Cloud.

How do I develop and deploy Flink UDFs for Confluent Cloud?▼

Developing and deploying Flink UDFs for Confluent Cloud requires specific templates and deployment workflows. This skill provides Java and Python UDF development templates alongside Confluent-specific deployment steps to accelerate production-grade streaming applications.

What is the best way to handle event-time processing and watermarks in Flink SQL?▼

Handling event-time processing and watermarks in Flink SQL requires careful design guidance. This skill offers best practices and references for managing watermarks, event-time processing, and changelog handling across heterogeneous streaming environments.

Does this Flink SQL skill support both OSS Flink and Confluent Cloud environments?▼

Yes, this Flink SQL skill supports both OSS Flink and Confluent Cloud environments. It consolidates unified SQL patterns, Table API workflows, and UDF development templates to support production-grade streaming apps across heterogeneous platforms.

Why is my Flink SQL streaming pipeline failing during table joins?▼

Flink SQL streaming pipeline failures during table joins often stem from incorrect windowing or changelog handling. This skill provides troubleshooting references and design patterns for various joins to help diagnose and resolve streaming architecture issues.

Related Skills

Explore More Data & Analytics Skills→
ancolemanancoleman
503

ingesting-data

Facilitates data ingestion from cloud, APIs, files, and streaming sources into databases.

Community
Advanced
hammadurrehman2006hammadurrehman2006

kafka-data-engineer

Design Kafka event-driven pipelines with topics, schemas, and processing logic.

Community
Advanced
ivanshamaevivanshamaev
14

apache-kafka

Configure Apache Kafka topics, producers, consumers, connectors, and monitoring.

Community
Advanced
ancolemanancoleman
503

streaming-data

Build event streaming pipelines with Kafka, Pulsar, Redpanda, and RabbitMQ.

Community
Advanced