Tools for generating test data for state migration tests in Apache Flink

JMX metrics reporter for Apache Flink that enables monitoring and management of Flink applications through Java Management Extensions (JMX)

InfluxDB metrics reporter for Apache Flink that enables exporting Flink metrics to InfluxDB time series database

Graphite metrics reporter implementation for Apache Flink that enables streaming and batch processing applications to send runtime metrics to Graphite monitoring systems

Dropwizard metrics integration for Apache Flink - provides bridges and wrappers to integrate Flink metrics with the Dropwizard Metrics library

Core metrics interfaces and implementations for Apache Flink stream processing framework

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