public class SortMergeFullOuterJoinIterator extends Object implements Closeable
Constructor and Description |
---|
SortMergeFullOuterJoinIterator(BinaryRowDataSerializer serializer1,
BinaryRowDataSerializer serializer2,
Projection<RowData,BinaryRowData> projection1,
Projection<RowData,BinaryRowData> projection2,
RecordComparator keyComparator,
MutableObjectIterator<BinaryRowData> iterator1,
MutableObjectIterator<BinaryRowData> iterator2,
ResettableExternalBuffer buffer1,
ResettableExternalBuffer buffer2,
boolean[] filterNulls) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ResettableExternalBuffer |
getBuffer1() |
ResettableExternalBuffer |
getBuffer2() |
BinaryRowData |
getMatchKey() |
boolean |
nextOuterJoin() |
public SortMergeFullOuterJoinIterator(BinaryRowDataSerializer serializer1, BinaryRowDataSerializer serializer2, Projection<RowData,BinaryRowData> projection1, Projection<RowData,BinaryRowData> projection2, RecordComparator keyComparator, MutableObjectIterator<BinaryRowData> iterator1, MutableObjectIterator<BinaryRowData> iterator2, ResettableExternalBuffer buffer1, ResettableExternalBuffer buffer2, boolean[] filterNulls) throws IOException
IOException
public boolean nextOuterJoin() throws IOException
IOException
public BinaryRowData getMatchKey()
public ResettableExternalBuffer getBuffer1()
public ResettableExternalBuffer getBuffer2()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.