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.