Interface DataStreamPythonFunctionOperator<OUT>

    • Method Detail

      • setNumPartitions

        void setNumPartitions​(int numPartitions)
        Sets the number of partitions. This is used for partitionCustom which takes the number of partitions to partition into as input.
      • addSideOutputTags

        void addSideOutputTags​(Collection<org.apache.flink.util.OutputTag<?>> outputTags)
        Add a collection of OutputTags to the operator.
      • getSideOutputTags

        Collection<org.apache.flink.util.OutputTag<?>> getSideOutputTags()
        Gets the OutputTags belongs to the operator.
      • copy

        <T> DataStreamPythonFunctionOperator<T> copy​(DataStreamPythonFunctionInfo pythonFunctionInfo,
                                                     org.apache.flink.api.common.typeinfo.TypeInformation<T> outputTypeInfo)
        Make a copy of the DataStreamPythonFunctionOperator with the given pythonFunctionInfo and outputTypeInfo. This is used for chaining optimization which may need to update the underlying pythonFunctionInfo and outputTypeInfo with the other fields not changed.