Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.aggregate |
Contains
AggregateOperation and several its variants, as well
as a builder object for the aggregate operations. |
com.hazelcast.jet.core.processor |
Apache Kafka reader/writer support for Hazelcast Jet.
|
Modifier and Type | Method and Description |
---|---|
<A,R> ComputeStage<Tuple2<K,R>> |
CoGroupBuilder.build(AggregateOperation<A,R> aggrOp)
Builds a new pipeline stage that performs the co-grouping operation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AggregateOperation1<T,A,R>
Specialization of
AggregateOperation to the "arity-1" case with
a single data stream being aggregated over. |
interface |
AggregateOperation2<T0,T1,A,R>
Specialization of
AggregateOperation to the "arity-2" case with
two data stream being aggregated over. |
interface |
AggregateOperation3<T0,T1,T2,A,R>
Specialization of
AggregateOperation to the "arity-3" case with
two data stream being aggregated over. |
Modifier and Type | Method and Description |
---|---|
<R> AggregateOperation<A,R> |
AggregateOperationBuilder.VarArity.andFinish(DistributedFunction<? super A,R> finishFn)
Constructs and returns an
AggregateOperation from the
current state of the builder and the supplied finish primitive. |
AggregateOperation<A,A> |
AggregateOperationBuilder.VarArity.andIdentityFinish()
Constructs and returns an
AggregateOperation from the current
state of the builder, with the identity function as the finish primitive. |
<R_NEW> AggregateOperation<A,R_NEW> |
AggregateOperation.withFinishFn(DistributedFunction<? super A,R_NEW> finishFn)
Returns a copy of this aggregate operation, but with the
finish
primitive replaced with the supplied one. |
Modifier and Type | Method and Description |
---|---|
static <K,A> DistributedSupplier<Processor> |
Processors.coAccumulateByKeyP(List<DistributedFunction<?,? extends K>> getKeyFs,
AggregateOperation<A,?> aggrOp)
Returns a supplier of processors for the first-stage vertex in a
two-stage group-and-aggregate setup.
|
static <K,A,R> DistributedSupplier<Processor> |
Processors.coAggregateByKeyP(List<DistributedFunction<?,? extends K>> getKeyFs,
AggregateOperation<A,R> aggrOp)
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> DistributedSupplier<Processor> |
Processors.combineByKeyP(AggregateOperation<A,R> aggrOp)
Returns a supplier of processors for the second-stage vertex in a
two-stage group-and-aggregate setup.
|
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.