Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
InputGateDeploymentDescriptor.getConsumedResultId() |
IntermediateDataSetID |
ResultPartitionDeploymentDescriptor.getResultId() |
Constructor and Description |
---|
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
int consumedSubpartitionIndex,
ShuffleDescriptor[] inputChannels) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
IntermediateResult.getId() |
IntermediateDataSetID |
PartitionInfo.getIntermediateDataSetID() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateDataSetID,IntermediateResult> |
ExecutionGraph.getAllIntermediateResults() |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionJobVertex.connectToPredecessors(Map<IntermediateDataSetID,IntermediateResult> intermediateDataSets) |
Constructor and Description |
---|
IntermediateResult(IntermediateDataSetID id,
ExecutionJobVertex producer,
int numParallelProducers,
ResultPartitionType resultType) |
PartitionInfo(IntermediateDataSetID intermediateResultPartitionID,
ShuffleDescriptor shuffleDescriptor) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
TaskExecutorPartitionInfo.getIntermediateDataSetId() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateDataSetID,DataSetMetaInfo> |
ResourceManagerPartitionTracker.listDataSets()
Returns all data sets for which partitions are being tracked.
|
Map<IntermediateDataSetID,DataSetMetaInfo> |
ResourceManagerPartitionTrackerImpl.listDataSets() |
CompletableFuture<Map<IntermediateDataSetID,DataSetMetaInfo>> |
ClusterPartitionManager.listDataSets()
Returns all datasets for which partitions are being tracked.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
ResourceManagerPartitionTracker.releaseClusterPartitions(IntermediateDataSetID dataSetId)
Issues a release calls to all task executors that are hosting partitions of the given data
set.
|
CompletableFuture<Void> |
ResourceManagerPartitionTrackerImpl.releaseClusterPartitions(IntermediateDataSetID dataSetId) |
CompletableFuture<Void> |
ClusterPartitionManager.releaseClusterPartitions(IntermediateDataSetID dataSetToRelease)
Releases all partitions associated with the given dataset.
|
void |
PartitionProducerStateProvider.requestPartitionProducerState(IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId,
java.util.function.Consumer<? super PartitionProducerStateProvider.ResponseHandle> responseConsumer)
Trigger the producer execution state request.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskExecutorClusterPartitionReleaser.releaseClusterPartitions(ResourceID taskExecutorId,
Set<IntermediateDataSetID> dataSetsToRelease) |
void |
TaskExecutorPartitionTracker.stopTrackingAndReleaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease)
Releases partitions associated with the given datasets and stops tracking of partitions that
were released.
|
void |
TaskExecutorPartitionTrackerImpl.stopTrackingAndReleaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease) |
Constructor and Description |
---|
TaskExecutorPartitionInfo(ResultPartitionID resultPartitionId,
IntermediateDataSetID intermediateDataSetId,
int numberOfPartitions) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
InputGateID.getConsumedResultID() |
Constructor and Description |
---|
InputGateID(IntermediateDataSetID consumedResultID,
ExecutionAttemptID consumerID) |
SingleInputGate(String owningTaskName,
int gateIndex,
IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
int consumedSubpartitionIndex,
int numberOfInputChannels,
PartitionProducerStateProvider partitionProducerStateProvider,
SupplierWithException<BufferPool,IOException> bufferPoolFactory,
BufferDecompressor bufferDecompressor,
MemorySegmentProvider memorySegmentProvider) |
Modifier and Type | Method and Description |
---|---|
static IntermediateDataSetID |
IntermediateDataSetID.fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
IntermediateDataSetID |
IntermediateDataSet.getId() |
IntermediateDataSetID |
JobEdge.getSourceId()
Gets the ID of the consumed data set.
|
Modifier and Type | Method and Description |
---|---|
void |
JobVertex.connectIdInput(IntermediateDataSetID dataSetId,
DistributionPattern distPattern) |
IntermediateDataSet |
JobVertex.createAndAddResultDataSet(IntermediateDataSetID id,
ResultPartitionType partitionType) |
Constructor and Description |
---|
IntermediateDataSet(IntermediateDataSetID id,
ResultPartitionType resultType,
JobVertex producer) |
IntermediateResultPartitionID(IntermediateDataSetID intermediateDataSetID,
int partitionNum)
Creates an new intermediate result partition ID with
IntermediateDataSetID and the
partitionNum. |
JobEdge(IntermediateDataSetID sourceId,
JobVertex target,
DistributionPattern distributionPattern)
Constructs a new job edge that refers to an intermediate result via the Id, rather than
directly through the intermediate data set structure.
|
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
DefaultLogicalResult.getId() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ExecutionState> |
JobMasterGateway.requestPartitionState(IntermediateDataSetID intermediateResultId,
ResultPartitionID partitionId)
Requests the current state of the partition.
|
CompletableFuture<ExecutionState> |
JobMaster.requestPartitionState(IntermediateDataSetID intermediateResultId,
ResultPartitionID resultPartitionId) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Map<IntermediateDataSetID,DataSetMetaInfo>> |
ResourceManager.listDataSets() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
ResourceManager.releaseClusterPartitions(IntermediateDataSetID dataSetId) |
Modifier and Type | Method and Description |
---|---|
protected IntermediateDataSetID |
ClusterDataSetIdPathParameter.convertFromString(String value) |
Modifier and Type | Method and Description |
---|---|
protected String |
ClusterDataSetIdPathParameter.convertToString(IntermediateDataSetID value) |
Modifier and Type | Method and Description |
---|---|
static ClusterDataSetListResponseBody |
ClusterDataSetListResponseBody.from(Map<IntermediateDataSetID,DataSetMetaInfo> dataSets) |
Modifier and Type | Method and Description |
---|---|
ExecutionState |
SchedulerBase.requestPartitionState(IntermediateDataSetID intermediateResultId,
ResultPartitionID resultPartitionId) |
ExecutionState |
SchedulerNG.requestPartitionState(IntermediateDataSetID intermediateResultId,
ResultPartitionID resultPartitionId) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
SchedulingResultPartition.getResultId()
Gets id of the intermediate result.
|
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
PartitionDescriptor.getResultId() |
Constructor and Description |
---|
PartitionDescriptor(IntermediateDataSetID resultId,
int totalNumberOfPartitions,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int connectionIndex) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ExecutionState> |
PartitionProducerStateChecker.requestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId)
Requests the execution state of the execution producing a result partition.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskExecutor.releaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.releaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease,
Time timeout)
Releases all cluster partitions belong to any of the given data sets.
|
Modifier and Type | Method and Description |
---|---|
IntermediateDataSetID |
ClusterPartitionReport.ClusterPartitionReportEntry.getDataSetId() |
Constructor and Description |
---|
ClusterPartitionReportEntry(IntermediateDataSetID dataSetId,
Set<ResultPartitionID> hostedPartitions,
int numTotalPartitions) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ExecutionState> |
RpcPartitionStateChecker.requestPartitionProducerState(JobID jobId,
IntermediateDataSetID resultId,
ResultPartitionID partitionId) |
Modifier and Type | Method and Description |
---|---|
void |
Task.requestPartitionProducerState(IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId,
java.util.function.Consumer<? super PartitionProducerStateProvider.ResponseHandle> responseConsumer) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.