public interface DistributedCollector<T,A,R> extends Collector<T,A,R>, Serializable
Serializable
variant of java.util.stream.Collector
.Modifier and Type | Interface and Description |
---|---|
static interface |
DistributedCollector.Reducer<T,R>
Interface for Jet-specific distributed reducers which execute the
terminal reduce operation over the current
DistributedStream
by building and executing a DAG. |
Collector.Characteristics
Modifier and Type | Method and Description |
---|---|
DistributedBiConsumer<A,T> |
accumulator() |
default Set<Collector.Characteristics> |
characteristics() |
DistributedBinaryOperator<A> |
combiner() |
DistributedFunction<A,R> |
finisher() |
static <T,A,R> DistributedCollector<T,A,R> |
of(DistributedSupplier<A> supplier,
DistributedBiConsumer<A,T> accumulator,
DistributedBinaryOperator<A> combiner,
DistributedFunction<A,R> finisher)
|
static <T,R> DistributedCollector<T,R,R> |
of(DistributedSupplier<R> supplier,
DistributedBiConsumer<R,T> accumulator,
DistributedBinaryOperator<R> combiner)
Serializable variant of java.util.stream.Collector#of(Supplier, BiConsumer, BinaryOperator, Characteristics...) |
DistributedSupplier<A> |
supplier() |
static <T,R> DistributedCollector<T,R,R> of(DistributedSupplier<R> supplier, DistributedBiConsumer<R,T> accumulator, DistributedBinaryOperator<R> combiner)
Serializable
variant of java.util.stream.Collector#of(Supplier, BiConsumer, BinaryOperator, Characteristics...)
static <T,A,R> DistributedCollector<T,A,R> of(DistributedSupplier<A> supplier, DistributedBiConsumer<A,T> accumulator, DistributedBinaryOperator<A> combiner, DistributedFunction<A,R> finisher)
DistributedBiConsumer<A,T> accumulator()
accumulator
in interface Collector<T,A,R>
DistributedBinaryOperator<A> combiner()
default Set<Collector.Characteristics> characteristics()
characteristics
in interface Collector<T,A,R>
Copyright © 2018 Hazelcast, Inc.. All rights reserved.