Package | Description |
---|---|
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 |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.function |
Serializable variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
DistributedBiConsumer<? super A,? super T> |
AggregateOperation1.accumulateFn()
A primitive that updates the accumulator state to account for a new
item.
|
<T> DistributedBiConsumer<? super A,? super T> |
AggregateOperation.accumulateFn(int index)
A primitive that updates the accumulator state to account for a new
item.
|
default <T> DistributedBiConsumer<? super A,? super T> |
AggregateOperation.accumulateFn(Tag<T> tag)
A primitive that updates the accumulator state to account for a new
item.
|
DistributedBiConsumer<? super A,? super T0> |
AggregateOperation3.accumulateFn0()
A primitive that updates the accumulator state to account for a new
item coming from stream-0.
|
DistributedBiConsumer<? super A,? super T0> |
AggregateOperation2.accumulateFn0()
A primitive that updates the accumulator state to account for a new
item coming from stream-0.
|
DistributedBiConsumer<? super A,? super T1> |
AggregateOperation3.accumulateFn1()
A primitive that updates the accumulator state to account for a new
item coming from stream-1.
|
DistributedBiConsumer<? super A,? super T1> |
AggregateOperation2.accumulateFn1()
A primitive that updates the accumulator state to account for a new
item coming from stream-1.
|
DistributedBiConsumer<? super A,? super T2> |
AggregateOperation3.accumulateFn2()
A primitive that updates the accumulator state to account for a new
item coming from stream-2.
|
DistributedBiConsumer<? super A,? super A> |
AggregateOperation.combineFn()
A primitive that accepts two accumulators and updates the state of the
left-hand one by combining it with the state of the right-hand one.
|
DistributedBiConsumer<? super A,? super A> |
AggregateOperation.deductFn()
A primitive that accepts two accumulators and updates the state of the
left-hand one by deducting the state of the right-hand one from it.
|
Modifier and Type | Method and Description |
---|---|
<T> AggregateOperationBuilder.Arity1<T,A> |
AggregateOperationBuilder.andAccumulate(DistributedBiConsumer<? super A,T> accumulateFn)
Registers the supplied
accumulate primitive. |
<T> AggregateOperationBuilder.VarArity<A> |
AggregateOperationBuilder.andAccumulate(Tag<T> tag,
DistributedBiConsumer<? super A,T> accumulateFn)
Registers the supplied
accumulate primitive for the stream tagged
with the supplied tag. |
<T> AggregateOperationBuilder.VarArity<A> |
AggregateOperationBuilder.VarArity.andAccumulate(Tag<T> tag,
DistributedBiConsumer<? super A,T> accumulateFn)
Registers the supplied
accumulate primitive for the stream tagged
with the supplied tag. |
<T0> AggregateOperationBuilder.Arity1<T0,A> |
AggregateOperationBuilder.andAccumulate0(DistributedBiConsumer<? super A,T0> accumulateFn0)
Registers the supplied
accumulate primitive for stream-0. |
<T1> AggregateOperationBuilder.Arity2<T0,T1,A> |
AggregateOperationBuilder.Arity1.andAccumulate1(DistributedBiConsumer<? super A,T1> accumulateFn1)
Registers the supplied
accumulate primitive for stream-1,
returning the arity-2 variant of the builder. |
<T2> AggregateOperationBuilder.Arity3<T0,T1,T2,A> |
AggregateOperationBuilder.Arity2.andAccumulate2(DistributedBiConsumer<? super A,T2> accumulateFn2)
Registers the supplied
accumulate primitive for stream-2,
returning the arity-3 variant of the builder. |
AggregateOperationBuilder.Arity1<T0,A> |
AggregateOperationBuilder.Arity1.andCombine(DistributedBiConsumer<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.Arity2<T0,T1,A> |
AggregateOperationBuilder.Arity2.andCombine(DistributedBiConsumer<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.Arity3<T0,T1,T2,A> |
AggregateOperationBuilder.Arity3.andCombine(DistributedBiConsumer<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.VarArity<A> |
AggregateOperationBuilder.VarArity.andCombine(DistributedBiConsumer<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.Arity1<T0,A> |
AggregateOperationBuilder.Arity1.andDeduct(DistributedBiConsumer<? super A,? super A> deductFn)
Registers the
deduct primitive. |
AggregateOperationBuilder.Arity2<T0,T1,A> |
AggregateOperationBuilder.Arity2.andDeduct(DistributedBiConsumer<? super A,? super A> deductFn)
Registers the
deduct primitive. |
AggregateOperationBuilder.Arity3<T0,T1,T2,A> |
AggregateOperationBuilder.Arity3.andDeduct(DistributedBiConsumer<? super A,? super A> deductFn)
Registers the
deduct primitive. |
AggregateOperationBuilder.VarArity<A> |
AggregateOperationBuilder.VarArity.andDeduct(DistributedBiConsumer<? super A,? super A> deductFn)
Registers the
deduct primitive. |
<NEW_T> AggregateOperation1<NEW_T,A,R> |
AggregateOperation1.withAccumulateFn(DistributedBiConsumer<? super A,? super NEW_T> accumulateFn)
Returns a copy of this aggregate operation, but with the
accumulate primitive replaced with the one supplied here. |
<T0_NEW> AggregateOperation3<T0_NEW,T1,T2,A,R> |
AggregateOperation3.withAccumulateFn0(DistributedBiConsumer<? super A,? super T0_NEW> newAccFn0)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 0 replaced with the one supplied here. |
<T0_NEW> AggregateOperation2<T0_NEW,T1,A,R> |
AggregateOperation2.withAccumulateFn0(DistributedBiConsumer<? super A,? super T0_NEW> newAccFn0)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 0 replaced with the one supplied here. |
<T1_NEW> AggregateOperation3<T0,T1_NEW,T2,A,R> |
AggregateOperation3.withAccumulateFn1(DistributedBiConsumer<? super A,? super T1_NEW> newAccFn1)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 1 replaced with the one supplied here. |
<T1_NEW> AggregateOperation2<T0,T1_NEW,A,R> |
AggregateOperation2.withAccumulateFn1(DistributedBiConsumer<? super A,? super T1_NEW> newAccFn1)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 1 replaced with the one supplied here. |
<T2_NEW> AggregateOperation3<T0,T1,T2_NEW,A,R> |
AggregateOperation3.withAccumulateFn2(DistributedBiConsumer<? super A,? super T2_NEW> newAccFn2)
Returns a copy of this aggregate operation, but with the
accumulate primitive at index 2 replaced with the one supplied here. |
AggregateOperation<A,R> |
AggregateOperation.withAccumulateFns(DistributedBiConsumer... accumulateFns)
Returns a copy of this aggregate operation, but with all the
accumulate primitives replaced with the ones supplied here. |
Modifier and Type | Method and Description |
---|---|
static <W,T> DistributedSupplier<Processor> |
SinkProcessors.writeBufferedP(DistributedFunction<? super Processor.Context,? extends W> createFn,
DistributedBiConsumer<? super W,? super T> onReceiveFn,
DistributedConsumer<? super W> flushFn,
DistributedConsumer<? super W> destroyFn)
Returns a supplier of processors for a vertex that drains all the items
from the inbox to an internal writer object and then does a flush.
|
static <W,T> DistributedSupplier<Processor> |
SinkProcessors.writeBufferedP(DistributedFunction<Processor.Context,W> createFn,
DistributedBiConsumer<W,T> onReceiveFn,
DistributedConsumer<W> flushFn)
Shortcut for
SinkProcessors.writeBufferedP(DistributedFunction,
DistributedBiConsumer, DistributedConsumer, DistributedConsumer) with
a no-op destroyFn . |
Modifier and Type | Method and Description |
---|---|
default DistributedBiConsumer<T,U> |
DistributedBiConsumer.andThen(DistributedBiConsumer<? super T,? super U> after)
Serializable variant of
java.util.function.BiConsumer#andThen(BiConsumer) . |
Modifier and Type | Method and Description |
---|---|
default DistributedBiConsumer<T,U> |
DistributedBiConsumer.andThen(DistributedBiConsumer<? super T,? super U> after)
Serializable variant of
java.util.function.BiConsumer#andThen(BiConsumer) . |
Modifier and Type | Method and Description |
---|---|
SinkBuilder<W,T> |
SinkBuilder.onReceiveFn(DistributedBiConsumer<? super W,? super T> onReceiveFn)
Sets the function Jet will call upon receiving an item.
|
Modifier and Type | Method and Description |
---|---|
DistributedBiConsumer<A,T> |
DistributedCollector.accumulator() |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.