Interface OutputTypeConfigurable<OUT>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void setOutputType​(org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo, org.apache.flink.api.common.ExecutionConfig executionConfig)
      Is called by the org.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer, String, StreamOperator, TypeInformation, TypeInformation, String) method when the StreamGraph is generated.
    • Method Detail

      • setOutputType

        void setOutputType​(org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo,
                           org.apache.flink.api.common.ExecutionConfig executionConfig)
        Is called by the org.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer, String, StreamOperator, TypeInformation, TypeInformation, String) method when the StreamGraph is generated. The method is called with the output TypeInformation which is also used for the StreamTask output serializer.
        Parameters:
        outTypeInfo - Output type information of the StreamTask
        executionConfig - Execution configuration