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

Class TemporalTableSourceSpec

java.lang.Object

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

public class TemporalTableSourceSpec
extends Object

TemporalTableSpec describes how the right tale of lookupJoin ser/des.

This class corresponds to RelOptTable rel node.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_LOOK_UP_TABLE_SOURCE
static String	FIELD_NAME_OUTPUT_TYPE

Constructor Summary

Constructors

Constructor and Description
TemporalTableSourceSpec(DynamicTableSourceSpec dynamicTableSourceSpec, org.apache.calcite.rel.type.RelDataType outputType)
TemporalTableSourceSpec(org.apache.calcite.plan.RelOptTable temporalTable)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rel.type.RelDataType	getOutputType()
DynamicTableSourceSpec	getTableSourceSpec()
org.apache.calcite.plan.RelOptTable	getTemporalTable(FlinkContext context, FlinkTypeFactory typeFactory)

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_LOOK_UP_TABLE_SOURCE

public static final String FIELD_NAME_LOOK_UP_TABLE_SOURCE

See Also:

Constant Field Values

FIELD_NAME_OUTPUT_TYPE

public static final String FIELD_NAME_OUTPUT_TYPE

See Also:

Constant Field Values

Constructor Detail

TemporalTableSourceSpec

public TemporalTableSourceSpec(org.apache.calcite.plan.RelOptTable temporalTable)

TemporalTableSourceSpec

public TemporalTableSourceSpec(@Nullable
                               DynamicTableSourceSpec dynamicTableSourceSpec,
                               @Nullable
                               org.apache.calcite.rel.type.RelDataType outputType)

Method Detail

getTemporalTable

public org.apache.calcite.plan.RelOptTable getTemporalTable(FlinkContext context,
                                                            FlinkTypeFactory typeFactory)

getTableSourceSpec

public DynamicTableSourceSpec getTableSourceSpec()

getOutputType

@Nullable
public org.apache.calcite.rel.type.RelDataType getOutputType()