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

Class 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IntervalJoinSpec.WindowBounds WindowBounds describes the time range condition of a Interval Join.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_JOIN_SPEC
static String	FIELD_NAME_WINDOW_BOUNDS

Constructor Summary

Constructors

Constructor and Description
IntervalJoinSpec(JoinSpec joinSpec, IntervalJoinSpec.WindowBounds windowBounds)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
JoinSpec	getJoinSpec()
IntervalJoinSpec.WindowBounds	getWindowBounds()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_WINDOW_BOUNDS

public static final String FIELD_NAME_WINDOW_BOUNDS

See Also:

Constant Field Values

FIELD_NAME_JOIN_SPEC

public static final String FIELD_NAME_JOIN_SPEC

See Also:

Constant Field Values

Constructor Detail

IntervalJoinSpec

public IntervalJoinSpec(JoinSpec joinSpec,
                        IntervalJoinSpec.WindowBounds windowBounds)

Method Detail

getWindowBounds

public IntervalJoinSpec.WindowBounds getWindowBounds()

getJoinSpec

public JoinSpec getJoinSpec()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object