public class HashSubpartitionBufferAccumulator extends Object
HashSubpartitionBufferAccumulator
accumulates the records in a subpartition.
Note that this class need not be thread-safe, because it should only be accessed from the main thread.
Constructor and Description |
---|
HashSubpartitionBufferAccumulator(TieredStorageSubpartitionId subpartitionId,
int bufferSize,
HashSubpartitionBufferAccumulatorContext bufferAccumulatorContext,
boolean isPartialRecordAllowed) |
Modifier and Type | Method and Description |
---|---|
void |
append(ByteBuffer record,
Buffer.DataType dataType) |
void |
close() |
public HashSubpartitionBufferAccumulator(TieredStorageSubpartitionId subpartitionId, int bufferSize, HashSubpartitionBufferAccumulatorContext bufferAccumulatorContext, boolean isPartialRecordAllowed)
public void append(ByteBuffer record, Buffer.DataType dataType) throws IOException
IOException
public void close()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.