Constructor and Description |
---|
CommonExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
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,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
RowType outputType,
LookupJoinHintSpec lookupJoinHintSpec,
String description) |
Modifier and Type | Method and Description |
---|---|
static LookupJoinHintSpec |
LookupJoinHintSpec.fromJoinHint(org.apache.calcite.rel.hint.RelHint lookupJoinHint)
Convert given joinHint to
LookupJoinHintSpec . |
Constructor and Description |
---|
StreamExecLookupJoin(int id,
ExecNodeContext context,
ReadableConfig persistedConfig,
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,
ChangelogMode inputChangelogMode,
List<InputProperty> inputProperties,
RowType outputType,
boolean lookupKeyContainsPrimaryKey,
boolean upsertMaterialize,
LookupJoinHintSpec lookupJoinHintSpec,
String description) |
StreamExecLookupJoin(ReadableConfig tableConfig,
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,
ChangelogMode inputChangelogMode,
InputProperty inputProperty,
RowType outputType,
boolean lookupKeyContainsPrimaryKey,
boolean upsertMaterialize,
LookupJoinHintSpec lookupJoinHintSpec,
String description) |
Modifier and Type | Method and Description |
---|---|
static UserDefinedFunction |
LookupJoinUtil.getLookupFunction(org.apache.calcite.plan.RelOptTable temporalTable,
Collection<Integer> lookupKeys,
ClassLoader classLoader,
LookupJoinHintSpec joinHintSpec,
boolean upsertMaterialize)
Gets lookup function (async or sync) from temporal table according to the given lookup keys
with considering
LookupJoinHintSpec and required upsertMaterialize. |
static boolean |
LookupJoinUtil.isAsyncLookup(org.apache.calcite.plan.RelOptTable temporalTable,
Collection<Integer> lookupKeys,
LookupJoinHintSpec lookupJoinHintSpec) |
static boolean |
LookupJoinUtil.preferAsync(LookupJoinHintSpec lookupJoinHintSpec) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.