Apache Flink Kubernetes integration module that provides native Kubernetes support for deploying and managing Flink clusters on Kubernetes.

Apache Flink Java API - Core Java APIs for Apache Flink's batch and stream processing framework

Hadoop compatibility layer for Apache Flink providing input/output format wrappers and utilities to integrate Hadoop MapReduce with Flink's DataSet and DataStream APIs

Apache Flink compatibility layer for integrating Hadoop InputFormats, OutputFormats, and MapReduce functions with Flink streaming and batch processing

Hadoop FileSystem integration for Apache Flink enabling seamless access to HDFS and other Hadoop-compatible file systems

Gelly: Flink Graph API - A comprehensive graph processing library for Apache Flink

Google Cloud Storage FileSystem plugin for Apache Flink providing gs:// URI support with recoverable writers

A collection of example applications demonstrating graph processing algorithms using Apache Flink's Gelly Graph API

Common utilities and interfaces for file sink functionality in Apache Flink stream processing applications

Apache Flink external resources management framework that provides GPU resource discovery and allocation capabilities for distributed stream and batch processing applications

Apache Flink streaming examples demonstrating various stream processing patterns and use cases

Apache Flink GPU external resource driver that provides infrastructure for discovering and managing GPU resources in Flink job execution environments through script-based resource discovery

End-to-end testing framework for Apache Flink stream processing with classloader behavior validation.

Apache Flink DSTL (Distributed State Timeline) - A filesystem-based state changelog implementation for Flink's state management

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.