| 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.