public class TieredStorageConsumerClient extends Object
TieredStorageConsumerClient
is used to read buffer from tiered store.Constructor and Description |
---|
TieredStorageConsumerClient(List<TierFactory> tierFactories,
List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs,
TieredStorageNettyService nettyService) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Optional<Buffer> |
getNextBuffer(TieredStoragePartitionId partitionId,
TieredStorageSubpartitionId subpartitionId) |
int |
peekNextBufferSubpartitionId(TieredStoragePartitionId partitionId,
ResultSubpartitionIndexSet indexSet)
Returns the index of the subpartition where the next buffer locates, or -1 if there is no
buffer available or the subpartition index does not belong to the specified indexSet.
|
void |
registerAvailabilityNotifier(AvailabilityNotifier notifier) |
void |
start() |
public TieredStorageConsumerClient(List<TierFactory> tierFactories, List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)
public void start()
public int peekNextBufferSubpartitionId(TieredStoragePartitionId partitionId, ResultSubpartitionIndexSet indexSet) throws IOException
partitionId
- The index of the partition which the returned subpartition should belong
to.indexSet
- The indexes of the subpartitions expected.IOException
public Optional<Buffer> getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)
public void registerAvailabilityNotifier(AvailabilityNotifier notifier)
public void close() throws IOException
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.