public interface PartitionTracker<K,M>
This interface deliberately does not have a method to start tracking partitions, so that implementation are flexible in their definitions for this method (otherwise one would end up with multiple methods, with one part likely being unused).
Modifier and Type | Method and Description |
---|---|
boolean |
isPartitionTracked(ResultPartitionID resultPartitionID)
Returns whether the given partition is being tracked.
|
boolean |
isTrackingPartitionsFor(K key)
Returns whether any partition is being tracked for the given key.
|
Collection<PartitionTrackerEntry<K,M>> |
stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
Stops the tracking of the given partitions.
|
Collection<PartitionTrackerEntry<K,M>> |
stopTrackingPartitionsFor(K key)
Stops the tracking of all partitions for the given key.
|
Collection<PartitionTrackerEntry<K,M>> stopTrackingPartitionsFor(K key)
Collection<PartitionTrackerEntry<K,M>> stopTrackingPartitions(Collection<ResultPartitionID> resultPartitionIds)
boolean isTrackingPartitionsFor(K key)
boolean isPartitionTracked(ResultPartitionID resultPartitionID)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.