public class BatchExecLookupJoin extends CommonExecLookupJoin implements BatchExecNode<RowData>
BatchExecNode
for temporal table join that implemented by lookup.FIELD_NAME_FILTER_ON_TEMPORAL_TABLE, FIELD_NAME_JOIN_CONDITION, FIELD_NAME_JOIN_TYPE, FIELD_NAME_LOOKUP_KEYS, FIELD_NAME_PROJECTION_ON_TEMPORAL_TABLE, FIELD_NAME_TEMPORAL_TABLE, LOOKUP_JOIN_TRANSFORMATION
FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_TYPE
Constructor and Description |
---|
BatchExecLookupJoin(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,
InputProperty inputProperty,
RowType outputType,
String description) |
getTemporalTableSourceSpec, translateToPlanInternal, validateLookupKeyType
accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges
translateToPlan
public BatchExecLookupJoin(ReadableConfig tableConfig, FlinkJoinType joinType, @Nullable org.apache.calcite.rex.RexNode joinCondition, TemporalTableSourceSpec temporalTableSourceSpec, Map<Integer,LookupJoinUtil.LookupKey> lookupKeys, @Nullable List<org.apache.calcite.rex.RexNode> projectionOnTemporalTable, @Nullable org.apache.calcite.rex.RexNode filterOnTemporalTable, InputProperty inputProperty, RowType outputType, String description)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.