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

Class NullAwareJoinHelper

java.lang.Object

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

public class NullAwareJoinHelper
extends Object

Helper for null aware join.

Constructor Summary

Constructors

Constructor	Description
NullAwareJoinHelper()

Method Summary

Modifier and Type	Method	Description
static int[]	getNullFilterKeys(boolean[] filterNulls)
static boolean	shouldFilter(boolean nullSafe, boolean filterAllNulls, int[] nullFilterKeys, BinaryRowData key)

Methods inherited from class java.lang.Object

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

Constructor Detail

NullAwareJoinHelper

public NullAwareJoinHelper()

Method Detail

getNullFilterKeys

public static int[] getNullFilterKeys(boolean[] filterNulls)

shouldFilter

public static boolean shouldFilter(boolean nullSafe,
                                   boolean filterAllNulls,
                                   int[] nullFilterKeys,
                                   BinaryRowData key)