A
- the type of the accumulatorpublic static class AggregateOperationBuilder.VarArity<A> extends Object
accumulate
primitives and associates
them with Tag
s. Does not capture the static type of the
stream items.Modifier and Type | Method and Description |
---|---|
<T> AggregateOperationBuilder.VarArity<A> |
andAccumulate(Tag<T> tag,
DistributedBiConsumer<? super A,T> accumulateFn)
Registers the supplied
accumulate primitive for the stream tagged
with the supplied tag. |
AggregateOperationBuilder.VarArity<A> |
andCombine(DistributedBiConsumer<? super A,? super A> combineFn)
Registers the
combine primitive. |
AggregateOperationBuilder.VarArity<A> |
andDeduct(DistributedBiConsumer<? super A,? super A> deductFn)
Registers the
deduct primitive. |
<R> AggregateOperation<A,R> |
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> |
andIdentityFinish()
Constructs and returns an
AggregateOperation from the current
state of the builder, with the identity function as the finish primitive. |
@Nonnull public <T> AggregateOperationBuilder.VarArity<A> andAccumulate(@Nonnull Tag<T> tag, @Nonnull DistributedBiConsumer<? super A,T> accumulateFn)
accumulate
primitive for the stream tagged
with the supplied tag.T
- the expected type of input itemtag
- the tag of the associated input streamaccumulateFn
- the accumulate
primitive@Nonnull public AggregateOperationBuilder.VarArity<A> andCombine(DistributedBiConsumer<? super A,? super A> combineFn)
combine
primitive.@Nonnull public AggregateOperationBuilder.VarArity<A> andDeduct(DistributedBiConsumer<? super A,? super A> deductFn)
deduct
primitive.@Nonnull public <R> AggregateOperation<A,R> andFinish(@Nonnull DistributedFunction<? super A,R> finishFn)
AggregateOperation
from the
current state of the builder and the supplied finish
primitive.@Nonnull public AggregateOperation<A,A> andIdentityFinish()
AggregateOperation
from the current
state of the builder, with the identity function as the finish
primitive.Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.