Modifier and Type | Method and Description |
---|---|
abstract ReadablesWrapper<O> |
SourceVertex.getReadableWrapper(int desiredNumOfSplits)
Gets parallel readable wrapper.
|
ReadablesWrapper<T> |
InitializedSourceVertex.getReadableWrapper(int desiredNumOfSplits) |
Modifier and Type | Method and Description |
---|---|
ReadablesWrapper<O> |
BeamBoundedSourceVertex.getReadableWrapper(int desiredNumOfSplits) |
Modifier and Type | Method and Description |
---|---|
ReadablesWrapper<T> |
SparkBoundedSourceVertex.getReadableWrapper(int desiredNumOfSplits) |
Constructor and Description |
---|
SparkBoundedSourceVertex(ReadablesWrapper<T> readablesWrapper)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
ReadablesWrapper<T> |
EmptyComponents.EmptySourceVertex.getReadableWrapper(int desirednumOfSplits) |
Constructor and Description |
---|
BoundedSourceTask(String taskId,
String irVertexId,
ReadablesWrapper<O> readablesWrapper)
Constructor.
|
Copyright © 2018. All rights reserved.