Uses of Interface
com.hazelcast.jet.aggregate.AggregateOperation
Package
Description
Contains
AggregateOperation
and its several variants, as well
as a builder object for the aggregate operations.Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of AggregateOperation in com.hazelcast.jet.aggregate
Modifier and TypeInterfaceDescriptioninterface
AggregateOperation1<T,
A, R> Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over.interface
AggregateOperation2<T0,
T1, A, R> Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-2" case with two data streams being aggregated over.interface
AggregateOperation3<T0,
T1, T2, A, R> Specialization ofAggregateOperation
(refer to its extensive documentation) to the "arity-3" case with three data streams being aggregated over.Modifier and TypeMethodDescription<R_NEW> AggregateOperation<A,
R_NEW> AggregateOperationBuilder.VarArity.andExportFinish
(FunctionEx<? super A, ? extends R_NEW> exportFinishFn) AggregateOperationBuilder.VarArity.andFinish
(FunctionEx<? super A, ? extends R> finishFn) Registers thefinish
primitive.<R_NEW> AggregateOperation<A,
R_NEW> AggregateOperation.andThen
(FunctionEx<? super R, ? extends R_NEW> thenFn) Returns a copy of this aggregate operation, but with theexport
andfinish
primitives composed with the suppliedthenFn
.CoAggregateOperationBuilder.build()
Builds and returns theAggregateOperation
.<R> AggregateOperation<Object[],
R> CoAggregateOperationBuilder.build
(FunctionEx<? super ItemsByTag, ? extends R> exportFinishFn) Builds and returns the multi-inputAggregateOperation
.AggregateOperation.withAccumulateFns
(BiConsumerEx... accumulateFns) Returns a copy of this aggregate operation, but with all theaccumulate
primitives replaced with the ones supplied here.AggregateOperation.withIdentityFinish()
Returns a copy of this aggregate operation, but with thefinish
primitive replaced with the identity function. -
Uses of AggregateOperation in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <K,
A> SupplierEx<Processor> Processors.accumulateByFrameP
(List<FunctionEx<?, ? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, AggregateOperation<A, ?> aggrOp) Returns a supplier of processors for the first-stage vertex in a two-stage sliding window aggregation setup (see theclass Javadoc
for an explanation of aggregation stages).static <K,
A> SupplierEx<Processor> Processors.accumulateByFrameP
(List<FunctionEx<?, ? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, AggregateOperation<A, ?> aggrOp, byte watermarkKey) Returns a supplier of processors for the first-stage vertex in a two-stage sliding window aggregation setup (see theclass Javadoc
for an explanation of aggregation stages).static <K,
A> SupplierEx<Processor> Processors.accumulateByKeyP
(List<FunctionEx<?, ? extends K>> getKeyFns, AggregateOperation<A, ?> aggrOp) Returns a supplier of processors for the first-stage vertex in a two-stage group-and-aggregate setup.static <A,
R> SupplierEx<Processor> Processors.accumulateP
(AggregateOperation<A, R> aggrOp) Returns a supplier of processors for a vertex that performs the accumulation step of the provided aggregate operation on all the items it receives.static <K,
A, R, OUT>
SupplierEx<Processor>Processors.aggregateByKeyP
(List<FunctionEx<?, ? extends K>> keyFns, AggregateOperation<A, R> aggrOp, BiFunctionEx<? super K, ? super R, OUT> mapToOutputFn) Returns a supplier of processors for a vertex that groups items by key and performs the provided aggregate operation on each group.static <A,
R> SupplierEx<Processor> Processors.aggregateP
(AggregateOperation<A, R> aggrOp) Returns a supplier of processors for a vertex that performs the provided aggregate operation on all the items it receives.static <K,
A, R, OUT>
SupplierEx<Processor>Processors.aggregateToSessionWindowP
(long sessionTimeout, long earlyResultsPeriod, List<ToLongFunctionEx<?>> timestampFns, List<FunctionEx<?, ? extends K>> keyFns, AggregateOperation<A, ? extends R> aggrOp, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT> mapToOutputFn) Returns a supplier of processors for a vertex that aggregates events into session windows.static <K,
A, R, OUT>
SupplierEx<Processor>Processors.aggregateToSlidingWindowP
(List<FunctionEx<?, ? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, long earlyResultsPeriod, AggregateOperation<A, ? extends R> aggrOp, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT> mapToOutputFn) Returns a supplier of processors for a vertex that aggregates events into a sliding window in a single stage (see theclass Javadoc
for an explanation of aggregation stages).static <K,
A, R, OUT>
SupplierEx<Processor>Processors.aggregateToSlidingWindowP
(List<FunctionEx<?, ? extends K>> keyFns, List<ToLongFunctionEx<?>> timestampFns, TimestampKind timestampKind, SlidingWindowPolicy winPolicy, long earlyResultsPeriod, AggregateOperation<A, ? extends R> aggrOp, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT> mapToOutputFn, byte windowWatermarkKey) Returns a supplier of processors for a vertex that aggregates events into a sliding window in a single stage (see theclass Javadoc
for an explanation of aggregation stages).static <K,
A, R, OUT>
SupplierEx<Processor>Processors.combineByKeyP
(AggregateOperation<A, R> aggrOp, BiFunctionEx<? super K, ? super R, OUT> mapToOutputFn) Returns a supplier of processors for the second-stage vertex in a two-stage group-and-aggregate setup.static <A,
R> SupplierEx<Processor> Processors.combineP
(AggregateOperation<A, R> aggrOp) Returns a supplier of processors for a vertex that performs the combining and finishing steps of the provided aggregate operation.static <K,
A, R, OUT>
SupplierEx<Processor>Processors.combineToSlidingWindowP
(SlidingWindowPolicy winPolicy, AggregateOperation<A, ? extends R> aggrOp, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT> mapToOutputFn) Returns a supplier of processors for the second-stage vertex in a two-stage sliding window aggregation setup (see theclass Javadoc
for an explanation of aggregation stages).static <K,
A, R, OUT>
SupplierEx<Processor>Processors.combineToSlidingWindowP
(SlidingWindowPolicy winPolicy, AggregateOperation<A, ? extends R> aggrOp, KeyedWindowResultFunction<? super K, ? super R, ? extends OUT> mapToOutputFn, byte windowWatermarkKey) Returns a supplier of processors for the second-stage vertex in a two-stage sliding window aggregation setup (see theclass Javadoc
for an explanation of aggregation stages) with specifiedwindowWatermarkKey
. -
Uses of AggregateOperation in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<R> BatchStage<R>
AggregateBuilder1.build
(AggregateOperation<?, R> aggrOp) Creates and returns a pipeline stage that performs the co-aggregation of pipeline stages registered with this builder object.<R> BatchStage<Map.Entry<K,
R>> GroupAggregateBuilder1.build
(AggregateOperation<?, R> aggrOp) Creates and returns a pipeline stage that performs the co-grouping and aggregation of pipeline stages registered with this builder object.<R,
OUT> BatchStage<OUT> GroupAggregateBuilder1.build
(AggregateOperation<?, R> aggrOp, BiFunctionEx<? super K, ? super R, OUT> mapToOutputFn) Deprecated.This is a leftover from an earlier development cycle of the Pipeline API.<A,
R> StreamStage<WindowResult<R>> WindowAggregateBuilder1.build
(AggregateOperation<A, R> aggrOp) Creates and returns a pipeline stage that performs a windowed co-aggregation of the pipeline stages registered with this builder object.<R> StreamStage<KeyedWindowResult<K,
R>> WindowGroupAggregateBuilder1.build
(AggregateOperation<?, ? extends R> aggrOp) Creates and returns a pipeline stage that performs a windowed cogroup-and-aggregate of the pipeline stages registered with this builder object.