Uses of Class
org.apache.nemo.common.ir.vertex.OperatorVertex

Packages that use OperatorVertex

Package	Description
org.apache.nemo.common.ir.vertex
org.apache.nemo.common.ir.vertex.utility
org.apache.nemo.common.ir.vertex.utility.runtimepass
org.apache.nemo.runtime.executor.datatransfer

Uses of OperatorVertex in org.apache.nemo.common.ir.vertex

Methods in org.apache.nemo.common.ir.vertex that return OperatorVertex

Modifier and Type	Method	Description
OperatorVertex	OperatorVertex.getClone()

Uses of OperatorVertex in org.apache.nemo.common.ir.vertex.utility

Subclasses of OperatorVertex in org.apache.nemo.common.ir.vertex.utility

Modifier and Type	Class	Description
class	RelayVertex	Relays input data from upstream vertex to downstream vertex promptly.

Uses of OperatorVertex in org.apache.nemo.common.ir.vertex.utility.runtimepass

Subclasses of OperatorVertex in org.apache.nemo.common.ir.vertex.utility.runtimepass

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

Uses of OperatorVertex in org.apache.nemo.runtime.executor.datatransfer

Methods in org.apache.nemo.runtime.executor.datatransfer that return OperatorVertex

Modifier and Type	Method	Description
OperatorVertex	NextIntraTaskOperatorInfo.getNextOperator()

Constructors in org.apache.nemo.runtime.executor.datatransfer with parameters of type OperatorVertex

Constructor	Description
DataFetcherOutputCollector(OperatorVertex nextOperatorVertex, int edgeIndex, InputWatermarkManager watermarkManager)	It forwards output to the next operator.
NextIntraTaskOperatorInfo(int edgeIndex, OperatorVertex nextOperator, InputWatermarkManager watermarkManager)
OperatorWatermarkCollector(OperatorVertex operatorVertex)