Uses of Class
org.apache.flink.table.planner.plan.utils.LookupJoinUtil.LookupKey

Packages that use LookupJoinUtil.LookupKey

Package	Description
org.apache.flink.table.planner.functions.inference
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.utils

Uses of LookupJoinUtil.LookupKey in org.apache.flink.table.planner.functions.inference

Constructor parameters in org.apache.flink.table.planner.functions.inference with type arguments of type LookupJoinUtil.LookupKey

Constructor and Description
LookupCallContext(org.apache.flink.table.catalog.DataTypeFactory dataTypeFactory, org.apache.flink.table.functions.UserDefinedFunction function, org.apache.flink.table.types.logical.LogicalType inputType, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, int[] lookupKeyOrder, org.apache.flink.table.types.logical.LogicalType lookupType)

Uses of LookupJoinUtil.LookupKey in org.apache.flink.table.planner.plan.nodes.exec.batch

Method parameters in org.apache.flink.table.planner.plan.nodes.exec.batch with type arguments of type LookupJoinUtil.LookupKey

Modifier and Type

Method and Description

protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>

BatchExecLookupJoin.createSyncLookupJoinWithState(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)

Constructor parameters in org.apache.flink.table.planner.plan.nodes.exec.batch with type arguments of type LookupJoinUtil.LookupKey

Constructor and Description

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

Uses of LookupJoinUtil.LookupKey in org.apache.flink.table.planner.plan.nodes.exec.common

Method parameters in org.apache.flink.table.planner.plan.nodes.exec.common with type arguments of type LookupJoinUtil.LookupKey

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.functions.ProcessFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>	CommonExecLookupJoin.createSyncLookupJoinFunction(org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled)
protected abstract org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>	CommonExecLookupJoin.createSyncLookupJoinWithState(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)
protected void	CommonExecLookupJoin.validateLookupKeyType(Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType)

Constructor parameters in org.apache.flink.table.planner.plan.nodes.exec.common with type arguments of type LookupJoinUtil.LookupKey

Constructor and Description

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 preFilterCondition, org.apache.calcite.rex.RexNode remainingJoinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, LookupJoinUtil.AsyncLookupOptions asyncLookupOptions, LookupJoinUtil.RetryLookupOptions retryOptions, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.RowType outputType, String description)

Uses of LookupJoinUtil.LookupKey in org.apache.flink.table.planner.plan.nodes.exec.stream

Method parameters in org.apache.flink.table.planner.plan.nodes.exec.stream with type arguments of type LookupJoinUtil.LookupKey

Modifier and Type

Method and Description

protected org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData>

StreamExecLookupJoin.createSyncLookupJoinWithState(org.apache.flink.api.dag.Transformation<org.apache.flink.table.data.RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, org.apache.flink.table.functions.TableFunction<?> syncLookupFunction, RelBuilder relBuilder, org.apache.flink.table.types.logical.RowType inputRowType, org.apache.flink.table.types.logical.RowType tableSourceRowType, org.apache.flink.table.types.logical.RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)

Constructor parameters in org.apache.flink.table.planner.plan.nodes.exec.stream with type arguments of type LookupJoinUtil.LookupKey

Constructor and Description
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 preFilterCondition, org.apache.calcite.rex.RexNode remainingJoinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, boolean lookupKeyContainsPrimaryKey, boolean upsertMaterialize, LookupJoinUtil.AsyncLookupOptions asyncLookupOptions, LookupJoinUtil.RetryLookupOptions retryOptions, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, List<StateMetadata> stateMetadataList, 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 preFilterCondition, org.apache.calcite.rex.RexNode remainingJoinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, org.apache.calcite.rex.RexNode filterOnTemporalTable, boolean lookupKeyContainsPrimaryKey, boolean upsertMaterialize, LookupJoinUtil.AsyncLookupOptions asyncLookupOptions, LookupJoinUtil.RetryLookupOptions retryOptions, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, InputProperty inputProperty, org.apache.flink.table.types.logical.RowType outputType, String description)

Uses of LookupJoinUtil.LookupKey in org.apache.flink.table.planner.plan.utils

Subclasses of LookupJoinUtil.LookupKey in org.apache.flink.table.planner.plan.utils

Modifier and Type	Class and Description
static class	LookupJoinUtil.ConstantLookupKey A LookupJoinUtil.LookupKey whose value is constant.
static class	LookupJoinUtil.FieldRefLookupKey A LookupJoinUtil.LookupKey whose value comes from the left table field.