public interface HashSubpartitionBufferAccumulatorContext
HashSubpartitionBufferAccumulator
to operate HashBufferAccumulator
.Modifier and Type | Method and Description |
---|---|
void |
flushAccumulatedBuffers(TieredStorageSubpartitionId subpartitionId,
Buffer accumulatedBuffer,
int numRemainingConsecutiveBuffers)
Flush the accumulated
Buffer s of the subpartition. |
BufferBuilder |
requestBufferBlocking()
Request
BufferBuilder from the BufferPool . |
BufferBuilder requestBufferBlocking()
BufferBuilder
from the BufferPool
.void flushAccumulatedBuffers(TieredStorageSubpartitionId subpartitionId, Buffer accumulatedBuffer, int numRemainingConsecutiveBuffers)
Buffer
s of the subpartition.subpartitionId
- the subpartition idaccumulatedBuffer
- the accumulated buffernumRemainingConsecutiveBuffers
- number of buffers that would be passed in the following
invocations and should be written to the same segment as this oneCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.