com.hazelcast.jet.pipeline

Interface StreamStageWithGrouping<T,K>

Type Parameters:

T - type of the stream items

K - type of the key

All Superinterfaces:

GeneralStageWithGrouping<T,K>

public interface StreamStageWithGrouping<T,K>
extends GeneralStageWithGrouping<T,K>

Represents an intermediate step while constructing a windowed group-and-aggregate pipeline stage. It captures the grouping key and offers a method to specify the window definition.

Method Summary

Modifier and Type	Method and Description
StageWithGroupingAndWindow<T,K>	window(WindowDefinition wDef) Adds the definition of the window to use in the group-and-aggregate pipeline stage being constructed.

Methods inherited from interface com.hazelcast.jet.pipeline.GeneralStageWithGrouping

keyFn

Method Detail

window

@Nonnull
StageWithGroupingAndWindow<T,K> window(@Nonnull
                                                WindowDefinition wDef)

Adds the definition of the window to use in the group-and-aggregate pipeline stage being constructed.