Modifier and Type | Method and Description |
---|---|
FileSystem.WriteMode |
FileOutputFormat.getWriteMode() |
Modifier and Type | Method and Description |
---|---|
void |
FileOutputFormat.setWriteMode(FileSystem.WriteMode mode) |
Modifier and Type | Method and Description |
---|---|
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,
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,
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<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> |
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 FileSystem.WriteMode |
FileSystem.WriteMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FileSystem.WriteMode[] |
FileSystem.WriteMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SafetyNetWrapperFileSystem.initOutPathDistFS(Path outPath,
FileSystem.WriteMode writeMode,
boolean createDirectory) |
boolean |
FileSystem.initOutPathDistFS(Path outPath,
FileSystem.WriteMode writeMode,
boolean createDirectory)
Initializes output directories on distributed file systems according to the given write mode.
|
boolean |
SafetyNetWrapperFileSystem.initOutPathLocalFS(Path outPath,
FileSystem.WriteMode writeMode,
boolean createDirectory) |
boolean |
FileSystem.initOutPathLocalFS(Path outPath,
FileSystem.WriteMode writeMode,
boolean createDirectory)
Initializes output directories on local file systems according to the given write mode.
|
Modifier and Type | Field and Description |
---|---|
FileSystem.WriteMode |
PythonOperationInfo.writeMode |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode)
Writes a DataStream to the file specified by the path parameter.
|
<X extends Tuple> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode,
String rowDelimiter,
String fieldDelimiter)
Writes a DataStream to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsText(String path,
FileSystem.WriteMode writeMode)
Writes a DataStream to the file specified by path in text format.
|
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode)
Writes the DataStream in CSV format to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode,
String rowDelimiter,
String fieldDelimiter)
Writes the DataStream in CSV format to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsText(String path,
FileSystem.WriteMode writeMode)
Writes a DataStream to the file specified by path in text format.
|
Constructor and Description |
---|
CsvTableSink(String path,
String fieldDelim,
int numFiles,
FileSystem.WriteMode writeMode)
A simple
TableSink to emit data as CSV files. |
Constructor and Description |
---|
CsvTableSink(String path,
scala.Option<String> fieldDelim,
scala.Option<Object> numFiles,
scala.Option<FileSystem.WriteMode> writeMode) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.