All Classes

Class Summary

Class	Description
BaseHadoopFsRecoverableFsDataOutputStream	Base class for ABFS and Hadoop recoverable stream.
HadoopBlockLocation	Implementation of the BlockLocation interface for the Hadoop Distributed File System.
HadoopConfigLoader	This class lazily loads hadoop configuration from resettable Flink's configuration.
HadoopDataInputStream	Concrete implementation of the FSDataInputStream for Hadoop's input streams.
HadoopDataOutputStream	Concrete implementation of the FSDataOutputStream for Hadoop's input streams.
HadoopFileStatus	Concrete implementation of the FileStatus interface for the Hadoop Distributed File System.
HadoopFileSystem	A FileSystem that wraps an Hadoop File System.
HadoopFsFactory	A file system factory for Hadoop-based file systems.
HadoopFsRecoverable	An implementation of the resume and commit descriptor objects for Hadoop's/AzureBlob file system abstraction.
HadoopRecoverableWriter	An implementation of the RecoverableWriter for Hadoop's file system abstraction.
HadoopUtils	Utility class for working with Hadoop-related classes.
LocatedHadoopFileStatus	Concrete implementation of the LocatedFileStatus interface for the Hadoop Distributed File System.