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 |
Apache Kafka reader/writer support for Hazelcast Jet.
|
com.hazelcast.jet.function |
Serializable variants of functional interfaces from
java.util.function . |
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. |
Modifier and Type | Method and Description |
---|---|
static <B,T> ProcessorSupplier |
SinkProcessors.writeBufferedP(DistributedIntFunction<B> newBufferFn,
DistributedBiConsumer<B,T> addToBufferFn,
DistributedConsumer<B> flushBufferFn)
Returns a supplier of processors for a vertex that drains all the items
from its inbox to an intermediate buffer and then flushes the buffer.
|
static <B,T> ProcessorSupplier |
SinkProcessors.writeBufferedP(DistributedIntFunction<B> newBufferFn,
DistributedBiConsumer<B,T> addToBufferFn,
DistributedConsumer<B> flushBufferFn,
DistributedConsumer<B> disposeBufferFn)
Returns a supplier of processors for a vertex that drains all the items
from the inbox to an intermediate buffer and then flushes the buffer.
|
Modifier and Type | Method and Description |
---|---|
default DistributedBiConsumer<T,U> |
DistributedBiConsumer.andThen(DistributedBiConsumer<? super T,? super U> after)
Returns a composed
BiConsumer that performs, in sequence, this
operation followed by the after operation. |
Modifier and Type | Method and Description |
---|---|
default DistributedBiConsumer<T,U> |
DistributedBiConsumer.andThen(DistributedBiConsumer<? super T,? super U> after)
Returns a composed
BiConsumer that performs, in sequence, this
operation followed by the after operation. |
Modifier and Type | Method and Description |
---|---|
DistributedBiConsumer<A,T> |
DistributedCollector.accumulator()
A function that folds a value into a mutable result container.
|
Modifier and Type | Method and Description |
---|---|
default <R> R |
DistributedStream.collect(DistributedSupplier<R> supplier,
DistributedBiConsumer<R,? super T> accumulator,
DistributedBiConsumer<R,R> combiner)
Performs a mutable
reduction operation on the elements of this stream.
|
default <R> R |
DistributedStream.collect(DistributedSupplier<R> supplier,
DistributedBiConsumer<R,? super T> accumulator,
DistributedBiConsumer<R,R> combiner)
Performs a mutable
reduction operation on the elements of this stream.
|
default <R> R |
DistributedDoubleStream.collect(DistributedSupplier<R> supplier,
DistributedObjDoubleConsumer<R> accumulator,
DistributedBiConsumer<R,R> combiner)
Performs a mutable
reduction operation on the elements of this stream.
|
default <R> R |
DistributedIntStream.collect(DistributedSupplier<R> supplier,
DistributedObjIntConsumer<R> accumulator,
DistributedBiConsumer<R,R> combiner)
Performs a mutable
reduction operation on the elements of this stream.
|
default <R> R |
DistributedLongStream.collect(DistributedSupplier<R> supplier,
DistributedObjLongConsumer<R> accumulator,
DistributedBiConsumer<R,R> combiner)
Performs a mutable
reduction operation on the elements of this stream.
|
static <T,A,R> DistributedCollector<T,A,R> |
DistributedCollector.of(DistributedSupplier<A> supplier,
DistributedBiConsumer<A,T> accumulator,
DistributedBinaryOperator<A> combiner,
DistributedFunction<A,R> finisher,
java.util.stream.Collector.Characteristics... characteristics)
Returns a new
DistributedCollector described by the given supplier ,
accumulator , combiner , and finisher functions. |
static <T,R> DistributedCollector<T,R,R> |
DistributedCollector.of(DistributedSupplier<R> supplier,
DistributedBiConsumer<R,T> accumulator,
DistributedBinaryOperator<R> combiner,
java.util.stream.Collector.Characteristics... characteristics)
Returns a new
DistributedCollector described by the given supplier ,
accumulator , and combiner functions. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.