BeClaude

flink

New
26.1kGitHubGeneralby apache

Apache Flink

First seen 5/22/2026

Summary

This skill provides expertise in Apache Flink, enabling developers to build real-time streaming and batch data processing applications.

  • It covers Flink's core concepts like DataStream API, Table API, state management, and deployment, helping you design scalable, fault-tolerant pipelines.

Install & Usage

1
Create the skills directory
mkdir -p .claude/skills
2
Download the skill file

Add the configuration to .claude/skills/flink.md

3
Invoke in Claude Code
/flink

Use Cases

Analyze and optimize a Flink job for low-latency stream processing with exactly-once semantics.
Design a real-time fraud detection pipeline using Flink's DataStream API and event time processing.
Migrate a batch ETL job to a streaming Flink application with stateful processing.
Troubleshoot checkpointing failures and backpressure issues in a production Flink cluster.
Implement a complex event processing (CEP) pattern to detect anomalies in IoT sensor data.
Integrate Flink with Kafka and Elasticsearch for end-to-end streaming analytics.

Usage Examples

1

/flink How do I set up a Flink job with event time and watermarks for late data handling?

2

/flink Write a Flink DataStream job that reads from Kafka, aggregates clicks per minute, and writes to S3.

3

/flink Explain the difference between keyed and non-keyed state in Flink and show an example using ValueState.

View source on GitHub

Security Audits

LicenseUnknownSourceWarnRepositoryPass

Frequently Asked Questions

What is flink?

This skill provides expertise in Apache Flink, enabling developers to build real-time streaming and batch data processing applications. It covers Flink's core concepts like DataStream API, Table API, state management, and deployment, helping you design scalable, fault-tolerant pipelines.

How to install flink?

To install flink: create the skills directory (mkdir -p .claude/skills), then add the config to .claude/skills/flink.md. Finally, /flink in Claude Code.

What is flink best for?

flink is a community categorized under General. Created by apache.

What can I use flink for?

flink is useful for: Analyze and optimize a Flink job for low-latency stream processing with exactly-once semantics.; Design a real-time fraud detection pipeline using Flink's DataStream API and event time processing.; Migrate a batch ETL job to a streaming Flink application with stateful processing.; Troubleshoot checkpointing failures and backpressure issues in a production Flink cluster.; Implement a complex event processing (CEP) pattern to detect anomalies in IoT sensor data.; Integrate Flink with Kafka and Elasticsearch for end-to-end streaming analytics..