Class MessageAggregatorVertex<K,​V,​O>

  • Type Parameters:
    K - of the input pair.
    V - of the input pair.
    O - of the output aggregated message.
    All Implemented Interfaces:
    Serializable, Cloneable<IRVertex>

    public final class MessageAggregatorVertex<K,​V,​O>
    extends OperatorVertex
    Aggregates upstream messages.
    See Also:
    Serialized Form