Class LocalCollectionOutputFormat<T>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.io.OutputFormat<T>, org.apache.flink.api.java.typeutils.InputTypeConfigurable

    @Deprecated
    @PublicEvolving
    public class LocalCollectionOutputFormat<T>
    extends org.apache.flink.api.common.io.RichOutputFormat<T>
    implements org.apache.flink.api.java.typeutils.InputTypeConfigurable
    Deprecated.
    All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
    An output format that adds records to a collection.
    See Also:
    FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API, Serialized Form
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.api.common.io.OutputFormat

        org.apache.flink.api.common.io.OutputFormat.InitializationContext
    • Constructor Detail

      • LocalCollectionOutputFormat

        public LocalCollectionOutputFormat​(Collection<T> out)
        Deprecated.
    • Method Detail

      • configure

        public void configure​(org.apache.flink.configuration.Configuration parameters)
        Deprecated.
        Specified by:
        configure in interface org.apache.flink.api.common.io.OutputFormat<T>
      • open

        public void open​(int taskNumber,
                         int numTasks)
                  throws IOException
        Deprecated.
        Specified by:
        open in interface org.apache.flink.api.common.io.OutputFormat<T>
        Throws:
        IOException
      • writeRecord

        public void writeRecord​(T record)
                         throws IOException
        Deprecated.
        Specified by:
        writeRecord in interface org.apache.flink.api.common.io.OutputFormat<T>
        Throws:
        IOException
      • close

        public void close()
                   throws IOException
        Deprecated.
        Specified by:
        close in interface org.apache.flink.api.common.io.OutputFormat<T>
        Throws:
        IOException
      • setInputType

        public void setInputType​(org.apache.flink.api.common.typeinfo.TypeInformation<?> type,
                                 org.apache.flink.api.common.ExecutionConfig executionConfig)
        Deprecated.
        Specified by:
        setInputType in interface org.apache.flink.api.java.typeutils.InputTypeConfigurable