Uses of Package
org.apache.nemo.common.ir.vertex.utility.runtimepass
-
Classes in org.apache.nemo.common.ir.vertex.utility.runtimepass used by org.apache.nemo.common.ir Class Description MessageAggregatorVertex Aggregates upstream messages.MessageGeneratorVertex Produces a message for run-time pass.SignalVertex Signal vertex holding signal transform. -
Classes in org.apache.nemo.common.ir.vertex.utility.runtimepass used by org.apache.nemo.common.ir.vertex.transform Class Description MessageAggregatorVertex.InitialStateSupplier Creates the initial aggregated message.MessageAggregatorVertex.MessageAggregatorFunction Aggregates incoming messages.MessageGeneratorVertex.MessageGeneratorFunction Applied on the input data elements to produce a message. -
Classes in org.apache.nemo.common.ir.vertex.utility.runtimepass used by org.apache.nemo.common.ir.vertex.utility.runtimepass Class Description MessageAggregatorVertex.InitialStateSupplier Creates the initial aggregated message.MessageAggregatorVertex.MessageAggregatorFunction Aggregates incoming messages.MessageGeneratorVertex.MessageGeneratorFunction Applied on the input data elements to produce a message.