Hannes Buseyne created KAFKA-20649:
--------------------------------------
Summary: KIP-1352: Ranges and Range Aggregations in the Kafka
Streams DSL
Key: KAFKA-20649
URL: https://issues.apache.org/jira/browse/KAFKA-20649
Project: Kafka
Issue Type: New Feature
Components: streams
Reporter: Hannes Buseyne
Assignee: Hannes Buseyne
This ticket tracks the implementation for {*}KIP-1352: Ranges and Range
Aggregations in the Kafka Streams DSL{*}.
*KIP Document:*
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-1352%3A+Ranges+and+Range+Aggregations+in+the+Kafka+Streams+DSL]
*Summary:* The Kafka Streams DSL currently excels at temporal grouping through
fixed, sliding, and hopping windows, but lacks a native mechanism for
event-centric, non-incremental aggregations (similar to SQL's {{OVER}} clause
with {{{}ROWS/RANGE BETWEEN{}}}).
This KIP introduces a new {{Range}} abstraction ({{{}EventTimeRange{}}} and
{{{}EventCountRange{}}}) and a {{rangeOver()}} operator for
{{{}KGroupedStream{}}}. This allows developers to define dynamic contexts
around specific anchor records and perform point-in-time aggregations without
emitting retroactive updates or causing exponential write amplification.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
