public class TierStateFetcher
extends java.lang.Object
Constructor and Description |
---|
TierStateFetcher(java.lang.Integer numThreads,
TierObjectStore tierObjectStore) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.util.concurrent.Future<scala.collection.immutable.List<kafka.server.epoch.EpochEntry>> |
fetchLeaderEpochState(TierObjectMetadata metadata)
Send a request to the tier state fetcher executor, returning a future that will be
completed when the request has read the tier state from the object store.
|
public TierStateFetcher(java.lang.Integer numThreads, TierObjectStore tierObjectStore)
public void close()
public java.util.concurrent.Future<scala.collection.immutable.List<kafka.server.epoch.EpochEntry>> fetchLeaderEpochState(TierObjectMetadata metadata)
metadata
- the tier object metadata for this tier state.