Uses of Class
org.apache.flink.core.fs.FSDataOutputStream

Packages that use FSDataOutputStream

Package	Description
org.apache.flink.api.common.io
org.apache.flink.api.common.serialization
org.apache.flink.core.fs
org.apache.flink.core.fs.local

Uses of FSDataOutputStream in org.apache.flink.api.common.io

Fields in org.apache.flink.api.common.io declared as FSDataOutputStream

Modifier and Type	Field	Description
protected FSDataOutputStream	FileOutputFormat.stream	The stream to which the data is written;

Uses of FSDataOutputStream in org.apache.flink.api.common.serialization

Methods in org.apache.flink.api.common.serialization with parameters of type FSDataOutputStream

Modifier and Type	Method	Description
BulkWriter<T>	BulkWriter.Factory.create(FSDataOutputStream out)	Creates a writer that writes to the given stream.

Uses of FSDataOutputStream in org.apache.flink.core.fs

Subclasses of FSDataOutputStream in org.apache.flink.core.fs

Modifier and Type	Class	Description
class	ClosingFSDataOutputStream	This class is a WrappingProxy for FSDataOutputStream that is used to implement a safety net against unclosed streams.
class	CommitterFromPersistRecoverableFsDataOutputStream<RESUME_RECOVERABLE extends RecoverableWriter.ResumeRecoverable>	RecoverableFsDataOutputStream with fixed implementation of CommitterFromPersistRecoverableFsDataOutputStream.closeForCommit() that is based on using CommitterFromPersistRecoverableFsDataOutputStream.persist() to ensure durability and creates the RecoverableFsDataOutputStream.Committer from the corresponding RecoverableWriter.ResumeRecoverable.
class	FSDataOutputStreamWrapper	Simple forwarding wrapper around FSDataInputStream.
class	RecoverableFsDataOutputStream	An output stream to a file system that can be recovered at well defined points.
class	RefCountedBufferingFileStream	A RefCountedFileWithStream that also uses an in-memory buffer for buffering small writes.
class	RefCountedFSOutputStream	A FSDataOutputStream with the RefCounted functionality.

Fields in org.apache.flink.core.fs declared as FSDataOutputStream

Modifier and Type	Field	Description
protected FSDataOutputStream	FSDataOutputStreamWrapper.outputStream

Methods in org.apache.flink.core.fs that return FSDataOutputStream

Modifier and Type	Method	Description
FSDataOutputStream	FileSystem.create(Path f, boolean overwrite)	Deprecated. Use FileSystem.create(Path, WriteMode) instead.
FSDataOutputStream	FileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)	Deprecated. Deprecated because not well supported across types of file systems.
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, boolean overwrite, int bufferSize, short replication, long blockSize)	Deprecated.
FSDataOutputStream	LimitedConnectionsFileSystem.create(Path f, FileSystem.WriteMode overwriteMode)
FSDataOutputStream	SafetyNetWrapperFileSystem.create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)
FSDataOutputStream	SafetyNetWrapperFileSystem.create(Path f, FileSystem.WriteMode overwrite)
FSDataOutputStream	FSDataOutputStreamWrapper.getWrappedDelegate()
FSDataOutputStream	OutputStreamAndPath.stream()

Methods in org.apache.flink.core.fs with parameters of type FSDataOutputStream

Modifier and Type	Method	Description
static ClosingFSDataOutputStream	ClosingFSDataOutputStream.wrapSafe(FSDataOutputStream delegate, SafetyNetCloseableRegistry registry)
static ClosingFSDataOutputStream	ClosingFSDataOutputStream.wrapSafe(FSDataOutputStream delegate, SafetyNetCloseableRegistry registry, String debugInfo)

Constructors in org.apache.flink.core.fs with parameters of type FSDataOutputStream

Constructor	Description
ClosingFSDataOutputStream(FSDataOutputStream delegate, SafetyNetCloseableRegistry registry)
FSDataOutputStreamWrapper(FSDataOutputStream outputStream)
OutputStreamAndPath(FSDataOutputStream stream, Path path)	Creates a OutputStreamAndPath.

Uses of FSDataOutputStream in org.apache.flink.core.fs.local

Subclasses of FSDataOutputStream in org.apache.flink.core.fs.local

Modifier and Type	Class	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.

Methods in org.apache.flink.core.fs.local that return FSDataOutputStream

Modifier and Type	Method	Description
FSDataOutputStream	LocalFileSystem.create(Path filePath, FileSystem.WriteMode overwrite)