[
https://issues.apache.org/jira/browse/KAFKA-20649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hannes Buseyne updated KAFKA-20649:
-----------------------------------
Priority: Major (was: Minor)
> 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
> Priority: Major
> Labels: kip
>
> 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)
