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

Interface Summary

Interface	Description
MessageAggregatorVertex.InitialStateSupplier<O>	Creates the initial aggregated message.
MessageAggregatorVertex.MessageAggregatorFunction<K,V,O>	Aggregates incoming messages.
MessageGeneratorVertex.MessageGeneratorFunction<I,K,V>	Applied on the input data elements to produce a message.

Class Summary

Class	Description
MessageAggregatorVertex<K,V,O>	Aggregates upstream messages.
MessageGeneratorVertex<I,K,V>	Produces a message for run-time pass.
SignalVertex	Signal vertex holding signal transform.