Comprehensive Table/SQL distribution for Apache Flink with Blink planner for optimized table processing in both batch and streaming modes.

Apache Flink input format library for parsing Twitter JSON data into structured Tweet objects for stream processing applications

Comprehensive integration test suite for Apache Flink stream processing framework providing test utilities, base classes, and infrastructure for validating fault tolerance, checkpointing, and streaming operations.

Test utilities library for Apache Flink applications providing streaming environments, test data sources, result collection mechanisms, and metrics testing utilities.

Runtime classes required by a task manager for execution of table programs in Apache Flink's Blink planner

Apache Flink Table Planner - translates and optimizes table programs into Flink pipelines

Flink Table Planner connects Table/SQL API and runtime, responsible for translating and optimizing table programs into Flink pipelines.

Scala API for Apache Flink's Table & SQL ecosystem with type-safe bindings and comprehensive support for Scala-specific types

Apache Flink Streaming Scala API provides elegant and fluent Scala APIs for building high-throughput, low-latency stream processing applications with fault-tolerance and exactly-once processing guarantees

Apache Flink Scala API for DataStream processing with type-safe, functional programming constructs for building streaming data processing applications.

Apache Flink Storm compatibility examples demonstrating Storm topology integration with embedded mode and full topology execution patterns.

Apache Flink SQL connector for Apache Kafka 0.11 with shaded dependencies providing streaming and table API integration

Apache Flink SQL connector for Apache Hive 3.1.2 that enables unified BATCH and STREAM processing of Hive tables.

Apache Flink SQL connector for Apache Hive 2.3.9 - enables reading from and writing to Hive tables

Apache Flink SQL connector for Apache Hive 2.3.6 providing integration between Flink and Hive for reading/writing Hive tables and using Hive Metastore as a catalog.

Apache Flink Scala API providing type-safe operations and functional programming paradigms for distributed stream and batch processing applications.

Apache Flink Scala API module that provides elegant and fluent Scala language bindings for Flink's distributed stream and batch processing framework

Apache Flink Scala API providing type-safe distributed stream and batch processing with idiomatic Scala constructs, functional programming features, and seamless runtime integration.

Runtime server components for Apache Flink's queryable state feature enabling external applications to query live streaming job state

Apache Flink ORC format support without Hive dependencies - provides ORC file reading and writing capabilities for Flink applications using a standalone ORC implementation