T
- type of the stream itemsK
- type of the keypublic interface StreamStageWithGrouping<T,K> extends GeneralStageWithGrouping<T,K>
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.
|
keyFn
@Nonnull StageWithGroupingAndWindow<T,K> window(@Nonnull WindowDefinition wDef)
Copyright © 2018 Hazelcast, Inc.. All rights reserved.