public class StreamExecJoin extends ExecNodeBase<RowData> implements StreamExecNode<RowData>, SingleTransformationTranslator<RowData>
StreamExecNode
for regular Joins.
Regular joins are the most generic type of join in which any new records or changes to either side of the join input are visible and are affecting the whole join result.
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_JOIN_SPEC |
static String |
FIELD_NAME_LEFT_UNIQUE_KEYS |
static String |
FIELD_NAME_RIGHT_UNIQUE_KEYS |
FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE
Constructor and Description |
---|
StreamExecJoin(JoinSpec joinSpec,
List<int[]> leftUniqueKeys,
List<int[]> rightUniqueKeys,
InputProperty leftInputProperty,
InputProperty rightInputProperty,
RowType outputType,
String description) |
StreamExecJoin(JoinSpec joinSpec,
List<int[]> leftUniqueKeys,
List<int[]> rightUniqueKeys,
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_LEFT_UNIQUE_KEYS
public static final String FIELD_NAME_RIGHT_UNIQUE_KEYS
public StreamExecJoin(JoinSpec joinSpec, List<int[]> leftUniqueKeys, List<int[]> rightUniqueKeys, InputProperty leftInputProperty, InputProperty rightInputProperty, 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.