public class BinaryKVInMemorySortBuffer extends BinaryIndexedSortable
currentSortIndexOffset, currentSortIndexSegment, indexEntrySize, lastIndexEntryOffset, memorySegmentPool, numRecords, OFFSET_LEN, recordBuffer, row1, serializer, serializer1, sortIndex
Modifier and Type | Method and Description |
---|---|
static BinaryKVInMemorySortBuffer |
createBuffer(NormalizedKeyComputer normalizedKeyComputer,
BinaryRowDataSerializer keySerializer,
BinaryRowDataSerializer valueSerializer,
RecordComparator comparator,
ArrayList<MemorySegment> recordBufferSegments,
long numElements,
MemorySegmentPool pool) |
MutableObjectIterator<Tuple2<BinaryRowData,BinaryRowData>> |
getIterator()
Gets an iterator over all KV records in this buffer in their logical order.
|
void |
writeToOutput(AbstractPagedOutputView output)
Spill: Write all records to a
AbstractPagedOutputView . |
checkNextIndexOffset, compare, compare, nextMemorySegment, recordSize, recordsPerSegment, size, swap, swap, writeIndexAndNormalizedKey
public static BinaryKVInMemorySortBuffer createBuffer(NormalizedKeyComputer normalizedKeyComputer, BinaryRowDataSerializer keySerializer, BinaryRowDataSerializer valueSerializer, RecordComparator comparator, ArrayList<MemorySegment> recordBufferSegments, long numElements, MemorySegmentPool pool) throws IOException
IOException
public void writeToOutput(AbstractPagedOutputView output) throws IOException
BinaryIndexedSortable
AbstractPagedOutputView
.writeToOutput
in class BinaryIndexedSortable
IOException
public final MutableObjectIterator<Tuple2<BinaryRowData,BinaryRowData>> getIterator()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.