Uses of Interface
com.hazelcast.jet.aggregate.AggregateOperation
Packages that use 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
Subinterfaces of AggregateOperation in com.hazelcast.jet.aggregateModifier and TypeInterfaceDescriptioninterfaceAggregateOperation1<T,A, R> Specialization ofAggregateOperation(refer to its extensive documentation) to the "arity-1" case with a single data stream being aggregated over.interfaceAggregateOperation2<T0,T1, A, R> Specialization ofAggregateOperation(refer to its extensive documentation) to the "arity-2" case with two data streams being aggregated over.interfaceAggregateOperation3<T0,T1, T2, A, R> Specialization ofAggregateOperation(refer to its extensive documentation) to the "arity-3" case with three data streams being aggregated over.Methods in com.hazelcast.jet.aggregate that return AggregateOperationModifier 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 thefinishprimitive.<R_NEW> AggregateOperation<A,R_NEW> AggregateOperation.andThen(FunctionEx<? super R, ? extends R_NEW> thenFn) Returns a copy of this aggregate operation, but with theexportandfinishprimitives 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 theaccumulateprimitives replaced with the ones supplied here.AggregateOperation.withIdentityFinish()Returns a copy of this aggregate operation, but with thefinishprimitive replaced with the identity function. -
Uses of AggregateOperation in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type AggregateOperationModifier 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 Javadocfor 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 Javadocfor 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 Javadocfor 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 Javadocfor 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 Javadocfor 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 Javadocfor an explanation of aggregation stages) with specifiedwindowWatermarkKey. -
Uses of AggregateOperation in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline with parameters of type AggregateOperationModifier 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.