Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
ResultPartitionDeploymentDescriptor.getPartitionId() |
Modifier and Type | Field and Description |
---|---|
protected Map<IntermediateResultPartitionID,Long> |
IOMetrics.numBytesProducedOfPartitions |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
IntermediateResultPartition.getPartitionId() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateResultPartitionID,Long> |
IOMetrics.getNumBytesProducedOfPartitions() |
Map<IntermediateResultPartitionID,IntermediateResultPartition> |
ExecutionVertex.getProducedPartitions() |
Constructor and Description |
---|
IOMetrics(Meter recordsIn,
Meter recordsOut,
Meter bytesIn,
Meter bytesOut,
Map<IntermediateResultPartitionID,Counter> numBytesProducedCounters,
Gauge<Long> accumulatedBackPressuredTime,
Gauge<Long> accumulatedIdleTime,
Gauge<Double> accumulatedBusyTime) |
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 |
---|---|
void |
SingleInputGate.retriggerPartitionRequest(IntermediateResultPartitionID partitionId,
int subpartitionIndex)
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 |
---|---|
void |
TaskIOMetricGroup.registerNumBytesProducedCounterForPartition(IntermediateResultPartitionID resultPartitionId,
Counter numBytesProducedCounter) |
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(int numConsumers,
IntermediateResultPartitionID resultPartition,
ResultPartitionType resultPartitionType) |
SchedulingResultPartition |
SchedulingTopology.getResultPartition(IntermediateResultPartitionID intermediateResultPartitionId)
Looks up the
SchedulingResultPartition for the given IntermediateResultPartitionID . |
void |
VertexwiseSchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId) |
void |
SchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId)
Called whenever an
IntermediateResultPartition becomes consumable. |
void |
PipelinedRegionSchedulingStrategy.onPartitionConsumable(IntermediateResultPartitionID resultPartitionId) |
Modifier and Type | Method and Description |
---|---|
static ConsumedPartitionGroup |
ConsumedPartitionGroup.fromMultiplePartitions(int numConsumers,
List<IntermediateResultPartitionID> resultPartitions,
ResultPartitionType resultPartitionType) |
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,
boolean isBroadcast,
boolean isAllToAllDistribution) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.