Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.runtime.jobmanager.scheduler |
Modifier and Type | Method and Description |
---|---|
JobVertex |
ExecutionJobVertex.getJobVertex() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.attachJobGraph(List<JobVertex> topologiallySorted) |
Constructor and Description |
---|
ExecutionJobVertex(ExecutionGraph graph,
JobVertex jobVertex,
int defaultParallelism,
int maxPriorAttemptsHistoryLength,
Time timeout,
long initialGlobalModVersion,
long createTimestamp) |
Modifier and Type | Class and Description |
---|---|
class |
InputOutputFormatVertex
A task vertex that runs an initialization and a finalization on the master.
|
Modifier and Type | Method and Description |
---|---|
JobVertex |
JobGraph.findVertexByID(JobVertexID id)
Searches for a vertex with a matching ID and returns it.
|
JobVertex |
IntermediateDataSet.getProducer() |
JobVertex |
JobEdge.getTarget()
Returns the vertex connected to this edge.
|
JobVertex[] |
JobGraph.getVerticesAsArray()
Returns an array of all job vertices that are registered with the job graph.
|
Modifier and Type | Method and Description |
---|---|
Iterable<JobVertex> |
JobGraph.getVertices()
Returns an Iterable to iterate all vertices registered with the job graph.
|
List<JobVertex> |
JobGraph.getVerticesSortedTopologicallyFromSources() |
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.addVertex(JobVertex vertex)
Adds a new task vertex to the job graph if it is not already included.
|
JobEdge |
JobVertex.connectNewDataSetAsInput(JobVertex input,
DistributionPattern distPattern,
ResultPartitionType partitionType) |
void |
JobVertex.setStrictlyCoLocatedWith(JobVertex strictlyCoLocatedWith)
Tells this vertex to strictly co locate its subtasks with the subtasks of the given vertex.
|
Constructor and Description |
---|
IntermediateDataSet(IntermediateDataSetID id,
ResultPartitionType resultType,
JobVertex producer) |
JobEdge(IntermediateDataSetID sourceId,
JobVertex target,
DistributionPattern distributionPattern)
Constructs a new job edge that refers to an intermediate result via the Id, rather than directly through
the intermediate data set structure.
|
JobEdge(IntermediateDataSet source,
JobVertex target,
DistributionPattern distributionPattern)
Constructs a new job edge, that connects an intermediate result to a consumer task.
|
JobGraph(JobID jobId,
String jobName,
JobVertex... vertices)
Constructs a new job graph with the given name, the given
ExecutionConfig ,
the given jobId or a random one if null supplied, and the given job vertices. |
JobGraph(JobVertex... vertices)
Constructs a new job graph with no name, a random job ID, the given
ExecutionConfig , and
the given job vertices. |
JobGraph(String jobName,
JobVertex... vertices)
Constructs a new job graph with the given name, the given
ExecutionConfig , a random job ID,
and the given job vertices. |
Modifier and Type | Method and Description |
---|---|
List<JobVertex> |
CoLocationGroup.getVertices() |
Modifier and Type | Method and Description |
---|---|
void |
CoLocationGroup.addVertex(JobVertex vertex) |
Constructor and Description |
---|
CoLocationGroup(JobVertex... vertices) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.