Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.io.network.partition | |
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 |
---|---|
IntermediateResultPartitionID |
ResultPartitionDeploymentDescriptor.getPartitionId() |
Constructor and Description |
---|
ResultPartitionDeploymentDescriptor(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
boolean eagerlyDeployConsumers) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
IntermediateResultPartition.getPartitionId() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateResultPartitionID,IntermediateResultPartition> |
ExecutionVertex.getProducedPartitions() |
Modifier and Type | Field and Description |
---|---|
com.google.common.collect.Table<ExecutionAttemptID,IntermediateResultPartitionID,ResultPartition> |
ResultPartitionManager.registeredPartitions |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
ResultPartitionID.getPartitionId() |
Constructor and Description |
---|
ResultPartitionID(IntermediateResultPartitionID partitionId,
ExecutionAttemptID producerId) |
Modifier and Type | Method and Description |
---|---|
void |
SingleInputGate.retriggerPartitionRequest(IntermediateResultPartitionID partitionId)
Retriggers a partition request.
|
void |
SingleInputGate.setInputChannel(IntermediateResultPartitionID partitionId,
InputChannel inputChannel) |
Modifier and Type | Method and Description |
---|---|
static IntermediateResultPartitionID |
IntermediateResultPartitionID.fromByteBuf(io.netty.buffer.ByteBuf buf) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
TaskMessages.PartitionState.partitionId() |
Constructor and Description |
---|
PartitionState(ExecutionAttemptID taskExecutionId,
IntermediateDataSetID taskResultId,
IntermediateResultPartitionID partitionId,
ExecutionState state) |
Modifier and Type | Method and Description |
---|---|
void |
Task.onPartitionStateUpdate(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ExecutionState partitionState)
Answer to a partition state check issued after a failed partition request.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.