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 |
---|---|
boolean |
ResultPartitionAvailabilityChecker.isAvailable(IntermediateResultPartitionID resultPartitionID)
Returns whether the given partition is available.
|
Modifier and Type | Method and Description |
---|---|
static Set<Set<SchedulingExecutionVertex>> |
SchedulingPipelinedRegionComputeUtil.computePipelinedRegions(Iterable<? extends SchedulingExecutionVertex> topologicallySortedVertices,
java.util.function.Function<ExecutionVertexID,? extends SchedulingExecutionVertex> executionVertexRetriever,
java.util.function.Function<IntermediateResultPartitionID,? extends SchedulingResultPartition> resultPartitionRetriever) |
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 |
DefaultScheduler.notifyPartitionDataAvailableInternal(IntermediateResultPartitionID partitionId) |
protected void |
SchedulerBase.notifyPartitionDataAvailableInternal(IntermediateResultPartitionID resultPartitionId) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition |
DefaultExecutionTopology.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId) |
Constructor and Description |
---|
DefaultSchedulingPipelinedRegion(Set<org.apache.flink.runtime.scheduler.adapter.DefaultExecutionVertex> defaultExecutionVertices,
java.util.function.Function<IntermediateResultPartitionID,org.apache.flink.runtime.scheduler.adapter.DefaultResultPartition> resultPartitionRetriever) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
ConsumedPartitionGroup.getFirst() |
Modifier and Type | Method and Description |
---|---|
Iterator<IntermediateResultPartitionID> |
ConsumedPartitionGroup.iterator() |
Modifier and Type | Method and Description |
---|---|
static ConsumedPartitionGroup |
ConsumedPartitionGroup.fromSinglePartition(IntermediateResultPartitionID resultPartition) |
SchedulingResultPartition |
SchedulingTopology.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
void |
PipelinedRegionSchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId) |
void |
SchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId)
Called whenever an
IntermediateResultPartition becomes consumable. |
Modifier and Type | Method and Description |
---|---|
static ConsumedPartitionGroup |
ConsumedPartitionGroup.fromMultiplePartitions(List<IntermediateResultPartitionID> resultPartitions) |
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–2023 The Apache Software Foundation. All rights reserved.