public class SortMergeOneSideOuterJoinIterator extends SortMergeJoinIterator
bufferedKey, bufferedRow, keyComparator, matchBuffer, matchKey, probeKey
Constructor and Description |
---|
SortMergeOneSideOuterJoinIterator(BinaryRowDataSerializer probeSerializer,
BinaryRowDataSerializer bufferedSerializer,
Projection<RowData,BinaryRowData> probeProjection,
Projection<RowData,BinaryRowData> bufferedProjection,
RecordComparator keyComparator,
MutableObjectIterator<RowData> probeIterator,
MutableObjectIterator<BinaryRowData> bufferedIterator,
ResettableExternalBuffer buffer,
boolean[] filterNullKeys) |
Modifier and Type | Method and Description |
---|---|
boolean |
nextOuterJoin() |
advanceNextSuitableBufferedRow, advanceNextSuitableProbeRow, bufferMatchingRows, close, getMatchBuffer, getMatchKey, getProbeRow, nextProbe
public SortMergeOneSideOuterJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<RowData,BinaryRowData> probeProjection, Projection<RowData,BinaryRowData> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<RowData> probeIterator, MutableObjectIterator<BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys) throws IOException
IOException
public boolean nextOuterJoin() throws IOException
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.