Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Interface and Description |
---|---|
interface |
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 Type | Method and Description |
---|---|
<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.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.