public class StreamExecTemporalJoin extends ExecNodeBase<RowData> implements StreamExecNode<RowData>, SingleTransformationTranslator<RowData>
StreamExecNode
for temporal table join (FOR SYSTEM_TIME AS OF) and temporal TableFunction
join (LATERAL TemporalTableFunction(o.proctime)).
The legacy temporal table function join is the subset of temporal table join, the only difference is the validation, we reuse most same logic here.
Modifier and Type | Field and Description |
---|---|
static int |
FIELD_INDEX_FOR_PROC_TIME_ATTRIBUTE |
static String |
FIELD_NAME_IS_TEMPORAL_FUNCTION_JOIN |
static String |
FIELD_NAME_JOIN_SPEC |
static String |
FIELD_NAME_LEFT_TIME_ATTRIBUTE_INDEX |
static String |
FIELD_NAME_RIGHT_TIME_ATTRIBUTE_INDEX |
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecTemporalJoin(JoinSpec joinSpec,
boolean isTemporalTableFunctionJoin,
int leftTimeAttributeIndex,
int rightTimeAttributeIndex,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecTemporalJoin(JoinSpec joinSpec,
boolean isTemporalTableFunctionJoin,
int leftTimeAttributeIndex,
int rightTimeAttributeIndex,
int id,
List<InputProperty> inputProperties,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
protected Transformation<RowData> |
translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
Internal method, translates this node into a Flink operator.
|
accept, getDescription, getId, getInputEdges, getInputProperties, getNewNodeId, getOutputType, inputsContainSingleton, replaceInputEdge, resetIdCounter, setInputEdges, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setInputEdges
translateToPlan
public static final String FIELD_NAME_JOIN_SPEC
public static final String FIELD_NAME_IS_TEMPORAL_FUNCTION_JOIN
public static final String FIELD_NAME_LEFT_TIME_ATTRIBUTE_INDEX
public static final String FIELD_NAME_RIGHT_TIME_ATTRIBUTE_INDEX
public static final int FIELD_INDEX_FOR_PROC_TIME_ATTRIBUTE
public StreamExecTemporalJoin(JoinSpec joinSpec, boolean isTemporalTableFunctionJoin, int leftTimeAttributeIndex, int rightTimeAttributeIndex, InputProperty leftInputProperty, InputProperty rightInputProperty, RowType outputType, String description)
public StreamExecTemporalJoin(JoinSpec joinSpec, boolean isTemporalTableFunctionJoin, int leftTimeAttributeIndex, int rightTimeAttributeIndex, int id, List<InputProperty> inputProperties, RowType outputType, String description)
protected Transformation<RowData> translateToPlanInternal(org.apache.flink.table.planner.delegation.PlannerBase planner)
ExecNodeBase
translateToPlanInternal
in class ExecNodeBase<RowData>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.