public interface PartitionTracker
Modifier and Type | Method and Description |
---|---|
boolean |
isPartitionTracked(ResultPartitionID resultPartitionID)
Returns whether the given partition is being tracked.
|
boolean |
isTrackingPartitionsFor(ResourceID producingTaskExecutorId)
Returns whether any partition is being tracked for the given task executor ID.
|
void |
startTrackingPartition(ResourceID producingTaskExecutorId,
ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)
Starts the tracking of the given partition for the given task executor ID.
|
void |
stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds)
Releases the given partitions and stop the tracking of partitions that were released.
|
void |
stopTrackingAndReleasePartitionsFor(ResourceID producingTaskExecutorId)
Releases all partitions for the given task executor ID, and stop the tracking of partitions that were released.
|
void |
stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
Stops the tracking of the given partitions.
|
void |
stopTrackingPartitionsFor(ResourceID producingTaskExecutorId)
Stops the tracking of all partitions for the given task executor ID, without issuing any release calls.
|
void startTrackingPartition(ResourceID producingTaskExecutorId, ResultPartitionDeploymentDescriptor resultPartitionDeploymentDescriptor)
producingTaskExecutorId
- ID of task executor on which the partition is producedresultPartitionDeploymentDescriptor
- deployment descriptor of the partitionvoid stopTrackingPartitionsFor(ResourceID producingTaskExecutorId)
void stopTrackingAndReleasePartitions(Collection<ResultPartitionID> resultPartitionIds)
void stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
void stopTrackingAndReleasePartitionsFor(ResourceID producingTaskExecutorId)
boolean isTrackingPartitionsFor(ResourceID producingTaskExecutorId)
boolean isPartitionTracked(ResultPartitionID resultPartitionID)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.