org.apache.flink.table.planner.plan.nodes.exec.spec

类 IntervalJoinSpec

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.spec.IntervalJoinSpec

public class IntervalJoinSpec
extends Object

IntervalJoinSpec describes how two tables will be joined in interval join.

This class corresponds to Join rel node. the join condition is splitted into two part: WindowBounds and JoinSpec: 1. WindowBounds contains the time range condition. 2. JoinSpec contains rest of the join condition except windowBounds.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	IntervalJoinSpec.WindowBounds WindowBounds describes the time range condition of a Interval Join.

字段概要

字段

限定符和类型	字段和说明
static String	FIELD_NAME_JOIN_SPEC
static String	FIELD_NAME_WINDOW_BOUNDS

构造器概要

构造器

构造器和说明
IntervalJoinSpec(JoinSpec joinSpec, IntervalJoinSpec.WindowBounds windowBounds)

方法概要

限定符和类型	方法和说明
boolean	equals(Object o)
JoinSpec	getJoinSpec()
IntervalJoinSpec.WindowBounds	getWindowBounds()
int	hashCode()

从类继承的方法 java.lang.Object

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

字段详细资料

FIELD_NAME_WINDOW_BOUNDS

public static final String FIELD_NAME_WINDOW_BOUNDS

另请参阅:

常量字段值

FIELD_NAME_JOIN_SPEC

public static final String FIELD_NAME_JOIN_SPEC

另请参阅:

常量字段值

构造器详细资料

IntervalJoinSpec

public IntervalJoinSpec(JoinSpec joinSpec,
                        IntervalJoinSpec.WindowBounds windowBounds)

方法详细资料

getWindowBounds

public IntervalJoinSpec.WindowBounds getWindowBounds()

getJoinSpec

public JoinSpec getJoinSpec()

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object