Skills
.Work. You
Rest

apache-flink

Community

Build low-latency, exactly-once streaming

Software Engineering#streaming#kafka#windowing#watermarks#exactly-once#apache flink#pyflink
Authorivanshamaev
Version1.0.0
Installs0

System Documentation

What problem does it solve?

Apache Flink streamlines building reliable, low-latency data pipelines that process events in motion, handle out-of-order data, and recover safely from failures without losing or duplicating records.

Core Features & Use Cases

  • Event-time streaming with windowing: TUMBLE/HOP/SESSION/CUMULATE window definitions using watermarks for correct results under out-of-order arrivals.
  • Stateful processing at scale: Keyed operations with managed state (e.g., ValueState, MapState) and timer-based session/dedup logic using the DataStream API.
  • Production-grade fault tolerance: Checkpointing with EXACTLY_ONCE semantics, configurable state backends (HashMap vs RocksDB), and savepoints for controlled upgrades.

Quick Start

Load the apache-flink skill and ask it to generate a PyFlink SQL streaming job that reads events from Kafka, applies an event-time watermark, performs a 5-minute tumbling aggregation, and writes results to Kafka with EXACTLY_ONCE delivery.

Dependency Matrix

Required Modules

None required

Components

Standard package

💻 Claude Code Installation

Recommended: Let Claude install automatically. Simply copy and paste the text below to Claude Code.

Please help me install this Skill:
Name: apache-flink
Download link: https://github.com/ivanshamaev/de-agent-skills/archive/main.zip#apache-flink

Please download this .zip file, extract it, and install it in the .claude/skills/ directory.
View Source Repository

Agent Skills Search Helper

Install a tiny helper to your Agent, search and equip skill from 471,000+ vetted skills library on demand.