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 |
---|---|
boolean |
ResultPartitionAvailabilityChecker.isAvailable(IntermediateResultPartitionID resultPartitionID)
Returns whether the given partition is available.
|
Modifier and Type | Method and Description |
---|---|
List<IntermediateResultPartitionID> |
RegionPartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
List<IntermediateResultPartitionID> |
PartitionReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.
|
List<IntermediateResultPartitionID> |
NotReleasingPartitionReleaseStrategy.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.
|
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 |
---|---|
protected void |
SchedulerBase.scheduleOrUpdateConsumersInternal(IntermediateResultPartitionID resultPartitionId) |
protected void |
DefaultScheduler.scheduleOrUpdateConsumersInternal(IntermediateResultPartitionID partitionId) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition |
DefaultExecutionTopology.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId) |
Modifier and Type | Method and Description |
---|---|
SchedulingResultPartition |
SchedulingTopology.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
void |
LazyFromSourcesSchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId) |
void |
PipelinedRegionSchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId) |
void |
EagerSchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId) |
void |
SchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId)
Called whenever an
IntermediateResultPartition becomes consumable. |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
PartitionDescriptor.getPartitionId() |
Constructor and Description |
---|
PartitionDescriptor(IntermediateDataSetID resultId,
int totalNumberOfPartitions,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int connectionIndex) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.