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

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:
    BiFunction<Pair<K,​V>,​O,​O>, Serializable
    Enclosing class:
    MessageAggregatorVertex<K,​V,​O>
    public static interface MessageAggregatorVertex.MessageAggregatorFunction<K,​V,​O>
extends BiFunction<Pair<K,​V>,​O,​O>, Serializable
    Aggregates incoming messages.