Distributed State Timeline - Distributed File System implementation for Apache Flink's state changelog storage

Apache Flink Core runtime components, type system, and foundational APIs for stream processing applications

Apache Flink CSV format support for reading and writing CSV data in stream and batch processing

Apache Flink contributor module providing the WikiEdits streaming connector for processing Wikipedia edit events from IRC

Apache Flink Twitter connector for streaming data from Twitter API with OAuth authentication

Apache Flink Container Module providing standalone application cluster entry point functionality for containerized Flink deployments.

Testing utilities for Apache Flink connectors providing test frameworks, assertion utilities, and abstractions for comprehensive connector testing

Apache Flink connector for NiFi that enables streaming data integration between Flink and Apache NiFi using the Site-to-Site protocol

A deprecated Apache Flink connector that enables integration with Apache NiFi through the NiFi Site-to-Site protocol for bidirectional streaming data exchange.

Apache Flink Kafka 0.10 connector for streaming data processing with exactly-once processing guarantees

Apache Flink HBase 1.4 Connector provides bidirectional data integration between Flink streaming applications and HBase NoSQL database.

Apache Flink connector for Google Cloud Pub/Sub that provides streaming data integration capabilities

Apache Flink connector for Google Cloud Pub/Sub with exactly-once processing guarantees for real-time stream processing applications

Flink filesystem connector providing fault-tolerant rolling file sinks for streaming data to HDFS and Hadoop-compatible filesystems

Apache Flink connector for Elasticsearch 1.x that enables streaming data ingestion into Elasticsearch clusters

Apache Flink file connector library for unified file processing in both batch and streaming modes with support for various formats, compression, and distributed processing capabilities.

Apache Flink connector for Apache Cassandra that provides both streaming and batch data integration capabilities

Apache Flink connector for Apache Cassandra - provides sinks for streaming data into Cassandra databases

Base classes and utilities for building Apache Flink connectors with async sink patterns, source readers, and advanced streaming capabilities

Apache Flink Client APIs and utilities for submitting and interacting with Flink jobs