flink
NewApache Flink
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
mkdir -p .claude/skillsAdd the configuration to .claude/skills/flink.md
/flinkUse Cases
Usage Examples
/flink How do I set up a Flink job with event time and watermarks for late data handling?
/flink Write a Flink DataStream job that reads from Kafka, aggregates clicks per minute, and writes to S3.
/flink Explain the difference between keyed and non-keyed state in Flink and show an example using ValueState.
Security Audits
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..