com.hazelcast.mapreduce
Interface ReducerFactory<KeyIn,ValueIn,ValueOut>

Type Parameters:

KeyIn - key type of the resulting keys

ValueIn - value type of the incoming values

ValueOut - value type of the reduced values

All Superinterfaces:

Serializable

@Beta
public interface ReducerFactory<KeyIn,ValueIn,ValueOut>
extends Serializable

A ReducerFactory implementation is used to build Reducer instances per key.
An implementation needs to be serializable by Hazelcast since it might be distributed inside the cluster to do parallel calculations of reducing step.

Since:

3.2

Method Summary

Reducer<KeyIn,ValueIn,ValueOut>

newReducer(KeyIn key) Build a new Reducer instance specific to the supplied key.

Method Detail

newReducer

Reducer<KeyIn,ValueIn,ValueOut> newReducer(KeyIn key)

Build a new Reducer instance specific to the supplied key.

Parameters:

key - key the Reducer is build for

Returns:

a Reducer instance specific for the given key