com.hazelcast.jet.stream

Interface DistributedCollector.Reducer<T,R>

Type Parameters:

T - the type of input elements to the reduction operation

R - the result type of the reduction operation

All Superinterfaces:

Serializable

Enclosing interface:

DistributedCollector<T,A,R>

public static interface DistributedCollector.Reducer<T,R>
extends Serializable

Interface for Jet-specific distributed reducers which execute the terminal reduce operation over the current DistributedStream by building and executing a DAG. These reducers can't be used as downstream collectors.

Method Summary

Modifier and Type	Method and Description
R	reduce(com.hazelcast.jet.stream.impl.pipeline.StreamContext context, com.hazelcast.jet.stream.impl.pipeline.Pipe<? extends T> upstream) Executes the reducer with the given context and upstream pipeline.

Method Detail

reduce

R reduce(com.hazelcast.jet.stream.impl.pipeline.StreamContext context,
         com.hazelcast.jet.stream.impl.pipeline.Pipe<? extends T> upstream)

Executes the reducer with the given context and upstream pipeline.

Parameters:

context - the context of the stream

upstream - the upstream pipeline to execute the stream on

Returns:

the result of the executed collector