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

Packages that use FSDataInputStream

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

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

Subclasses of FSDataInputStream in org.apache.flink.api.common.io

Modifier and Type	Class	Description
class	InputStreamFSInputWrapper	This class wraps an InputStream and exposes it as FSDataInputStream.

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

Modifier and Type	Field	Description
protected FSDataInputStream	FileInputFormat.stream	The input stream reading from the input file.

Methods in org.apache.flink.api.common.io that return FSDataInputStream

Modifier and Type	Method	Description
protected FSDataInputStream	FileInputFormat.decorateInputStream(FSDataInputStream inputStream, FileInputSplit fileSplit)	This method allows to wrap/decorate the raw FSDataInputStream for a certain file split, e.g., for decoding.
FSDataInputStream	FileInputFormat.InputSplitOpenThread.waitForCompletion()

Methods in org.apache.flink.api.common.io with parameters of type FSDataInputStream

Modifier and Type	Method	Description
protected FSDataInputStream	FileInputFormat.decorateInputStream(FSDataInputStream inputStream, FileInputSplit fileSplit)	This method allows to wrap/decorate the raw FSDataInputStream for a certain file split, e.g., for decoding.

Constructors in org.apache.flink.api.common.io with parameters of type FSDataInputStream

Constructor	Description
BlockBasedInput(FSDataInputStream in, int blockSize)
BlockBasedInput(FSDataInputStream in, int startPos, long length)

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

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

Modifier and Type	Class	Description
class	ClosingFSDataInputStream	This class is a WrappingProxy for FSDataInputStream that is used to implement a safety net against unclosed streams.
class	FSDataInputStreamWrapper	Simple forwarding wrapper around FSDataInputStream.

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

Modifier and Type	Field	Description
protected FSDataInputStream	FSDataInputStreamWrapper.inputStream

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

Modifier and Type	Method	Description
FSDataInputStream	FSDataInputStreamWrapper.getWrappedDelegate()
abstract FSDataInputStream	FileSystem.open(Path f)	Opens an FSDataInputStream at the indicated Path.
abstract FSDataInputStream	FileSystem.open(Path f, int bufferSize)	Opens an FSDataInputStream at the indicated Path.
FSDataInputStream	LimitedConnectionsFileSystem.open(Path f)
FSDataInputStream	LimitedConnectionsFileSystem.open(Path f, int bufferSize)
FSDataInputStream	SafetyNetWrapperFileSystem.open(Path f)
FSDataInputStream	SafetyNetWrapperFileSystem.open(Path f, int bufferSize)

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

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

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

Constructor	Description
FSDataInputStreamWrapper(FSDataInputStream inputStream)

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

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

Modifier and Type	Class	Description
class	LocalDataInputStream	The LocalDataInputStream class is a wrapper class for a data input stream to the local file system.

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

Modifier and Type	Method	Description
FSDataInputStream	LocalFileSystem.open(Path f)
FSDataInputStream	LocalFileSystem.open(Path f, int bufferSize)