org.apache.flink.streaming.api.functions.python

Class DataStreamPythonFunctionInfo

java.lang.Object

org.apache.flink.table.functions.python.PythonFunctionInfo

org.apache.flink.streaming.api.functions.python.DataStreamPythonFunctionInfo

All Implemented Interfaces:

Serializable

@Internal
public class DataStreamPythonFunctionInfo
extends PythonFunctionInfo

DataStreamPythonFunctionInfo holds a PythonFunction and its function type.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DataStreamPythonFunctionInfo(PythonFunction pythonFunction, DataStreamPythonFunctionInfo input, int functionType)
DataStreamPythonFunctionInfo(PythonFunction pythonFunction, int functionType)

Method Summary

Modifier and Type	Method and Description
DataStreamPythonFunctionInfo	copy()
int	getFunctionType()

Methods inherited from class org.apache.flink.table.functions.python.PythonFunctionInfo

getInputs, getPythonFunction, setInputs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataStreamPythonFunctionInfo

public DataStreamPythonFunctionInfo(PythonFunction pythonFunction,
                                    int functionType)

DataStreamPythonFunctionInfo

public DataStreamPythonFunctionInfo(PythonFunction pythonFunction,
                                    DataStreamPythonFunctionInfo input,
                                    int functionType)

Method Detail

getFunctionType

public int getFunctionType()

copy

public DataStreamPythonFunctionInfo copy()