Modifier and Type | Field and Description |
---|---|
protected FSDataOutputStream |
FileOutputFormat.stream
The stream to which the data is written;
|
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
BulkWriter.Factory.create(FSDataOutputStream out)
Creates a writer that writes to the given stream.
|
Modifier and Type | Class and Description |
---|---|
class |
ClosingFSDataOutputStream
This class is a
WrappingProxy for FSDataOutputStream that is used to
implement a safety net against unclosed streams. |
class |
FSDataOutputStreamWrapper
Simple forwarding wrapper around
FSDataInputStream . |
class |
RecoverableFsDataOutputStream
An output stream to a file system that can be recovered at well defined points.
|
Modifier and Type | Field and Description |
---|---|
protected FSDataOutputStream |
FSDataOutputStreamWrapper.outputStream |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
FileSystem.create(Path f,
boolean overwrite)
Deprecated.
Use
FileSystem.create(Path, WriteMode) instead. |
FSDataOutputStream |
LimitedConnectionsFileSystem.create(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize)
Deprecated.
|
FSDataOutputStream |
SafetyNetWrapperFileSystem.create(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize) |
FSDataOutputStream |
FileSystem.create(Path f,
boolean overwrite,
int bufferSize,
short replication,
long blockSize)
Deprecated.
Deprecated because not well supported across types of file systems.
Control the behavior of specific file systems via configurations instead.
|
FSDataOutputStream |
LimitedConnectionsFileSystem.create(Path f,
FileSystem.WriteMode overwriteMode) |
FSDataOutputStream |
SafetyNetWrapperFileSystem.create(Path f,
FileSystem.WriteMode overwrite) |
abstract FSDataOutputStream |
FileSystem.create(Path f,
FileSystem.WriteMode overwriteMode)
Opens an FSDataOutputStream to a new file at the given path.
|
FSDataOutputStream |
FSDataOutputStreamWrapper.getWrappedDelegate() |
FSDataOutputStream |
OutputStreamAndPath.stream() |
Modifier and Type | Method and Description |
---|---|
static ClosingFSDataOutputStream |
ClosingFSDataOutputStream.wrapSafe(FSDataOutputStream delegate,
SafetyNetCloseableRegistry registry) |
static ClosingFSDataOutputStream |
ClosingFSDataOutputStream.wrapSafe(FSDataOutputStream delegate,
SafetyNetCloseableRegistry registry,
String debugInfo) |
Constructor and Description |
---|
ClosingFSDataOutputStream(FSDataOutputStream delegate,
SafetyNetCloseableRegistry registry) |
FSDataOutputStreamWrapper(FSDataOutputStream outputStream) |
OutputStreamAndPath(FSDataOutputStream stream,
Path path)
Creates a OutputStreamAndPath.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalDataOutputStream
The
LocalDataOutputStream class is a wrapper class for a data
output stream to the local file system. |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
LocalFileSystem.create(Path filePath,
FileSystem.WriteMode overwrite) |
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
ParquetWriterFactory.create(FSDataOutputStream stream) |
Modifier and Type | Method and Description |
---|---|
SequenceFileWriter<K,V> |
SequenceFileWriterFactory.create(FSDataOutputStream out) |
Modifier and Type | Class and Description |
---|---|
class |
RefCountedBufferingFileStream
A
RefCountedFile that also uses an in-memory buffer for buffering small writes. |
class |
RefCountedFSOutputStream
A
FSDataOutputStream with the RefCounted functionality. |
Modifier and Type | Class and Description |
---|---|
class |
S3RecoverableFsDataOutputStream
A RecoverableFsDataOutputStream to S3 that is based on a recoverable multipart upload.
|
Modifier and Type | Class and Description |
---|---|
class |
HadoopDataOutputStream
Concrete implementation of the
FSDataOutputStream for Hadoop's input streams. |
Modifier and Type | Class and Description |
---|---|
class |
CheckpointMetadataOutputStream
An output stream for checkpoint metadata.
|
static class |
CheckpointStreamFactory.CheckpointStateOutputStream
A dedicated output stream that produces a
StreamStateHandle when closed. |
class |
DuplicatingCheckpointOutputStream
A CheckpointStateOutputStream that wraps a primary and a secondary CheckpointStateOutputStream and duplicates
all writes into both streams.
|
Modifier and Type | Method and Description |
---|---|
long |
HeapBroadcastState.write(FSDataOutputStream out) |
long |
BackendWritableBroadcastState.write(FSDataOutputStream out) |
Modifier and Type | Class and Description |
---|---|
class |
FileBasedStateOutputStream
A
CheckpointStreamFactory.CheckpointStateOutputStream that writes into a specified file and
returns a FileStateHandle upon closing. |
class |
FsCheckpointMetadataOutputStream
A
CheckpointMetadataOutputStream that writes a specified file and directory, and
returns a FsCompletedCheckpointStorageLocation upon closing. |
static class |
FsCheckpointStreamFactory.FsCheckpointStateOutputStream
A
CheckpointStreamFactory.CheckpointStateOutputStream that writes into a file and
returns a StreamStateHandle upon closing. |
Modifier and Type | Class and Description |
---|---|
static class |
MemCheckpointStreamFactory.MemoryCheckpointOutputStream
A
CheckpointStateOutputStream that writes into a byte array. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.