Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala | |
org.apache.flink.ml |
Modifier and Type | Method and Description |
---|---|
DataSink<T> |
DataSet.output(OutputFormat<T> outputFormat)
Emits a DataSet using an
OutputFormat . |
DataSink<T> |
DataSet.print(String sinkIdentifier)
Deprecated.
Use
DataSet.printOnTaskManager(String) instead. |
DataSink<T> |
DataSet.printOnTaskManager(String prefix)
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, othe
PrintingOutputFormat instead. |
DataSink<T> |
DataSet.write(FileOutputFormat<T> outputFormat,
String filePath)
Writes a DataSet using a
FileOutputFormat to a specified location. |
DataSink<T> |
DataSet.write(FileOutputFormat<T> outputFormat,
String filePath,
FileSystem.WriteMode writeMode)
Writes a DataSet using a
FileOutputFormat to a specified location. |
DataSink<T> |
DataSet.writeAsCsv(String filePath)
Writes a
Tuple DataSet as CSV file(s) to the specified location.Note: Only a Tuple DataSet can written as a CSV file. For each Tuple field the result of Object.toString() is written. |
DataSink<T> |
DataSet.writeAsCsv(String filePath,
FileSystem.WriteMode writeMode)
Writes a
Tuple DataSet as CSV file(s) to the specified location.Note: Only a Tuple DataSet can written as a CSV file. For each Tuple field the result of Object.toString() is written. |
DataSink<T> |
DataSet.writeAsCsv(String filePath,
String rowDelimiter,
String fieldDelimiter)
Writes a
Tuple DataSet as CSV file(s) to the specified location with the specified field and line delimiters.Note: Only a Tuple DataSet can written as a CSV file. For each Tuple field the result of Object.toString() is written. |
DataSink<T> |
DataSet.writeAsCsv(String filePath,
String rowDelimiter,
String fieldDelimiter,
FileSystem.WriteMode writeMode)
Writes a
Tuple DataSet as CSV file(s) to the specified location with the specified field and line delimiters.Note: Only a Tuple DataSet can written as a CSV file. ยง * For each Tuple field the result of Object.toString() is written. |
DataSink<String> |
DataSet.writeAsFormattedText(String filePath,
FileSystem.WriteMode writeMode,
TextOutputFormat.TextFormatter<T> formatter)
Writes a DataSet as text file(s) to the specified location.
For each element of the DataSet the result of TextOutputFormat.TextFormatter.format(Object) is written. |
DataSink<String> |
DataSet.writeAsFormattedText(String filePath,
TextOutputFormat.TextFormatter<T> formatter)
Writes a DataSet as text file(s) to the specified location.
For each element of the DataSet the result of TextOutputFormat.TextFormatter.format(Object) is written. |
DataSink<T> |
DataSet.writeAsText(String filePath)
Writes a DataSet as text file(s) to the specified location.
For each element of the DataSet the result of Object.toString() is written.Output files and directories What output how writeAsText() method produces is depending on other circumstance A directory is created and multiple files are written underneath. |
DataSink<T> |
DataSet.writeAsText(String filePath,
FileSystem.WriteMode writeMode)
Writes a DataSet as text file(s) to the specified location.
For each element of the DataSet the result of Object.toString() is written. |
Modifier and Type | Method and Description |
---|---|
DataSink<T> |
DataSink.name(String name) |
DataSink<T> |
DataSink.setParallelism(int parallelism)
Sets the parallelism for this data sink.
|
DataSink<T> |
DataSink.sortLocalOutput(int field,
Order order)
Deprecated.
|
DataSink<T> |
DataSink.sortLocalOutput(String fieldExpression,
Order order)
Deprecated.
|
DataSink<T> |
DataSink.withParameters(Configuration parameters)
Pass a configuration to the OutputFormat
|
Modifier and Type | Method and Description |
---|---|
Plan |
OperatorTranslation.translateToPlan(List<DataSink<?>> sinks,
String jobName) |
Modifier and Type | Method and Description |
---|---|
DataSink<T> |
DataSet.output(OutputFormat<T> outputFormat)
Emits
this DataSet using a custom OutputFormat . |
DataSink<T> |
DataSet.print(String sinkIdentifier)
Deprecated.
Use
DataSet.printOnTaskManager(String) instead. |
DataSink<T> |
DataSet.printOnTaskManager(String prefix)
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. |
DataSink<T> |
DataSet.write(FileOutputFormat<T> outputFormat,
String filePath,
FileSystem.WriteMode writeMode)
Writes
this DataSet to the specified location using a custom
FileOutputFormat . |
DataSink<T> |
DataSet.writeAsCsv(String filePath,
String rowDelimiter,
String fieldDelimiter,
FileSystem.WriteMode writeMode)
Writes
this DataSet to the specified location as CSV file(s). |
DataSink<T> |
DataSet.writeAsText(String filePath,
FileSystem.WriteMode writeMode)
Writes
this DataSet to the specified location. |
Modifier and Type | Method and Description |
---|---|
static DataSink<String> |
MLUtils.writeLibSVM(String filePath,
DataSet<LabeledVector> labeledVectors)
Writes a
DataSet of LabeledVector to a file using the libSVM/SVMLight format. |
DataSink<String> |
MLUtils$.writeLibSVM(String filePath,
DataSet<LabeledVector> labeledVectors)
Writes a
DataSet of LabeledVector to a file using the libSVM/SVMLight format. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.