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
org.apache.flink.formats.avro.utils
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 FSDataInputStream in org.apache.flink.api.common.io

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

Modifier and Type	Class and 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 and 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 and 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 and 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 and 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 and Description
class	AbstractMultiFSDataInputStream Abstract base class for wrappers over multiple FSDataInputStream, which gives a contiguous view on all inner streams and makes them look like a single stream, in which we can read, seek, etc.
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 and Description
protected FSDataInputStream	AbstractMultiFSDataInputStream.delegate Inner stream for the currently accessed segment of the virtual global stream.
protected FSDataInputStream	FSDataInputStreamWrapper.inputStream

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

Modifier and Type	Method and Description
protected abstract FSDataInputStream	AbstractMultiFSDataInputStream.getSeekedStreamForOffset(long globalStreamOffset) Delivers a the right stream for the given global stream offset.
FSDataInputStream	FSDataInputStreamWrapper.getWrappedDelegate()
FSDataInputStream	LimitedConnectionsFileSystem.open(Path f)
FSDataInputStream	SafetyNetWrapperFileSystem.open(Path f)
abstract FSDataInputStream	FileSystem.open(Path f) Opens an FSDataInputStream at the indicated Path.
FSDataInputStream	LimitedConnectionsFileSystem.open(Path f, int bufferSize)
FSDataInputStream	SafetyNetWrapperFileSystem.open(Path f, int bufferSize)
abstract FSDataInputStream	FileSystem.open(Path f, int bufferSize) Opens an FSDataInputStream at the indicated Path.

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

Modifier and Type	Method and 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 and 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 and 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 and Description
FSDataInputStream	LocalFileSystem.open(Path f)
FSDataInputStream	LocalFileSystem.open(Path f, int bufferSize)

Uses of FSDataInputStream in org.apache.flink.formats.avro.utils

Constructors in org.apache.flink.formats.avro.utils with parameters of type FSDataInputStream

Constructor and Description
FSDataInputStreamWrapper(FSDataInputStream stream, long len)

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

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

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

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

Methods in org.apache.flink.runtime.state that return FSDataInputStream

Modifier and Type	Method and Description
FSDataInputStream	KeyGroupsStateHandle.openInputStream()
FSDataInputStream	PlaceholderStreamStateHandle.openInputStream()
FSDataInputStream	OperatorStateHandle.openInputStream() Returns an input stream to read the operator state information.
FSDataInputStream	RetrievableStreamStateHandle.openInputStream()
FSDataInputStream	StreamStateHandle.openInputStream() Returns an FSDataInputStream that can be used to read back the data that was previously written to the stream.
FSDataInputStream	OperatorStreamStateHandle.openInputStream()

Constructors in org.apache.flink.runtime.state with parameters of type FSDataInputStream

Constructor and Description
BoundedInputStream(FSDataInputStream delegate, long endOffsetExclusive)

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

Methods in org.apache.flink.runtime.state.filesystem that return FSDataInputStream

Modifier and Type	Method and Description
FSDataInputStream	FileStateHandle.openInputStream()

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

Methods in org.apache.flink.runtime.state.memory that return FSDataInputStream

Modifier and Type	Method and Description
FSDataInputStream	ByteStreamStateHandle.openInputStream()