Uses of Class
org.apache.nemo.common.ir.vertex.SourceVertex
-
Packages that use SourceVertex Package Description org.apache.nemo.common.ir.vertex org.apache.nemo.common.test org.apache.nemo.compiler.frontend.beam.source -
-
Uses of SourceVertex in org.apache.nemo.common.ir.vertex
Subclasses of SourceVertex 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.Constructors in org.apache.nemo.common.ir.vertex with parameters of type SourceVertex Constructor Description SourceVertex(SourceVertex that)
Copy Constructor for SourceVertex. -
Uses of SourceVertex in org.apache.nemo.common.test
Subclasses of SourceVertex in org.apache.nemo.common.test Modifier and Type Class Description static class
EmptyComponents.EmptySourceVertex<T>
An empty Source Vertex. -
Uses of SourceVertex in org.apache.nemo.compiler.frontend.beam.source
Subclasses of SourceVertex 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.
-