Package org.apache.flink.table.runtime.operators.join

Class SortMergeOneSideOuterJoinIterator

java.lang.Object

org.apache.flink.table.runtime.operators.join.SortMergeJoinIterator

org.apache.flink.table.runtime.operators.join.SortMergeOneSideOuterJoinIterator

All Implemented Interfaces:

Closeable, AutoCloseable

public class SortMergeOneSideOuterJoinIterator
extends SortMergeJoinIterator

Gets probeRow and match rows for left/right join.

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.join.SortMergeJoinIterator

bufferedKey, bufferedRow, keyComparator, matchBuffer, matchKey, probeKey

Constructor Summary

Constructors

Constructor

Description

SortMergeOneSideOuterJoinIterator(BinaryRowDataSerializer probeSerializer, BinaryRowDataSerializer bufferedSerializer, Projection<org.apache.flink.table.data.RowData,org.apache.flink.table.data.binary.BinaryRowData> probeProjection, Projection<org.apache.flink.table.data.RowData,org.apache.flink.table.data.binary.BinaryRowData> bufferedProjection, RecordComparator keyComparator, org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.RowData> probeIterator, org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)

Method Summary

Modifier and Type	Method	Description
boolean	nextOuterJoin()

Methods inherited from class org.apache.flink.table.runtime.operators.join.SortMergeJoinIterator

advanceNextSuitableBufferedRow, advanceNextSuitableProbeRow, bufferMatchingRows, close, getMatchBuffer, getMatchKey, getProbeRow, nextProbe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SortMergeOneSideOuterJoinIterator

public SortMergeOneSideOuterJoinIterator(BinaryRowDataSerializer probeSerializer,
                                         BinaryRowDataSerializer bufferedSerializer,
                                         Projection<org.apache.flink.table.data.RowData,org.apache.flink.table.data.binary.BinaryRowData> probeProjection,
                                         Projection<org.apache.flink.table.data.RowData,org.apache.flink.table.data.binary.BinaryRowData> bufferedProjection,
                                         RecordComparator keyComparator,
                                         org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.RowData> probeIterator,
                                         org.apache.flink.util.MutableObjectIterator<org.apache.flink.table.data.binary.BinaryRowData> bufferedIterator,
                                         ResettableExternalBuffer buffer,
                                         boolean[] filterNullKeys)
                                  throws IOException

Throws:

IOException

Method Detail

nextOuterJoin

public boolean nextOuterJoin()
                      throws IOException

Throws:

IOException