public class TierFetcher
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
kafka.tier.fetcher.TierFetcherMetrics |
tierFetcherMetrics |
Constructor and Description |
---|
TierFetcher(TierFetcherConfig tierFetcherConfig,
TierObjectStore tierObjectStore,
kafka.utils.KafkaScheduler scheduler,
org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.LogContext logContext) |
Modifier and Type | Method and Description |
---|---|
PendingFetch |
buildFetch(java.util.List<kafka.tier.fetcher.TierFetchMetadata> tierFetchMetadataList,
org.apache.kafka.common.IsolationLevel isolationLevel,
java.util.function.Consumer<kafka.server.DelayedOperationKey> fetchCompletionCallback) |
void |
close()
Seal the TierFetcher from accepting new fetches, and cancel all in-progress fetches.
|
PendingFetch |
fetch(java.util.List<kafka.tier.fetcher.TierFetchMetadata> tierFetchMetadataList,
org.apache.kafka.common.IsolationLevel isolationLevel,
java.util.function.Consumer<kafka.server.DelayedOperationKey> fetchCompletionCallback)
Execute a read for a single partition from Tiered Storage.
|
PendingOffsetForTimestamp |
fetchOffsetForTimestamp(java.util.Map<org.apache.kafka.common.TopicPartition,TierTimestampAndOffset> tierTimestampAndOffsets,
java.util.function.Consumer<kafka.server.DelayedOperationKey> fetchCompletionCallback) |
public final kafka.tier.fetcher.TierFetcherMetrics tierFetcherMetrics
public TierFetcher(TierFetcherConfig tierFetcherConfig, TierObjectStore tierObjectStore, kafka.utils.KafkaScheduler scheduler, org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.LogContext logContext)
public void close()
public PendingFetch buildFetch(java.util.List<kafka.tier.fetcher.TierFetchMetadata> tierFetchMetadataList, org.apache.kafka.common.IsolationLevel isolationLevel, java.util.function.Consumer<kafka.server.DelayedOperationKey> fetchCompletionCallback)
public PendingFetch fetch(java.util.List<kafka.tier.fetcher.TierFetchMetadata> tierFetchMetadataList, org.apache.kafka.common.IsolationLevel isolationLevel, java.util.function.Consumer<kafka.server.DelayedOperationKey> fetchCompletionCallback)
Returns a list of TierFetcherOperationKey to be used when registering a DelayedOperation which depends on this fetch.
public PendingOffsetForTimestamp fetchOffsetForTimestamp(java.util.Map<org.apache.kafka.common.TopicPartition,TierTimestampAndOffset> tierTimestampAndOffsets, java.util.function.Consumer<kafka.server.DelayedOperationKey> fetchCompletionCallback)