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

Class MessageGeneratorVertex<I,K,V>

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.MessageGeneratorVertex<I,K,V>

Type Parameters:

I - input type

K - of the output pair.

V - of the output pair.

All Implemented Interfaces:

java.io.Serializable, Cloneable<IRVertex>

public final class MessageGeneratorVertex<I,K,V>
extends OperatorVertex

Produces a message for run-time pass.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MessageGeneratorVertex.MessageGeneratorFunction<I,K,V>	Applied on the input data elements to produce a message.

Constructor Summary

Constructors

Constructor	Description
MessageGeneratorVertex(MessageGeneratorVertex.MessageGeneratorFunction<I,K,V> messageFunction)

Method Summary

Modifier and Type	Method	Description
MessageGeneratorVertex.MessageGeneratorFunction<I,K,V>	getMessageFunction()

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

MessageGeneratorVertex

public MessageGeneratorVertex(MessageGeneratorVertex.MessageGeneratorFunction<I,K,V> messageFunction)

Parameters:

messageFunction - for producing a message.

Method Detail

getMessageFunction

public MessageGeneratorVertex.MessageGeneratorFunction<I,K,V> getMessageFunction()