com.hazelcast.jet.stream

Interface DistributedCollector<T,A,R>

All Superinterfaces:

Collector<T,A,R>, Serializable

public interface DistributedCollector<T,A,R>
extends Collector<T,A,R>, Serializable

Serializable variant of java.util.stream.Collector.

Nested Class Summary

Nested Classes

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.

Nested classes/interfaces inherited from interface java.util.stream.Collector

Collector.Characteristics

Method Summary

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) Serializable variant of java.util.stream.Collector#of(Supplier, BiConsumer, BinaryOperator, Function, Characteristics...)
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()

Methods inherited from interface java.util.stream.Collector

of, of

Method Detail

of

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...)

of

static <T,A,R> DistributedCollector<T,A,R> of(DistributedSupplier<A> supplier,
                                              DistributedBiConsumer<A,T> accumulator,
                                              DistributedBinaryOperator<A> combiner,
                                              DistributedFunction<A,R> finisher)

Serializable variant of java.util.stream.Collector#of(Supplier, BiConsumer, BinaryOperator, Function, Characteristics...)

supplier

DistributedSupplier<A> supplier()

Specified by:

supplier in interface Collector<T,A,R>

accumulator

DistributedBiConsumer<A,T> accumulator()

Specified by:

accumulator in interface Collector<T,A,R>

combiner

DistributedBinaryOperator<A> combiner()

Specified by:

combiner in interface Collector<T,A,R>

finisher

DistributedFunction<A,R> finisher()

Specified by:

finisher in interface Collector<T,A,R>

characteristics

default Set<Collector.Characteristics> characteristics()

Specified by:

characteristics in interface Collector<T,A,R>