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,
boolean isKeyedStream) |
PythonCoMapOperator(Configuration config,
TypeInformation<IN1> inputTypeInfo1,
TypeInformation<IN2> inputTypeInfo2,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo,
boolean isKeyedStream) |
PythonFlatMapOperator(Configuration config,
TypeInformation<IN> inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonKeyedProcessOperator(Configuration config,
RowTypeInfo inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
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) |
PythonReduceOperator(Configuration config,
TypeInformation<Row> inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo) |
PythonTimestampsAndWatermarksOperator(Configuration config,
TypeInformation<IN> inputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo,
WatermarkStrategy<IN> watermarkStrategy) |
TwoInputPythonFunctionOperator(Configuration config,
TypeInformation<IN1> inputTypeInfo1,
TypeInformation<IN2> inputTypeInfo2,
TypeInformation<OUT> outputTypeInfo,
DataStreamPythonFunctionInfo pythonFunctionInfo,
boolean isKeyedStream) |