Uses of Class
org.apache.nemo.common.dag.Vertex

Packages that use Vertex

Package	Description
org.apache.nemo.common.dag
org.apache.nemo.common.ir
org.apache.nemo.common.ir.vertex
org.apache.nemo.common.ir.vertex.utility
org.apache.nemo.common.ir.vertex.utility.runtimepass
org.apache.nemo.common.test
org.apache.nemo.compiler.frontend.beam.source
org.apache.nemo.runtime.common.plan

Uses of Vertex in org.apache.nemo.common.dag

Classes in org.apache.nemo.common.dag with type parameters of type Vertex

Modifier and Type	Class	Description
class	DAG<V extends Vertex,E extends Edge<V>>	DAG implementation.
class	DAGBuilder<V extends Vertex,E extends Edge<V>>	DAG Builder.
interface	DAGInterface<V extends Vertex,E extends Edge<V>>	Methods for querying a directed-acyclic graph (DAG).
class	Edge<V extends Vertex>	Connects two vertices of a DAG.

Uses of Vertex in org.apache.nemo.common.ir

Methods in org.apache.nemo.common.ir with parameters of type Vertex

Modifier and Type	Method	Description
static java.lang.String	IdManager.getVertexId(Vertex v)	Used for cloning vertices.
static void	IdManager.saveVertexId(Vertex v, java.lang.String id)	Save the vertex id for the vertices that can be cloned later on.

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

Subclasses of Vertex in org.apache.nemo.common.ir.vertex

Modifier and Type	Class	Description
class	CachedSourceVertex<T>	Bounded source vertex for cached data.
class	InMemorySourceVertex<T>	Source vertex with the data in memory.
class	IRVertex	The basic unit of operation in a dataflow program, as well as the most important data structure in Nemo.
class	LoopVertex	IRVertex that contains a partial DAG that is iterative.
class	OperatorVertex	IRVertex that transforms input data.
class	SourceVertex<O>	IRVertex that reads data from an external source.

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

Subclasses of Vertex 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.
class	SamplingVertex	Executes the original IRVertex using a subset of input data partitions.
class	TaskSizeSplitterVertex	This vertex works as a partition-based sampling vertex of dynamic task sizing pass.

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

Subclasses of Vertex 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 Vertex in org.apache.nemo.common.test

Subclasses of Vertex in org.apache.nemo.common.test

Modifier and Type	Class	Description
static class	EmptyComponents.EmptySourceVertex<T>	An empty Source Vertex.

Uses of Vertex in org.apache.nemo.compiler.frontend.beam.source

Subclasses of Vertex in org.apache.nemo.compiler.frontend.beam.source

Modifier and Type	Class	Description
class	BeamBoundedSourceVertex<O>	SourceVertex implementation for BoundedSource.
class	BeamUnboundedSourceVertex<O,M extends org.apache.beam.sdk.io.UnboundedSource.CheckpointMark>	SourceVertex implementation for UnboundedSource.

Uses of Vertex in org.apache.nemo.runtime.common.plan

Classes in org.apache.nemo.runtime.common.plan with type parameters of type Vertex

Modifier and Type	Class	Description
class	RuntimeEdge<V extends Vertex>	Represents the edge between vertices in a logical/physical plan in runtime.

Subclasses of Vertex in org.apache.nemo.runtime.common.plan

Modifier and Type	Class	Description
class	Stage	Stage.