Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage

Class TieredStorageConsumerClient

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage.TieredStorageConsumerClient

public class TieredStorageConsumerClient
extends Object

TieredStorageConsumerClient is used to read buffer from tiered store.

Constructor Summary

Constructors

Constructor	Description
TieredStorageConsumerClient(List<TierFactory> tierFactories, List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)

Method Summary

Modifier and Type	Method	Description
void	close()
Optional<Buffer>	getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)
void	registerAvailabilityNotifier(AvailabilityNotifier notifier)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TieredStorageConsumerClient

public TieredStorageConsumerClient(List<TierFactory> tierFactories,
                                   List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs,
                                   TieredStorageNettyService nettyService)

Method Detail

start

public void start()

getNextBuffer

public Optional<Buffer> getNextBuffer(TieredStoragePartitionId partitionId,
                                      TieredStorageSubpartitionId subpartitionId)

registerAvailabilityNotifier

public void registerAvailabilityNotifier(AvailabilityNotifier notifier)

close

public void close()
           throws IOException

Throws:

IOException