Package org.apache.nemo.common.ir.vertex.utility.runtimepass

Interface MessageAggregatorVertex.MessageAggregatorFunction<K,V,O>

Type Parameters:

K - of the input pair.

V - of the input pair.

O - of the output aggregated message.

All Superinterfaces:

java.util.function.BiFunction<Pair<K,V>,O,O>, java.io.Serializable

Enclosing class:

MessageAggregatorVertex<K,V,O>

public static interface MessageAggregatorVertex.MessageAggregatorFunction<K,V,O>
extends java.util.function.BiFunction<Pair<K,V>,O,O>, java.io.Serializable

Aggregates incoming messages.

Method Summary

Methods inherited from interface java.util.function.BiFunction

andThen, apply