类的使用
org.apache.flink.table.planner.plan.nodes.exec.spec.TemporalTableSourceSpec

使用TemporalTableSourceSpec的程序包

程序包	说明
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.stream

org.apache.flink.table.planner.plan.nodes.exec.batch中TemporalTableSourceSpec的使用

参数类型为TemporalTableSourceSpec的org.apache.flink.table.planner.plan.nodes.exec.batch中的构造器

构造器和说明

BatchExecLookupJoin(org.apache.flink.configuration.ReadableConfig tableConfig, org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType, org.apache.calcite.rex.RexNode joinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, InputProperty inputProperty, org.apache.flink.table.types.logical.RowType outputType, String description)

org.apache.flink.table.planner.plan.nodes.exec.common中TemporalTableSourceSpec的使用

返回TemporalTableSourceSpec的org.apache.flink.table.planner.plan.nodes.exec.common中的方法

限定符和类型	方法和说明
TemporalTableSourceSpec	CommonExecLookupJoin.getTemporalTableSourceSpec()

参数类型为TemporalTableSourceSpec的org.apache.flink.table.planner.plan.nodes.exec.common中的构造器

构造器和说明

CommonExecLookupJoin(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType, org.apache.calcite.rex.RexNode joinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)

org.apache.flink.table.planner.plan.nodes.exec.stream中TemporalTableSourceSpec的使用

参数类型为TemporalTableSourceSpec的org.apache.flink.table.planner.plan.nodes.exec.stream中的构造器

构造器和说明
StreamExecLookupJoin(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType, org.apache.calcite.rex.RexNode joinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)
StreamExecLookupJoin(org.apache.flink.configuration.ReadableConfig tableConfig, org.apache.flink.table.runtime.operators.join.FlinkJoinType joinType, org.apache.calcite.rex.RexNode joinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, InputProperty inputProperty, org.apache.flink.table.types.logical.RowType outputType, String description)