Uses of Interface
org.apache.nemo.common.Cloneable
-
-
Uses of Cloneable in org.apache.nemo.common
Classes in org.apache.nemo.common with type parameters of type Cloneable Modifier and Type Interface Description interface
Cloneable<T extends Cloneable<T>>
This interface is implemented by objects that can be cloned. -
Uses of Cloneable in org.apache.nemo.common.ir.vertex
Classes in org.apache.nemo.common.ir.vertex that implement Cloneable 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 Cloneable in org.apache.nemo.common.ir.vertex.utility
Classes in org.apache.nemo.common.ir.vertex.utility that implement Cloneable 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 Cloneable in org.apache.nemo.common.ir.vertex.utility.runtimepass
Classes in org.apache.nemo.common.ir.vertex.utility.runtimepass that implement Cloneable 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 Cloneable in org.apache.nemo.common.test
Classes in org.apache.nemo.common.test that implement Cloneable Modifier and Type Class Description static class
EmptyComponents.EmptySourceVertex<T>
An empty Source Vertex. -
Uses of Cloneable in org.apache.nemo.compiler.frontend.beam.source
Classes in org.apache.nemo.compiler.frontend.beam.source that implement Cloneable 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.
-