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)
Deprecated.
Writes a DataSet using a
FileOutputFormat to a specified location. |
DataSink<T> |
DataSet.writeAsCsv(String filePath,
FileSystem.WriteMode writeMode)
Deprecated.
Writes a
Tuple DataSet as CSV file(s) to the specified location. |
DataSink<T> |
DataSet.writeAsCsv(String filePath,
String rowDelimiter,
String fieldDelimiter,
FileSystem.WriteMode writeMode)
Deprecated.
Writes a
Tuple DataSet as CSV file(s) to the specified location with the specified
field and line delimiters. |
DataSink<String> |
DataSet.writeAsFormattedText(String filePath,
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,
FileSystem.WriteMode writeMode)
Deprecated.
Writes a DataSet as text file(s) 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 |
---|---|
abstract FSDataOutputStream |
FileSystem.create(Path f,
FileSystem.WriteMode overwriteMode)
Opens an FSDataOutputStream to a new file at the given path.
|
FSDataOutputStream |
LimitedConnectionsFileSystem.create(Path f,
FileSystem.WriteMode overwriteMode) |
FSDataOutputStream |
SafetyNetWrapperFileSystem.create(Path f,
FileSystem.WriteMode overwrite) |
static OutputStreamAndPath |
EntropyInjector.createEntropyAware(FileSystem fs,
Path path,
FileSystem.WriteMode writeMode)
Handles entropy injection across regular and entropy-aware file systems.
|
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.initOutPathDistFS(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.
|
boolean |
SafetyNetWrapperFileSystem.initOutPathLocalFS(Path outPath,
FileSystem.WriteMode writeMode,
boolean createDirectory) |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
LocalFileSystem.create(Path filePath,
FileSystem.WriteMode overwrite) |
Modifier and Type | Method and Description |
---|---|
HadoopDataOutputStream |
HadoopFileSystem.create(Path f,
FileSystem.WriteMode overwrite) |
Modifier and Type | Method and Description |
---|---|
ByteBufferWritableFSDataOutputStream |
ForStFlinkFileSystem.create(Path path,
FileSystem.WriteMode overwriteMode) |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
<X extends Tuple> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode,
String rowDelimiter,
String fieldDelimiter)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
DataStreamSink<T> |
DataStream.writeAsText(String path,
FileSystem.WriteMode writeMode)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
Constructor and Description |
---|
CsvTableSink(String path,
String fieldDelim,
int numFiles,
FileSystem.WriteMode writeMode)
Deprecated.
A simple
TableSink to emit data as CSV files. |
CsvTableSink(String path,
String fieldDelim,
int numFiles,
FileSystem.WriteMode writeMode,
String[] fieldNames,
DataType[] fieldTypes)
Deprecated.
A simple
TableSink to emit data as CSV files. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.