Uses of Interface
org.apache.nemo.common.ir.Readable

Packages that use Readable

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

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

Classes in org.apache.nemo.common.ir that implement Readable

Modifier and Type	Class	Description
class	BoundedIteratorReadable<O>	An abstract readable class that retrieves data from iterator.

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

Methods in org.apache.nemo.common.ir.vertex that return types with arguments of type Readable

Modifier and Type	Method	Description
java.util.List<Readable<T>>	CachedSourceVertex.getReadables(int desiredNumOfSplits)
java.util.List<Readable<T>>	InMemorySourceVertex.getReadables(int desiredNumOfSplits)
abstract java.util.List<Readable<O>>	SourceVertex.getReadables(int desiredNumOfSplits)	Gets parallel readables.

Uses of Readable in org.apache.nemo.common.test

Methods in org.apache.nemo.common.test that return types with arguments of type Readable

Modifier and Type	Method	Description
java.util.List<Readable<T>>	EmptyComponents.EmptySourceVertex.getReadables(int desirednumOfSplits)

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

Methods in org.apache.nemo.compiler.frontend.beam.source that return types with arguments of type Readable

Modifier and Type	Method	Description
java.util.List<Readable<org.apache.beam.sdk.util.WindowedValue<O>>>	BeamBoundedSourceVertex.getReadables(int desiredNumOfSplits)
java.util.List<Readable<java.lang.Object>>	BeamUnboundedSourceVertex.getReadables(int desiredNumOfSplits)

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

Methods in org.apache.nemo.runtime.common.plan that return types with arguments of type Readable

Modifier and Type	Method	Description
java.util.Map<java.lang.String,Readable>	Task.getIrVertexIdToReadable()
java.util.List<java.util.Map<java.lang.String,Readable>>	Stage.getVertexIdToReadables()

Constructor parameters in org.apache.nemo.runtime.common.plan with type arguments of type Readable

Constructor	Description
Task(java.lang.String planId, java.lang.String taskId, ExecutionPropertyMap<VertexExecutionProperty> executionProperties, byte[] serializedIRDag, java.util.List<StageEdge> taskIncomingEdges, java.util.List<StageEdge> taskOutgoingEdges, java.util.Map<java.lang.String,Readable> irVertexIdToReadable)	Constructor.