Modifier and Type | Method and Description |
---|---|
BinaryRow |
BinaryRow.copy() |
BinaryRow |
BinaryRow.copy(BinaryRow reuse) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
BinaryRow.copy(BinaryRow reuse) |
Constructor and Description |
---|
BinaryRowWriter(BinaryRow row) |
BinaryRowWriter(BinaryRow row,
int initialSize) |
Modifier and Type | Field and Description |
---|---|
static BinaryRow |
BinaryRowUtil.EMPTY_ROW |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
LookupBucketIterator.getRow() |
BinaryRow |
BuildSideIterator.getRow() |
BinaryRow |
BuildSideIterator.BucketIterator.getRow() |
BinaryRow |
LongHashPartition.MatchIterator.getRow() |
BinaryRow |
ProbeIterator.next() |
abstract BinaryRow |
LongHybridHashTable.probeToBinary(BaseRow row)
For code gen probe side to BinaryRow.
|
Modifier and Type | Method and Description |
---|---|
RowIterator<BinaryRow> |
BinaryHashTable.getBuildSideIterator() |
Modifier and Type | Method and Description |
---|---|
void |
LongHybridHashTable.putBuildRow(BinaryRow row) |
void |
LongHashPartition.serializeToPages(BinaryRow row) |
void |
ProbeIterator.setReuse(BinaryRow reuse) |
Modifier and Type | Method and Description |
---|---|
void |
ProbeIterator.set(ChannelReaderInputViewIterator<BinaryRow> source) |
Constructor and Description |
---|
ProbeIterator(BinaryRow instance) |
Constructor and Description |
---|
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowSerializer buildSideSerializer,
AbstractRowSerializer probeSideSerializer,
Projection<BaseRow,BinaryRow> buildSideProjection,
Projection<BaseRow,BinaryRow> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
IOManager ioManager,
int avgRecordLen,
long buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
BinaryHashTable(Configuration conf,
Object owner,
AbstractRowSerializer buildSideSerializer,
AbstractRowSerializer probeSideSerializer,
Projection<BaseRow,BinaryRow> buildSideProjection,
Projection<BaseRow,BinaryRow> probeSideProjection,
MemoryManager memManager,
long reservedMemorySize,
IOManager ioManager,
int avgRecordLen,
long buildRowCount,
boolean useBloomFilters,
HashJoinType type,
JoinCondition condFunc,
boolean reverseJoin,
boolean[] filterNulls,
boolean tryDistinctBuildRow) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
BinaryRowChannelInputViewIterator.next() |
BinaryRow |
BinaryRowChannelInputViewIterator.next(BinaryRow reuse) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
BinaryRowChannelInputViewIterator.next(BinaryRow reuse) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
BytesHashMap.append(BytesHashMap.LookupInfo info,
BinaryRow value)
Append an value into the hash map's record area.
|
BinaryRow |
BytesHashMap.Entry.getKey() |
BinaryRow |
BytesHashMap.LookupInfo.getValue() |
BinaryRow |
BytesHashMap.Entry.getValue() |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
BytesHashMap.append(BytesHashMap.LookupInfo info,
BinaryRow value)
Append an value into the hash map's record area.
|
BytesHashMap.LookupInfo |
BytesHashMap.lookup(BinaryRow key) |
Constructor and Description |
---|
Entry(BinaryRow key,
BinaryRow value) |
Modifier and Type | Field and Description |
---|---|
protected BinaryRow |
SortMergeJoinIterator.bufferedKey |
protected BinaryRow |
SortMergeJoinIterator.bufferedRow |
protected BinaryRow |
SortMergeJoinIterator.matchKey |
protected BinaryRow |
SortMergeJoinIterator.probeKey |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
SortMergeJoinIterator.getMatchKey() |
BinaryRow |
SortMergeFullOuterJoinIterator.getMatchKey() |
Modifier and Type | Method and Description |
---|---|
static boolean |
NullAwareJoinHelper.shouldFilter(boolean nullSafe,
boolean filterAllNulls,
int[] nullFilterKeys,
BinaryRow key) |
Modifier and Type | Method and Description |
---|---|
abstract void |
HashJoinOperator.join(RowIterator<BinaryRow> buildIter,
BaseRow probeRow) |
Modifier and Type | Method and Description |
---|---|
static BinaryRow |
OverWindowFrame.getNextOrNull(ResettableExternalBuffer.BufferIterator iterator)
Get next row from iterator.
|
Modifier and Type | Field and Description |
---|---|
protected BinaryRow |
BinaryIndexedSortable.row1 |
Modifier and Type | Method and Description |
---|---|
protected MutableObjectIterator<BinaryRow> |
BinaryExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView) |
protected MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView) |
protected MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVExternalMerger.channelReaderInputViewIterator(AbstractChannelReaderInputView inView) |
MutableObjectIterator<BinaryRow> |
BinaryExternalSorter.getIterator() |
MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVInMemorySortBuffer.getIterator()
Gets an iterator over all KV records in this buffer in their logical order.
|
MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVInMemorySortBuffer.getIterator()
Gets an iterator over all KV records in this buffer in their logical order.
|
MutableObjectIterator<BinaryRow> |
BinaryInMemorySortBuffer.getIterator()
Gets an iterator over all records in this buffer in their logical order.
|
MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> |
BufferedKVExternalSorter.getKVIterator() |
MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> |
BufferedKVExternalSorter.getKVIterator() |
protected Comparator<BinaryRow> |
BinaryExternalMerger.mergeComparator() |
protected Comparator<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVExternalMerger.mergeComparator() |
protected Comparator<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVExternalMerger.mergeComparator() |
protected List<BinaryRow> |
BinaryExternalMerger.mergeReusedEntries(int size) |
protected List<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVExternalMerger.mergeReusedEntries(int size) |
protected List<Tuple2<BinaryRow,BinaryRow>> |
BinaryKVExternalMerger.mergeReusedEntries(int size) |
Modifier and Type | Method and Description |
---|---|
void |
BinaryExternalSorter.write(MutableObjectIterator<BinaryRow> iterator) |
protected void |
BinaryExternalMerger.writeMergingOutput(MutableObjectIterator<BinaryRow> mergeIterator,
AbstractPagedOutputView output) |
protected void |
BinaryKVExternalMerger.writeMergingOutput(MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> mergeIterator,
AbstractPagedOutputView output) |
protected void |
BinaryKVExternalMerger.writeMergingOutput(MutableObjectIterator<Tuple2<BinaryRow,BinaryRow>> mergeIterator,
AbstractPagedOutputView output) |
Modifier and Type | Method and Description |
---|---|
RowIterator<BinaryRow> |
WindowsGrouping.buildTriggerWindowElementsIterator() |
protected abstract RowIterator<BinaryRow> |
WindowsGrouping.newBufferIterator(int startIndex) |
protected RowIterator<BinaryRow> |
HeapWindowsGrouping.newBufferIterator(int startIndex) |
Modifier and Type | Method and Description |
---|---|
void |
WindowsGrouping.addInputToBuffer(BinaryRow input) |
protected abstract void |
WindowsGrouping.addIntoBuffer(BinaryRow input) |
protected void |
HeapWindowsGrouping.addIntoBuffer(BinaryRow input) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
BinaryRowSerializer.copy(BinaryRow from) |
BinaryRow |
BinaryRowSerializer.copy(BinaryRow from,
BinaryRow reuse) |
BinaryRow |
BinaryRowSerializer.createInstance() |
BinaryRow |
BinaryRowSerializer.deserialize(BinaryRow reuse,
DataInputView source) |
BinaryRow |
BinaryRowSerializer.deserialize(DataInputView source) |
BinaryRow |
BinaryRowSerializer.deserializeFromPages(AbstractPagedInputView headerLessView) |
BinaryRow |
BinaryRowSerializer.deserializeFromPages(BinaryRow reuse,
AbstractPagedInputView headerLessView) |
BinaryRow |
BinaryRowSerializer.mapFromPages(AbstractPagedInputView headerLessView) |
BinaryRow |
BinaryRowSerializer.mapFromPages(BinaryRow reuse,
AbstractPagedInputView headerLessView) |
BinaryRow |
BaseRowSerializer.toBinaryRow(BaseRow row)
Convert base row to binary row.
|
BinaryRow |
BinaryRowSerializer.toBinaryRow(BinaryRow baseRow) |
abstract BinaryRow |
AbstractRowSerializer.toBinaryRow(T baseRow)
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<BinaryRow> |
BinaryRowSerializer.duplicate() |
TypeSerializerSchemaCompatibility<BinaryRow> |
BinaryRowSerializer.BinaryRowSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BinaryRow> newSerializer) |
TypeSerializer<BinaryRow> |
BinaryRowSerializer.BinaryRowSerializerSnapshot.restoreSerializer() |
TypeSerializerSnapshot<BinaryRow> |
BinaryRowSerializer.snapshotConfiguration() |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
BinaryRowSerializer.copy(BinaryRow from) |
BinaryRow |
BinaryRowSerializer.copy(BinaryRow from,
BinaryRow reuse) |
BinaryRow |
BinaryRowSerializer.deserialize(BinaryRow reuse,
DataInputView source) |
BinaryRow |
BinaryRowSerializer.deserializeFromPages(BinaryRow reuse,
AbstractPagedInputView headerLessView) |
BinaryRow |
BinaryRowSerializer.mapFromPages(BinaryRow reuse,
AbstractPagedInputView headerLessView) |
void |
BinaryRowSerializer.pointTo(int length,
BinaryRow reuse,
AbstractPagedInputView headerLessView)
Point row to memory segments with offset(in the AbstractPagedInputView) and length.
|
void |
BinaryRowSerializer.serialize(BinaryRow record,
DataOutputView target) |
int |
BinaryRowSerializer.serializeToPages(BinaryRow record,
AbstractPagedOutputView headerLessView) |
static void |
BinaryRowSerializer.serializeWithoutLengthSlow(BinaryRow record,
MemorySegmentWritable out) |
BinaryRow |
BinaryRowSerializer.toBinaryRow(BinaryRow baseRow) |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<BinaryRow> |
BinaryRowSerializer.BinaryRowSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<BinaryRow> newSerializer) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
ResettableExternalBuffer.BufferIterator.getRow() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.