Uses of Interface
com.hazelcast.jet.pipeline.GeneralStageWithKey
Package
Description
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of GeneralStageWithKey in com.hazelcast.jet.pipeline
Modifier and TypeInterfaceDescriptioninterface
BatchStageWithKey<T,
K> An intermediate step while constructing a group-and-aggregate batch pipeline stage.interface
StreamStageWithKey<T,
K> An intermediate step while constructing a pipeline transform that involves a grouping key, such as windowed group-and-aggregate.Modifier and TypeMethodDescription<K> GeneralStageWithKey<T,
K> GeneralStage.groupingKey
(FunctionEx<? super T, ? extends K> keyFn) Specifies the function that will extract a key from the items in the associated pipeline stage.