TierConsumerAgent (Flink : Runtime 1.18.1-cp1 API)

All Known Implementing Classes:

DiskTierConsumerAgent, MemoryTierConsumerAgent, RemoteTierConsumerAgent
```
public interface TierConsumerAgent
```
The TierConsumerAgent is the consumer agent of each tier in tiered store, which could read data from responding tier.

Method Summary

All Methods Instance Methods Abstract Methods
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.

- Method Detail
  - start
```
void start()
```
    Start the consumer agent.
  - getNextBuffer
```
Optional<Buffer> getNextBuffer(TieredStoragePartitionId partitionId,
                               TieredStorageSubpartitionId subpartitionId,
                               int segmentId)
```
    Get buffer from the consumer agent.
    
    Parameters:
    
    partitionId - the id of partition.
    
    subpartitionId - the id of subpartition.
    
    segmentId - the id of segment.
    
    Returns:
    
    buffer.
  - registerAvailabilityNotifier
```
void registerAvailabilityNotifier(AvailabilityNotifier notifier)
```
    Register the notifier to notify the availability of a subpartition.
    
    Parameters:
    
    notifier - to notify availability.
  - close
```
void close()
    throws IOException
```
    Close the consumer agent.
    
    Throws:
    
    IOException