Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.scheduler.adapter | |
org.apache.flink.runtime.scheduler.strategy |
Modifier and Type | Method and Description |
---|---|
ConsumedPartitionGroup |
ExecutionVertex.getConsumedPartitionGroup(int input) |
Modifier and Type | Method and Description |
---|---|
List<ConsumedPartitionGroup> |
ExecutionVertex.getAllConsumedPartitionGroups() |
List<ConsumedPartitionGroup> |
EdgeManager.getConsumedPartitionGroupsForVertex(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.addConsumedPartitionGroup(ConsumedPartitionGroup consumedPartitions) |
void |
EdgeManager.connectVertexWithConsumedPartitionGroup(ExecutionVertexID executionVertexId,
ConsumedPartitionGroup consumedPartitionGroup) |
Modifier and Type | Method and Description |
---|---|
Iterable<ConsumedPartitionGroup> |
DefaultSchedulingPipelinedRegion.getAllBlockingConsumedPartitionGroups() |
Modifier and Type | Method and Description |
---|---|
static ConsumedPartitionGroup |
ConsumedPartitionGroup.fromMultiplePartitions(List<IntermediateResultPartitionID> resultPartitions) |
static ConsumedPartitionGroup |
ConsumedPartitionGroup.fromSinglePartition(IntermediateResultPartitionID resultPartition) |
Modifier and Type | Method and Description |
---|---|
Iterable<ConsumedPartitionGroup> |
SchedulingPipelinedRegion.getAllBlockingConsumedPartitionGroups()
Get all distinct blocking
ConsumedPartitionGroup s. |
List<ConsumedPartitionGroup> |
SchedulingExecutionVertex.getConsumedPartitionGroups()
Gets the
ConsumedPartitionGroup s. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.