Class Hierarchy
- java.lang.Object
- org.apache.flink.core.fs.FileSystem (implements org.apache.flink.core.fs.IFileSystem)
- org.apache.flink.runtime.fs.hdfs.HadoopFileSystem
- org.apache.flink.runtime.fs.hdfs.HadoopBlockLocation (implements org.apache.flink.core.fs.BlockLocation)
- org.apache.flink.runtime.fs.hdfs.HadoopFileStatus (implements org.apache.flink.core.fs.FileStatus)
- org.apache.flink.runtime.fs.hdfs.LocatedHadoopFileStatus (implements org.apache.flink.core.fs.LocatedFileStatus)
- org.apache.flink.runtime.fs.hdfs.HadoopFsFactory (implements org.apache.flink.core.fs.FileSystemFactory)
- org.apache.flink.runtime.fs.hdfs.HadoopFsRecoverable (implements org.apache.flink.core.fs.RecoverableWriter.CommitRecoverable, org.apache.flink.core.fs.RecoverableWriter.ResumeRecoverable)
- org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriter (implements org.apache.flink.core.fs.RecoverableWriter)
- java.io.InputStream (implements java.io.Closeable)
- org.apache.flink.core.fs.FSDataInputStream
- org.apache.flink.runtime.fs.hdfs.HadoopDataInputStream (implements org.apache.flink.core.fs.ByteBufferReadable)
- org.apache.flink.core.fs.FSDataInputStream
- java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
- org.apache.flink.core.fs.FSDataOutputStream
- org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream
- org.apache.flink.core.fs.RecoverableFsDataOutputStream
- org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream<RESUME_RECOVERABLE>
- org.apache.flink.runtime.fs.hdfs.BaseHadoopFsRecoverableFsDataOutputStream
- org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream<RESUME_RECOVERABLE>
- org.apache.flink.core.fs.FSDataOutputStream
- org.apache.flink.core.fs.FileSystem (implements org.apache.flink.core.fs.IFileSystem)