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

Packages that use FSDataOutputStream

Package	Description
org.apache.flink.api.common.io
org.apache.flink.core.fs
org.apache.flink.core.fs.local
org.apache.flink.runtime.fs.hdfs
org.apache.flink.runtime.state
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.memory

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 and Description
protected FSDataOutputStream	FileOutputFormat.stream The stream to which the data is written;

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

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

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.

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

Modifier and Type	Field and Description
protected FSDataOutputStream	FSDataOutputStreamWrapper.outputStream

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

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()

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

Modifier and Type	Method and 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 and Description
ClosingFSDataOutputStream(FSDataOutputStream delegate, SafetyNetCloseableRegistry registry)
FSDataOutputStreamWrapper(FSDataOutputStream outputStream)

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

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

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.

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

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

Uses of FSDataOutputStream in org.apache.flink.runtime.fs.hdfs

Subclasses of FSDataOutputStream in org.apache.flink.runtime.fs.hdfs

Modifier and Type	Class and Description
class	HadoopDataOutputStream Concrete implementation of the FSDataOutputStream for Hadoop's input streams.

Uses of FSDataOutputStream in org.apache.flink.runtime.state

Subclasses of FSDataOutputStream in org.apache.flink.runtime.state

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

Methods in org.apache.flink.runtime.state with parameters of type FSDataOutputStream

Modifier and Type	Method and Description
long	HeapBroadcastState.write(FSDataOutputStream out)
long	BackendWritableBroadcastState.write(FSDataOutputStream out)

Uses of FSDataOutputStream in org.apache.flink.runtime.state.filesystem

Subclasses of FSDataOutputStream in org.apache.flink.runtime.state.filesystem

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.

Uses of FSDataOutputStream in org.apache.flink.runtime.state.memory

Subclasses of FSDataOutputStream in org.apache.flink.runtime.state.memory

Modifier and Type	Class and Description
static class	MemCheckpointStreamFactory.MemoryCheckpointOutputStream A CheckpointStateOutputStream that writes into a byte array.