Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote

Class RemoteTierConsumerAgent

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote.RemoteTierConsumerAgent

All Implemented Interfaces:

TierConsumerAgent

public class RemoteTierConsumerAgent
extends Object
implements TierConsumerAgent

The data client is used to fetch data from remote tier.

Constructor Summary

Constructors

Constructor	Description
RemoteTierConsumerAgent(RemoteStorageScanner remoteStorageScanner, PartitionFileReader partitionFileReader, int bufferSizeBytes)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the consumer agent.
Optional<Buffer>	getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId)	Get buffer from the consumer agent.
void	registerAvailabilityNotifier(AvailabilityNotifier notifier)	Register the notifier to notify the availability of a subpartition.
void	start()	Start the consumer agent.

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteTierConsumerAgent

public RemoteTierConsumerAgent(RemoteStorageScanner remoteStorageScanner,
                               PartitionFileReader partitionFileReader,
                               int bufferSizeBytes)

Method Detail

start

public void start()

Description copied from interface: TierConsumerAgent

Start the consumer agent.

Specified by:

start in interface TierConsumerAgent

getNextBuffer

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

Description copied from interface: TierConsumerAgent

Get buffer from the consumer agent.

Specified by:

getNextBuffer in interface TierConsumerAgent

Parameters:

partitionId - the id of partition.

subpartitionId - the id of subpartition.

segmentId - the id of segment.

Returns:

buffer.

registerAvailabilityNotifier

public void registerAvailabilityNotifier(AvailabilityNotifier notifier)

Description copied from interface: TierConsumerAgent

Register the notifier to notify the availability of a subpartition.

Specified by:

registerAvailabilityNotifier in interface TierConsumerAgent

Parameters:

notifier - to notify availability.

close

public void close()
           throws IOException

Description copied from interface: TierConsumerAgent

Close the consumer agent.

Specified by:

close in interface TierConsumerAgent

Throws:

IOException