Modifier and Type | Class and Description |
---|---|
class |
DAG<V extends Vertex,E extends Edge<V>>
DAG implementation.
|
class |
DAGBuilder<V extends Vertex,E extends Edge<V>>
DAG Builder.
|
class |
Edge<V extends Vertex>
Connects two vertices of a DAG.
|
Modifier and Type | Method and Description |
---|---|
<V2 extends Vertex,E2 extends Edge<V2>> |
DAG.convert(Function<DAG<V,E>,DAG<V2,E2>> function)
Converts a DAG into another DAG according to a function.
|
Modifier and Type | Class and Description |
---|---|
class |
InitializedSourceVertex<T>
Source vertex with initial data as object.
|
class |
IRVertex
The top-most wrapper for a user operation in the IR.
|
class |
LoopVertex
IRVertex that contains a partial DAG that is iterative.
|
class |
MetricCollectionBarrierVertex<T>
IRVertex that collects statistics to send them to the optimizer for dynamic optimization.
|
class |
OperatorVertex
IRVertex that transforms input data.
|
class |
SourceVertex<O>
IRVertex that reads data from an external source.
|
Modifier and Type | Class and Description |
---|---|
class |
BeamBoundedSourceVertex<O>
SourceVertex implementation for BoundedSource.
|
Modifier and Type | Class and Description |
---|---|
class |
SparkBoundedSourceVertex<T>
Bounded source vertex for Spark.
|
Modifier and Type | Class and Description |
---|---|
static class |
EmptyComponents.EmptySourceVertex<T>
An empty Source Vertex.
|
Modifier and Type | Class and Description |
---|---|
class |
RuntimeEdge<V extends Vertex>
Represents the edge between vertices in a logical/physical plan in runtime.
|
Modifier and Type | Class and Description |
---|---|
class |
BoundedSourceTask<O>
BoundedSourceTask.
|
class |
MetricCollectionBarrierTask
MetricCollectionBarrierTask.
|
class |
OperatorTask
OperatorTask.
|
class |
PhysicalStage
PhysicalStage.
|
class |
Task
Task.
|
class |
UnboundedSourceTask
UnboundedSourceTask.
|
Modifier and Type | Class and Description |
---|---|
class |
Stage
Represents a stage in Runtime's execution of a job.
|
Copyright © 2018. All rights reserved.