HashSubpartitionBufferAccumulatorContext (Flink : Runtime 1.18.1-cp1 API)

All Known Implementing Classes:

HashBufferAccumulator
```
public interface HashSubpartitionBufferAccumulatorContext
```
This interface is used by HashSubpartitionBufferAccumulator to operate HashBufferAccumulator.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`flushAccumulatedBuffers(TieredStorageSubpartitionId subpartitionId, List<Buffer> accumulatedBuffers)`	Flush the accumulated `Buffer`s of the subpartition.
`BufferBuilder`	`requestBufferBlocking()`	Request `BufferBuilder` from the `BufferPool`.

- Method Detail
  - requestBufferBlocking
```
BufferBuilder requestBufferBlocking()
```
    Request BufferBuilder from the BufferPool.
    
    Returns:
    
    the requested buffer
  - flushAccumulatedBuffers
```
void flushAccumulatedBuffers(TieredStorageSubpartitionId subpartitionId,
                             List<Buffer> accumulatedBuffers)
```
    Flush the accumulated Buffers of the subpartition.
    
    Parameters:
    
    subpartitionId - the subpartition id
    
    accumulatedBuffers - the accumulated buffers