Package | Description |
---|---|
org.apache.flink.runtime.executiongraph |
Modifier and Type | Method and Description |
---|---|
IntermediateResult |
IntermediateResultPartition.getIntermediateResult() |
IntermediateResult[] |
ExecutionJobVertex.getProducedDataSets() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateDataSetID,IntermediateResult> |
ExecutionGraph.getAllIntermediateResults() |
List<IntermediateResult> |
ExecutionJobVertex.getInputs() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.connectSource(int inputNumber,
IntermediateResult source,
JobEdge edge,
int consumerNumber) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionJobVertex.connectToPredecessors(Map<IntermediateDataSetID,IntermediateResult> intermediateDataSets) |
Constructor and Description |
---|
ExecutionVertex(ExecutionJobVertex jobVertex,
int subTaskIndex,
IntermediateResult[] producedDataSets,
Time timeout,
long initialGlobalModVersion,
long createTimestamp,
int maxPriorExecutionHistoryLength)
Creates an ExecutionVertex.
|
IntermediateResultPartition(IntermediateResult totalResult,
ExecutionVertex producer,
int partitionNumber) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.