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 FSDataOutputStreamFileOutputFormat. streamThe 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 classClosingFSDataOutputStreamThis class is aWrappingProxyforFSDataOutputStreamthat is used to implement a safety net against unclosed streams.classFSDataOutputStreamWrapperSimple forwarding wrapper aroundFSDataInputStream.classRecoverableFsDataOutputStreamAn output stream to a file system that can be recovered at well defined points.classRefCountedBufferingFileStreamARefCountedFileWithStreamthat also uses an in-memory buffer for buffering small writes.classRefCountedFSOutputStreamAFSDataOutputStreamwith theRefCountedfunctionality.Fields in org.apache.flink.core.fs declared as FSDataOutputStream Modifier and Type Field Description protected FSDataOutputStreamFSDataOutputStreamWrapper. outputStreamMethods in org.apache.flink.core.fs that return FSDataOutputStream Modifier and Type Method Description FSDataOutputStreamFileSystem. create(Path f, boolean overwrite)Deprecated.UseFileSystem.create(Path, WriteMode)instead.FSDataOutputStreamFileSystem. create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)Deprecated.Deprecated because not well supported across types of file systems.abstract FSDataOutputStreamFileSystem. create(Path f, FileSystem.WriteMode overwriteMode)Opens an FSDataOutputStream to a new file at the given path.FSDataOutputStreamLimitedConnectionsFileSystem. create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)Deprecated.FSDataOutputStreamLimitedConnectionsFileSystem. create(Path f, FileSystem.WriteMode overwriteMode)FSDataOutputStreamSafetyNetWrapperFileSystem. create(Path f, boolean overwrite, int bufferSize, short replication, long blockSize)FSDataOutputStreamSafetyNetWrapperFileSystem. create(Path f, FileSystem.WriteMode overwrite)FSDataOutputStreamFSDataOutputStreamWrapper. getWrappedDelegate()FSDataOutputStreamOutputStreamAndPath. stream()Methods in org.apache.flink.core.fs with parameters of type FSDataOutputStream Modifier and Type Method Description static ClosingFSDataOutputStreamClosingFSDataOutputStream. wrapSafe(FSDataOutputStream delegate, SafetyNetCloseableRegistry registry)static ClosingFSDataOutputStreamClosingFSDataOutputStream. 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 classLocalDataOutputStreamTheLocalDataOutputStreamclass is a wrapper class for a data output stream to the local file system.classLocalRecoverableFsDataOutputStreamARecoverableFsDataOutputStreamfor theLocalFileSystem.Methods in org.apache.flink.core.fs.local that return FSDataOutputStream Modifier and Type Method Description FSDataOutputStreamLocalFileSystem. create(Path filePath, FileSystem.WriteMode overwrite)
-