Class TableOperatorWrapper.Edge
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.multipleinput.TableOperatorWrapper.Edge
-
- All Implemented Interfaces:
Serializable
- Enclosing class:
- TableOperatorWrapper<OP extends StreamOperator<RowData>>
public static class TableOperatorWrapper.Edge extends Object implements Serializable
The edge connecting twoTableOperatorWrapper
s.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description Edge(TableOperatorWrapper<?> source, TableOperatorWrapper<?> target, int inputId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
getInputId()
TableOperatorWrapper<?>
getSource()
TableOperatorWrapper<?>
getTarget()
int
hashCode()
String
toString()
-
-
-
Constructor Detail
-
Edge
public Edge(TableOperatorWrapper<?> source, TableOperatorWrapper<?> target, int inputId)
-
-
Method Detail
-
getSource
public TableOperatorWrapper<?> getSource()
-
getTarget
public TableOperatorWrapper<?> getTarget()
-
getInputId
public int getInputId()
-
-