Class TableOperatorWrapper.Edge
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.multipleinput.TableOperatorWrapper.Edge
-
- All Implemented Interfaces:
Serializable
- Enclosing class:
- TableOperatorWrapper<OP extends org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.table.data.RowData>>
public static class TableOperatorWrapper.Edge extends Object implements Serializable
The edge connecting twoTableOperatorWrappers.- 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 booleanequals(Object o)intgetInputId()TableOperatorWrapper<?>getSource()TableOperatorWrapper<?>getTarget()inthashCode()StringtoString()
-
-
-
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()
-
-