Constructor and Description |
---|
LongHybridHashTable(Configuration conf,
Object owner,
BinaryRowSerializer buildSideSerializer,
BinaryRowSerializer probeSideSerializer,
MemoryManager memManager,
long reservedMemorySize,
long preferredMemorySize,
long perRequestMemorySize,
IOManager ioManager,
int avgRecordLen,
long buildRowCount) |
Constructor and Description |
---|
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
BinaryRowSerializer serializer) |
BinaryRowChannelInputViewIterator(ChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
BinaryRowSerializer serializer) |
Modifier and Type | Field and Description |
---|---|
protected BinaryRowSerializer |
BinaryIndexedSortable.serializer |
protected BinaryRowSerializer |
BinaryIndexedSortable.serializer1 |
Modifier and Type | Method and Description |
---|---|
static BinaryInMemorySortBuffer |
BinaryInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer,
AbstractRowSerializer<BaseRow> inputSerializer,
BinaryRowSerializer serializer,
RecordComparator comparator,
List<MemorySegment> memory)
Create a memory sorter in `insert` way.
|
static BinaryKVInMemorySortBuffer |
BinaryKVInMemorySortBuffer.createBuffer(NormalizedKeyComputer normalizedKeyComputer,
BinaryRowSerializer keySerializer,
BinaryRowSerializer valueSerializer,
RecordComparator comparator,
ArrayList<MemorySegment> recordBufferSegments,
long numElements,
MemorySegmentPool pool) |
Constructor and Description |
---|
BinaryExternalMerger(IOManager ioManager,
int pageSize,
int maxFanIn,
SpillChannelManager channelManager,
BinaryRowSerializer serializer,
RecordComparator comparator,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowSerializer<BaseRow> inputSerializer,
BinaryRowSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf) |
BinaryExternalSorter(Object owner,
MemoryManager memoryManager,
long reservedMemorySize,
IOManager ioManager,
AbstractRowSerializer<BaseRow> inputSerializer,
BinaryRowSerializer serializer,
NormalizedKeyComputer normalizedKeyComputer,
RecordComparator comparator,
Configuration conf,
float startSpillingFraction) |
BinaryIndexedSortable(NormalizedKeyComputer normalizedKeyComputer,
BinaryRowSerializer serializer,
RecordComparator comparator,
ArrayList<MemorySegment> recordBufferSegments,
MemorySegmentPool memorySegmentPool) |
BinaryKVExternalMerger(IOManager ioManager,
int pageSize,
int maxFanIn,
SpillChannelManager channelManager,
BinaryRowSerializer keySerializer,
BinaryRowSerializer valueSerializer,
RecordComparator comparator,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize) |
BufferedKVExternalSorter(IOManager ioManager,
BinaryRowSerializer keySerializer,
BinaryRowSerializer valueSerializer,
NormalizedKeyComputer nKeyComputer,
RecordComparator comparator,
int pageSize,
Configuration conf) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.