Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.io.network.netty | |
org.apache.flink.runtime.io.network.partition.consumer | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
InputGateDeploymentDescriptor.getConsumedResultId() |
IntermediateDataSetID |
ResultPartitionDeploymentDescriptor.getResultId() |
IntermediateDataSetID |
PartialInputChannelDeploymentDescriptor.getResultId() |
Constructor and Description |
---|
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
int consumedSubpartitionIndex,
InputChannelDeploymentDescriptor[] inputChannels) |
PartialInputChannelDeploymentDescriptor(IntermediateDataSetID resultId,
ResultPartitionID partitionID,
TaskManagerLocation partitionTaskManagerLocation,
int partitionConnectionIndex) |
ResultPartitionDeploymentDescriptor(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int maxParallelism,
boolean lazyScheduling) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
IntermediateResult.getId() |
IntermediateDataSetID |
PartitionInfo.getIntermediateDataSetID() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateDataSetID,IntermediateResult> |
ExecutionGraph.getAllIntermediateResults() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionJobVertex.connectToPredecessors(Map<IntermediateDataSetID,IntermediateResult> intermediateDataSets) |
Constructor and Description |
---|
IntermediateResult(IntermediateDataSetID id,
ExecutionJobVertex producer,
int numParallelProducers,
ResultPartitionType resultType) |
PartitionInfo(IntermediateDataSetID intermediateResultPartitionID,
InputChannelDeploymentDescriptor inputChannelDeploymentDescriptor) |
Modifier and Type | Method and Description |
---|---|
Future<ExecutionState> |
PartitionProducerStateChecker.requestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId)
Requests the execution state of the execution producing a result partition.
|
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
SingleInputGate.getConsumedResultId() |
Constructor and Description |
---|
SingleInputGate(String owningTaskName,
JobID jobId,
IntermediateDataSetID consumedResultId,
int consumedSubpartitionIndex,
int numberOfInputChannels,
TaskActions taskActions,
TaskIOMetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
IntermediateDataSet.getId() |
IntermediateDataSetID |
JobEdge.getSourceId()
Gets the ID of the consumed data set.
|
Modifier and Type | Method and Description |
---|---|
void |
JobVertex.connectIdInput(IntermediateDataSetID dataSetId,
DistributionPattern distPattern) |
IntermediateDataSet |
JobVertex.createAndAddResultDataSet(IntermediateDataSetID id,
ResultPartitionType partitionType) |
Constructor and Description |
---|
IntermediateDataSet(IntermediateDataSetID id,
JobVertex producer) |
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.
|
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
JobManagerMessages.RequestPartitionProducerState.intermediateDataSetId() |
IntermediateDataSetID |
TaskMessages.UpdateTaskSinglePartitionInfo.resultId() |
Modifier and Type | Method and Description |
---|---|
static TaskMessages.UpdateTaskMultiplePartitionInfos |
TaskMessages.createUpdateTaskMultiplePartitionInfos(ExecutionAttemptID executionID,
List<IntermediateDataSetID> resultIDs,
List<InputChannelDeploymentDescriptor> partitionInfos) |
TaskMessages.UpdateTaskMultiplePartitionInfos |
TaskMessages$.createUpdateTaskMultiplePartitionInfos(ExecutionAttemptID executionID,
List<IntermediateDataSetID> resultIDs,
List<InputChannelDeploymentDescriptor> partitionInfos) |
Constructor and Description |
---|
RequestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId) |
UpdateTaskSinglePartitionInfo(ExecutionAttemptID executionID,
IntermediateDataSetID resultId,
InputChannelDeploymentDescriptor partitionInfo) |
Modifier and Type | Method and Description |
---|---|
SingleInputGate |
Task.getInputGateById(IntermediateDataSetID id) |
Future<ExecutionState> |
ActorGatewayPartitionProducerStateChecker.requestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId) |
void |
TaskActions.triggerPartitionProducerStateCheck(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId)
Check the execution state of the execution producing a result partition.
|
void |
Task.triggerPartitionProducerStateCheck(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.