KGroupedStreamImpl¶

KGroupedStreamImpl is a KGroupedStream (and an AbstractStream).

Creating Instance¶

KGroupedStreamImpl takes the following to be created:

• Name
• Sub-Topology Source Nodes (Names)
• GroupedInternal<K, V>
• repartitionRequired flag
• GraphNode
• InternalStreamsBuilder

KGroupedStreamImpl is created when:

• KStreamImpl is requested to groupBy and groupByKey

GroupedStreamAggregateBuilder¶

KGroupedStreamImpl creates a GroupedStreamAggregateBuilder when created.

repartitionRequired Flag¶

KGroupedStreamImpl is given a repartitionRequired flag when created.

The repartitionRequired flag is always true for groupBy.