Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
ResultPartitionDeploymentDescriptor.getPartitionId() |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
IntermediateResultPartition.getPartitionId() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateResultPartitionID,IntermediateResultPartition> |
ExecutionVertex.getProducedPartitions() |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartition |
IntermediateResult.getPartitionById(IntermediateResultPartitionID resultPartitionId)
Returns the partition with the given ID.
|
Optional<ResultPartitionDeploymentDescriptor> |
Execution.getResultPartitionDeploymentDescriptor(IntermediateResultPartitionID id) |
boolean |
ExecutionGraphResultPartitionAvailabilityChecker.isAvailable(IntermediateResultPartitionID resultPartitionID) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
FailoverEdge.getResultPartitionID()
Returns the ID of the result partition that the source produces.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ResultPartitionAvailabilityChecker.isAvailable(IntermediateResultPartitionID resultPartitionID)
Returns whether the given partition is available.
|
Modifier and Type | Method and Description |
---|---|
List<IntermediateResultPartitionID> |
PartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.
|
List<IntermediateResultPartitionID> |
NotReleasingPartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
List<IntermediateResultPartitionID> |
RegionPartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
ResultPartitionID.getPartitionId() |
Constructor and Description |
---|
ResultPartitionID(IntermediateResultPartitionID partitionId,
ExecutionAttemptID producerId) |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateResultPartitionID,InputChannel> |
SingleInputGate.getInputChannels() |
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(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
Modifier and Type | Method and Description |
---|---|
Optional<SchedulingResultPartition> |
ExecutionGraphToSchedulingTopologyAdapter.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
SchedulingResultPartition.getId()
Gets id of the result partition.
|
Modifier and Type | Method and Description |
---|---|
Optional<SchedulingResultPartition> |
SchedulingTopology.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
default SchedulingResultPartition |
SchedulingTopology.getResultPartitionOrThrow(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
PartitionDescriptor.getPartitionId() |
Constructor and Description |
---|
PartitionDescriptor(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int connectionIndex) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.