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

Class SortMergeJoinFunction

java.lang.Object

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

All Implemented Interfaces:

Serializable

public class SortMergeJoinFunction
extends Object
implements Serializable

This function is used to process the main logic of sort merge join.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description

SortMergeJoinFunction(double externalBufferMemRatio, FlinkJoinType type, boolean leftIsSmaller, int maxNumFileHandles, boolean compressionEnabled, int compressionBlockSize, boolean asyncMergeEnabled, GeneratedJoinCondition condFuncCode, GeneratedProjection projectionCode1, GeneratedProjection projectionCode2, GeneratedNormalizedKeyComputer computer1, GeneratedRecordComparator comparator1, GeneratedNormalizedKeyComputer computer2, GeneratedRecordComparator comparator2, GeneratedRecordComparator genKeyComparator, boolean[] filterNulls)

Method Summary

Modifier and Type	Method and Description
void	close()
void	endInput(int inputId)
void	open(boolean adaptiveHashJoin, StreamTask<?,?> taskContainer, StreamConfig operatorConfig, StreamRecordCollector collector, long totalMemory, RuntimeContext runtimeContext, OperatorMetricGroup operatorMetricGroup)
void	processElement1(RowData element)
void	processElement2(RowData element)

Methods inherited from class java.lang.Object

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

Constructor Detail

SortMergeJoinFunction

public SortMergeJoinFunction(double externalBufferMemRatio,
                             FlinkJoinType type,
                             boolean leftIsSmaller,
                             int maxNumFileHandles,
                             boolean compressionEnabled,
                             int compressionBlockSize,
                             boolean asyncMergeEnabled,
                             GeneratedJoinCondition condFuncCode,
                             GeneratedProjection projectionCode1,
                             GeneratedProjection projectionCode2,
                             GeneratedNormalizedKeyComputer computer1,
                             GeneratedRecordComparator comparator1,
                             GeneratedNormalizedKeyComputer computer2,
                             GeneratedRecordComparator comparator2,
                             GeneratedRecordComparator genKeyComparator,
                             boolean[] filterNulls)

Method Detail

open

public void open(boolean adaptiveHashJoin,
                 StreamTask<?,?> taskContainer,
                 StreamConfig operatorConfig,
                 StreamRecordCollector collector,
                 long totalMemory,
                 RuntimeContext runtimeContext,
                 OperatorMetricGroup operatorMetricGroup)
          throws Exception

Throws:

Exception

processElement1

public void processElement1(RowData element)
                     throws Exception

Throws:

Exception

processElement2

public void processElement2(RowData element)
                     throws Exception

Throws:

Exception

endInput

public void endInput(int inputId)
              throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception