Package org.apache.flink.table.runtime.operators.multipleinput

Class TableOperatorWrapper<OP extends StreamOperator<RowData>>

java.lang.Object

org.apache.flink.table.runtime.operators.multipleinput.TableOperatorWrapper<OP>

All Implemented Interfaces:

Serializable

public class TableOperatorWrapper<OP extends StreamOperator<RowData>>
extends Object
implements Serializable

This class handles the close, endInput and other related logic of a StreamOperator. It also automatically propagates the end-input operation to the next wrapper that the outputEdges points to, so we only need to call the head wrapper's endOperatorInput(int) method.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TableOperatorWrapper.Edge	The edge connecting two TableOperatorWrappers.

Constructor Summary

Constructors

Constructor	Description
TableOperatorWrapper(StreamOperatorFactory<RowData> factory, String operatorName, List<TypeInformation<?>> allInputTypes, TypeInformation<?> outputType)

Method Summary

Modifier and Type	Method	Description
void	addInput(TableOperatorWrapper<?> input, int inputId)
void	close()
void	createOperator(StreamOperatorParameters<RowData> parameters)
void	endOperatorInput(int inputId)
boolean	equals(Object o)
List<TypeInformation<?>>	getAllInputTypes()
int	getEndedInputCount()
List<TableOperatorWrapper.Edge>	getInputEdges()
List<TableOperatorWrapper<?>>	getInputWrappers()
double	getManagedMemoryFraction()
String	getOperatorName()
List<TableOperatorWrapper.Edge>	getOutputEdges()
TypeInformation<?>	getOutputType()
List<TableOperatorWrapper<?>>	getOutputWrappers()
OP	getStreamOperator()
int	hashCode()
boolean	isClosed()	Checks if the wrapped operator has been closed.
void	setManagedMemoryFraction(double managedMemoryFraction)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TableOperatorWrapper

public TableOperatorWrapper(StreamOperatorFactory<RowData> factory,
                            String operatorName,
                            List<TypeInformation<?>> allInputTypes,
                            TypeInformation<?> outputType)

Method Detail

createOperator

public void createOperator(StreamOperatorParameters<RowData> parameters)

endOperatorInput

public void endOperatorInput(int inputId)
                      throws Exception

Throws:

Exception

getStreamOperator

public OP getStreamOperator()

getAllInputTypes

public List<TypeInformation<?>> getAllInputTypes()

getOutputType

public TypeInformation<?> getOutputType()

addInput

public void addInput(TableOperatorWrapper<?> input,
                     int inputId)

setManagedMemoryFraction

public void setManagedMemoryFraction(double managedMemoryFraction)

getManagedMemoryFraction

public double getManagedMemoryFraction()

getInputEdges

public List<TableOperatorWrapper.Edge> getInputEdges()

getInputWrappers

public List<TableOperatorWrapper<?>> getInputWrappers()

getOutputEdges

public List<TableOperatorWrapper.Edge> getOutputEdges()

getOutputWrappers

public List<TableOperatorWrapper<?>> getOutputWrappers()

isClosed

public boolean isClosed()

Checks if the wrapped operator has been closed.

Note that this method must be called in the task thread.

close

public void close()
           throws Exception

Throws:

Exception

getOperatorName

public String getOperatorName()

getEndedInputCount

@VisibleForTesting
public int getEndedInputCount()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object