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 | Method and Description |
---|---|
BulkWriter<RowData> |
FileSystemTableSink.ProjectionBulkFactory.create(FSDataOutputStream out) |
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. |
class |
LocalRecoverableFsDataOutputStream
A
RecoverableFsDataOutputStream for the LocalFileSystem . |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
LocalFileSystem.create(Path filePath,
FileSystem.WriteMode overwrite) |
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
AvroWriterFactory.create(FSDataOutputStream out) |
Modifier and Type | Method and Description |
---|---|
BulkWriter<IN> |
CompressWriterFactory.create(FSDataOutputStream out) |
Constructor and Description |
---|
NoCompressionBulkWriter(FSDataOutputStream outputStream,
Extractor<T> extractor) |
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
RefCountedFileWithStream 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 | Method and Description |
---|---|
BulkWriter<RowData> |
OrcNoHiveBulkWriterFactory.create(FSDataOutputStream out) |
Constructor and Description |
---|
NoHivePhysicalWriterImpl(FSDataOutputStream out,
org.apache.orc.OrcFile.WriterOptions opts) |
Modifier and Type | Method and Description |
---|---|
BulkWriter<T> |
OrcBulkWriterFactory.create(FSDataOutputStream out) |
Constructor and Description |
---|
PhysicalWriterImpl(FSDataOutputStream out,
org.apache.orc.OrcFile.WriterOptions opts) |
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.
|
class |
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 |
BackendWritableBroadcastState.write(FSDataOutputStream out) |
long |
HeapBroadcastState.write(FSDataOutputStream out) |
long[] |
PartitionableListState.write(FSDataOutputStream out) |
Modifier and Type | Class and Description |
---|---|
class |
FileBasedStateOutputStream
A
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
CheckpointStateOutputStream that writes into a file and returns a StreamStateHandle upon closing. |
Modifier and Type | Method and Description |
---|---|
FSDataOutputStream |
FSDataOutputStreamWrapper.getOutput() |
FSDataOutputStream |
RecoverableStreamWrapper.getOutput() |
Modifier and Type | Class and Description |
---|---|
static class |
MemCheckpointStreamFactory.MemoryCheckpointOutputStream
A
CheckpointStateOutputStream that writes into a byte array. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.