OneInputPythonFunctionOperator(Configuration config,
TypeInformation<UDFIN> runnerInputTypeInfo,
TypeInformation<UDFOUT> runnerOutputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonCoFlatMapOperator(Configuration config,
TypeInformation<IN1> inputTypeInfo1,
TypeInformation<IN2> inputTypeInfo2,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonCoMapOperator(Configuration config,
TypeInformation<IN1> inputTypeInfo1,
TypeInformation<IN2> inputTypeInfo2,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonFlatMapOperator(Configuration config,
TypeInformation<IN> inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonKeyedCoProcessOperator(Configuration config,
TypeInformation<Row> inputTypeInfo1,
TypeInformation<Row> inputTypeInfo2,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonKeyedProcessOperator(Configuration config,
RowTypeInfo inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonKeyedProcessOperator(Configuration config,
RowTypeInfo inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo,
TypeSerializer namespaceSerializer) |
PythonMapOperator(Configuration config,
TypeInformation<IN> inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonPartitionCustomOperator(Configuration config,
TypeInformation<IN> inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonProcessOperator(Configuration config,
TypeInformation<IN> inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonTimestampsAndWatermarksOperator(Configuration config,
TypeInformation<IN> inputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo,
WatermarkStrategy<IN> watermarkStrategy) |
TwoInputPythonFunctionOperator(Configuration config,
DataStreamPythonFunctionInfo pythonFunctionInfo,
String coderUrn,
TypeInformation<Row> runnerInputTypeInfo,
TypeInformation<RUNNER_OUT> runnerOutputTypeInfo) |
TwoInputPythonFunctionOperator(Configuration config,
TypeInformation<IN1> inputTypeInfo1,
TypeInformation<IN2> inputTypeInfo2,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo,
String coderUrn) |