public abstract class SortMergeJoinIterator extends Object implements Closeable
Modifier and Type | Field and Description |
---|---|
protected BinaryRow |
bufferedKey |
protected BinaryRow |
bufferedRow |
protected RecordComparator |
keyComparator |
protected ResettableExternalBuffer |
matchBuffer |
protected BinaryRow |
matchKey |
protected BinaryRow |
probeKey |
Constructor and Description |
---|
SortMergeJoinIterator(BinaryRowSerializer probeSerializer,
BinaryRowSerializer bufferedSerializer,
Projection<BaseRow,BinaryRow> probeProjection,
Projection<BaseRow,BinaryRow> bufferedProjection,
RecordComparator keyComparator,
MutableObjectIterator<BaseRow> probeIterator,
MutableObjectIterator<BinaryRow> bufferedIterator,
ResettableExternalBuffer buffer,
boolean[] filterNulls) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
advanceNextSuitableBufferedRow() |
protected boolean |
advanceNextSuitableProbeRow() |
protected void |
bufferMatchingRows() |
void |
close() |
ResettableExternalBuffer |
getMatchBuffer() |
BinaryRow |
getMatchKey() |
BaseRow |
getProbeRow() |
protected boolean |
nextProbe() |
protected final RecordComparator keyComparator
protected BinaryRow probeKey
protected BinaryRow bufferedRow
protected BinaryRow bufferedKey
protected BinaryRow matchKey
protected ResettableExternalBuffer matchBuffer
public SortMergeJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls) throws IOException
IOException
protected boolean advanceNextSuitableProbeRow() throws IOException
IOException
protected boolean advanceNextSuitableBufferedRow() throws IOException
IOException
protected boolean nextProbe() throws IOException
IOException
protected void bufferMatchingRows() throws IOException
IOException
public BaseRow getProbeRow()
public BinaryRow getMatchKey()
public ResettableExternalBuffer getMatchBuffer()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.