Uses of Package
org.apache.nemo.common.ir.vertex.utility
-
Packages that use org.apache.nemo.common.ir.vertex.utility Package Description org.apache.nemo.common.ir org.apache.nemo.common.ir.vertex.transform org.apache.nemo.common.ir.vertex.utility -
Classes in org.apache.nemo.common.ir.vertex.utility used by org.apache.nemo.common.ir Class Description MessageAggregatorVertex Aggregates upstream messages.RelayVertex Relays input data from upstream vertex to downstream vertex promptly.SamplingVertex Executes the original IRVertex using a subset of input data partitions.TriggerVertex Produces a message and triggers a run-time pass. -
Classes in org.apache.nemo.common.ir.vertex.utility used by org.apache.nemo.common.ir.vertex.transform Class Description MessageAggregatorVertex.InitialStateSupplier Creates the initial aggregated message.MessageAggregatorVertex.MessageAggregatorFunction Aggregates incoming messages.TriggerVertex.MessageGeneratorFunction Applied on the input data elements to produce a message. -
Classes in org.apache.nemo.common.ir.vertex.utility used by org.apache.nemo.common.ir.vertex.utility Class Description MessageAggregatorVertex.InitialStateSupplier Creates the initial aggregated message.MessageAggregatorVertex.MessageAggregatorFunction Aggregates incoming messages.TriggerVertex.MessageGeneratorFunction Applied on the input data elements to produce a message.