Uses of Class
org.apache.flink.api.java.operators.DataSink

Packages that use DataSink

Package	Description
org.apache.flink.api.java
org.apache.flink.api.java.operators
org.apache.flink.api.java.utils

Uses of DataSink in org.apache.flink.api.java

Methods in org.apache.flink.api.java that return DataSink

Modifier and Type	Method	Description
DataSink<T>	DataSet.output(org.apache.flink.api.common.io.OutputFormat<T> outputFormat)	Deprecated. Emits a DataSet using an OutputFormat.
DataSink<T>	DataSet.print(String sinkIdentifier)	Deprecated. Use DataSet.printOnTaskManager(String) instead.
DataSink<T>	DataSet.printOnTaskManager(String prefix)	Deprecated. Writes a DataSet to the standard output streams (stdout) of the TaskManagers that execute the program (or more specifically, the data sink operators).
DataSink<T>	DataSet.printToErr(String sinkIdentifier)	Deprecated. Use DataSet.printOnTaskManager(String) instead, or the PrintingOutputFormat.
DataSink<T>	DataSet.write(org.apache.flink.api.common.io.FileOutputFormat<T> outputFormat, String filePath)	Deprecated. Writes a DataSet using a FileOutputFormat to a specified location.
DataSink<T>	DataSet.write(org.apache.flink.api.common.io.FileOutputFormat<T> outputFormat, String filePath, org.apache.flink.core.fs.FileSystem.WriteMode writeMode)	Deprecated. Writes a DataSet using a FileOutputFormat to a specified location.
DataSink<T>	DataSet.writeAsCsv(String filePath)	Deprecated. Writes a Tuple DataSet as CSV file(s) to the specified location.
DataSink<T>	DataSet.writeAsCsv(String filePath, String rowDelimiter, String fieldDelimiter)	Deprecated. Writes a Tuple DataSet as CSV file(s) to the specified location with the specified field and line delimiters.
DataSink<T>	DataSet.writeAsCsv(String filePath, String rowDelimiter, String fieldDelimiter, org.apache.flink.core.fs.FileSystem.WriteMode writeMode)	Deprecated. Writes a Tuple DataSet as CSV file(s) to the specified location with the specified field and line delimiters.
DataSink<T>	DataSet.writeAsCsv(String filePath, org.apache.flink.core.fs.FileSystem.WriteMode writeMode)	Deprecated. Writes a Tuple DataSet as CSV file(s) to the specified location.
DataSink<String>	DataSet.writeAsFormattedText(String filePath, TextOutputFormat.TextFormatter<T> formatter)	Deprecated. Writes a DataSet as text file(s) to the specified location.
DataSink<String>	DataSet.writeAsFormattedText(String filePath, org.apache.flink.core.fs.FileSystem.WriteMode writeMode, TextOutputFormat.TextFormatter<T> formatter)	Deprecated. Writes a DataSet as text file(s) to the specified location.
DataSink<T>	DataSet.writeAsText(String filePath)	Deprecated. Writes a DataSet as text file(s) to the specified location.
DataSink<T>	DataSet.writeAsText(String filePath, org.apache.flink.core.fs.FileSystem.WriteMode writeMode)	Deprecated. Writes a DataSet as text file(s) to the specified location.

Uses of DataSink in org.apache.flink.api.java.operators

Methods in org.apache.flink.api.java.operators that return DataSink

Modifier and Type	Method	Description
DataSink<T>	DataSink.name(String name)	Deprecated.
DataSink<T>	DataSink.setParallelism(int parallelism)	Deprecated. Sets the parallelism for this data sink.
DataSink<T>	DataSink.sortLocalOutput(int field, org.apache.flink.api.common.operators.Order order)	Deprecated. Use DataSet.sortPartition(int, Order) instead
DataSink<T>	DataSink.sortLocalOutput(String fieldExpression, org.apache.flink.api.common.operators.Order order)	Deprecated. Use DataSet.sortPartition(String, Order) instead
DataSink<T>	DataSink.withParameters(org.apache.flink.configuration.Configuration parameters)	Deprecated. Pass a configuration to the OutputFormat.

Method parameters in org.apache.flink.api.java.operators with type arguments of type DataSink

Modifier and Type	Method	Description
org.apache.flink.api.common.Plan	OperatorTranslation.translateToPlan(List<DataSink<?>> sinks, String jobName)

Uses of DataSink in org.apache.flink.api.java.utils

Constructor parameters in org.apache.flink.api.java.utils with type arguments of type DataSink

Constructor	Description
PlanGenerator(List<DataSink<?>> sinks, org.apache.flink.api.common.ExecutionConfig config, int defaultParallelism, List<org.apache.flink.api.java.tuple.Tuple2<String,org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry>> cacheFile, String jobName)