org.apache.flink.table.planner.plan.utils

Class TemporalTableJoinUtil

java.lang.Object

org.apache.flink.table.planner.plan.utils.TemporalTableJoinUtil

public class TemporalTableJoinUtil
extends Object

Utility for temporal table join which will gradually replace the scala class TemporalJoinUtil.

Constructor Summary

Constructors

Constructor and Description
TemporalTableJoinUtil()

Method Summary

Modifier and Type	Method and Description
static boolean	isEventTimeTemporalJoin(org.apache.calcite.rex.RexNode joinCondition) Check if the given join condition is an initial temporal join condition or a rewrote join condition on event time.
static boolean	isRowTimeTemporalTableJoinCondition(org.apache.calcite.rex.RexCall call) Check if the given rexCall is a rewrote join condition on event time.

Methods inherited from class java.lang.Object

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

Constructor Detail

TemporalTableJoinUtil

public TemporalTableJoinUtil()

Method Detail

isEventTimeTemporalJoin

public static boolean isEventTimeTemporalJoin(@Nonnull
                                              org.apache.calcite.rex.RexNode joinCondition)

Check if the given join condition is an initial temporal join condition or a rewrote join condition on event time.

isRowTimeTemporalTableJoinCondition

public static boolean isRowTimeTemporalTableJoinCondition(org.apache.calcite.rex.RexCall call)

Check if the given rexCall is a rewrote join condition on event time.