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

Class MessageAggregatorVertex<K,V,O>

java.lang.Object

org.apache.nemo.common.dag.Vertex

org.apache.nemo.common.ir.vertex.IRVertex

org.apache.nemo.common.ir.vertex.OperatorVertex

org.apache.nemo.common.ir.vertex.utility.runtimepass.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:

java.io.Serializable, Cloneable<IRVertex>

public final class MessageAggregatorVertex<K,V,O>
extends OperatorVertex

Aggregates upstream messages.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MessageAggregatorVertex.InitialStateSupplier<O>	Creates the initial aggregated message.
static interface	MessageAggregatorVertex.MessageAggregatorFunction<K,V,O>	Aggregates incoming messages.

Constructor Summary

Constructors

Constructor	Description
MessageAggregatorVertex(MessageAggregatorVertex.InitialStateSupplier<O> initialStateSupplier, MessageAggregatorVertex.MessageAggregatorFunction<K,V,O> userFunction)

Method Summary

Methods inherited from class org.apache.nemo.common.ir.vertex.OperatorVertex

getClone, getPropertiesAsJsonNode, getTransform

Methods inherited from class org.apache.nemo.common.ir.vertex.IRVertex

copyExecutionPropertiesTo, getExecutionProperties, getIRVertexPropertiesAsJsonNode, getPropertyValue, isUtilityVertex, setProperty, setPropertyPermanently

Methods inherited from class org.apache.nemo.common.dag.Vertex

getId, getNumericId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessageAggregatorVertex

public MessageAggregatorVertex(MessageAggregatorVertex.InitialStateSupplier<O> initialStateSupplier,
                               MessageAggregatorVertex.MessageAggregatorFunction<K,V,O> userFunction)

Parameters:

initialStateSupplier - for producing the initial state.

userFunction - for aggregating the messages.