Writing to Hive Dynamic Partitions with Flink SQL
Apache Flink and Apache Hive are commonly integrated in modern data pipelines to enable efficient batch and stream processing with persistent, partitioned storage. One powerful capability is writing data from Flink SQL into Hive tables using dynamic partitioning—where partition values are derived from the data itself rather than being hardcoded ...
Posted on Wed, 02 Sep 2026 16:19:30 +0000 by Twysted
Flink SQL Window Aggregation: Tumble, Hop, Session, and Cumulate Windows
Tumbling Windows (TUMBLE)
Tumbling windows assign each element to a window of a specified duration. These windows have a fixed size and do not overlap. For instance, with a 5-minute tumbling window, Flink creates a new window every 5 minutes, where each record belongs to exactly one window.
Use cases: Minute-level aggregations such as page view ...
Posted on Mon, 18 May 2026 04:57:36 +0000 by RoBoTTo