Constructor and Description |
---|
LookupCallContext(DataTypeFactory dataTypeFactory,
UserDefinedFunction function,
LogicalType inputType,
Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
int[] lookupKeyOrder,
LogicalType lookupType) |
Constructor and Description |
---|
BatchExecLookupJoin(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,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected void |
CommonExecLookupJoin.validateLookupKeyType(Map<Integer,LookupJoinUtil.LookupKey> lookupKeys,
RowType inputRowType,
RowType tableSourceRowType) |
Constructor and Description |
---|
CommonExecLookupJoin(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,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Constructor and Description |
---|
StreamExecLookupJoin(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,
RowType outputType,
String description) |
StreamExecLookupJoin(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,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
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. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.