Understanding ClickHouse AggregatingMergeTree, AggregateFunction, and Materialized Views

This article explains how ClickHouse's AggregatingMergeTree engine uses the special AggregateFunction data type to pre‑aggregate data, demonstrates table creation, data insertion, and querying with state and merge functions, and shows how to combine it with materialized views for efficient analytics.

AggregateFunctionAggregatingMergeTreeClickHouse

0 likes · 8 min read

Understanding ClickHouse AggregatingMergeTree, AggregateFunction, and Materialized Views

Big Data Technology & Architecture

Mar 29, 2021 · Big Data

Understanding Flink AggregateFunction, Session Windows, and Timer Mechanisms

This article explains how Flink's DataStream API uses AggregateFunction and session windows, details the MergingWindowAssigner and MergingWindowSet implementations, and demonstrates timer registration and processing with KeyedProcessFunction, providing full code examples and internal workflow analysis.

AggregateFunctionFlinkKeyedProcessFunction

0 likes · 25 min read

Understanding Flink AggregateFunction, Session Windows, and Timer Mechanisms