Package org.apache.flink.api.java.io
Class LocalCollectionOutputFormat<T>
- java.lang.Object
-
- org.apache.flink.api.common.io.RichOutputFormat<T>
-
- org.apache.flink.api.java.io.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.
-
-
Constructor Summary
Constructors Constructor Description LocalCollectionOutputFormat(Collection<T> out)Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description voidclose()Deprecated.voidconfigure(org.apache.flink.configuration.Configuration parameters)Deprecated.voidopen(int taskNumber, int numTasks)Deprecated.voidsetInputType(org.apache.flink.api.common.typeinfo.TypeInformation<?> type, org.apache.flink.api.common.ExecutionConfig executionConfig)Deprecated.voidwriteRecord(T record)Deprecated.-
Methods inherited from class org.apache.flink.api.common.io.RichOutputFormat
getRuntimeContext, setRuntimeContext
-
-
-
-
Constructor Detail
-
LocalCollectionOutputFormat
public LocalCollectionOutputFormat(Collection<T> out)
Deprecated.
-
-
Method Detail
-
configure
public void configure(org.apache.flink.configuration.Configuration parameters)
Deprecated.- Specified by:
configurein interfaceorg.apache.flink.api.common.io.OutputFormat<T>
-
open
public void open(int taskNumber, int numTasks) throws IOExceptionDeprecated.- Specified by:
openin interfaceorg.apache.flink.api.common.io.OutputFormat<T>- Throws:
IOException
-
writeRecord
public void writeRecord(T record) throws IOException
Deprecated.- Specified by:
writeRecordin interfaceorg.apache.flink.api.common.io.OutputFormat<T>- Throws:
IOException
-
close
public void close() throws IOExceptionDeprecated.- Specified by:
closein interfaceorg.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:
setInputTypein interfaceorg.apache.flink.api.java.typeutils.InputTypeConfigurable
-
-