Hierarchy For Package org.apache.flink.core.fs

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.util.AbstractAutoCloseableRegistry<R,C,T,E> (implements java.lang.AutoCloseable)
    • org.apache.flink.core.fs.AutoCloseableRegistry
    • org.apache.flink.core.fs.CloseableRegistry (implements java.io.Closeable)
    • org.apache.flink.core.fs.SafetyNetCloseableRegistry
  • org.apache.flink.core.fs.BackPressuringExecutor (implements java.util.concurrent.Executor)
  • org.apache.flink.core.fs.ConnectionLimitingFactory (implements org.apache.flink.core.fs.FileSystemFactory)
  • org.apache.flink.core.fs.EntropyInjector
  • org.apache.flink.core.fs.FileSystem
    • org.apache.flink.core.fs.LimitedConnectionsFileSystem
    • org.apache.flink.core.fs.SafetyNetWrapperFileSystem (implements org.apache.flink.util.WrappingProxy<T>)
  • org.apache.flink.core.fs.FileSystemSafetyNet
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.flink.core.fs.FSDataInputStream
      • org.apache.flink.core.fs.FSDataInputStreamWrapper (implements org.apache.flink.util.WrappingProxy<T>)
        • org.apache.flink.core.fs.ClosingFSDataInputStream (implements org.apache.flink.core.fs.WrappingProxyCloseable<T>)
  • org.apache.flink.core.fs.LimitedConnectionsFileSystem.ConnectionLimitingSettings
  • org.apache.flink.core.io.LocatableInputSplit (implements org.apache.flink.core.io.InputSplit, java.io.Serializable)
    • org.apache.flink.core.fs.FileInputSplit
  • org.apache.flink.core.fs.OffsetAwareOutputStream (implements java.io.Closeable)
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.flink.core.fs.FSDataOutputStream
      • org.apache.flink.core.fs.FSDataOutputStreamWrapper (implements org.apache.flink.util.WrappingProxy<T>)
        • org.apache.flink.core.fs.ClosingFSDataOutputStream (implements org.apache.flink.core.fs.WrappingProxyCloseable<T>)
      • org.apache.flink.core.fs.RecoverableFsDataOutputStream
        • org.apache.flink.core.fs.CommitterFromPersistRecoverableFsDataOutputStream<RESUME_RECOVERABLE>
      • org.apache.flink.core.fs.RefCountedFSOutputStream (implements org.apache.flink.util.RefCounted)
        • org.apache.flink.core.fs.RefCountedBufferingFileStream
  • org.apache.flink.core.fs.OutputStreamAndPath
  • org.apache.flink.core.fs.Path (implements org.apache.flink.core.io.IOReadableWritable, java.io.Serializable)
  • org.apache.flink.core.fs.PluginFileSystemFactory (implements org.apache.flink.core.fs.FileSystemFactory)
  • org.apache.flink.core.fs.RefCountedFile (implements org.apache.flink.util.RefCounted)
    • org.apache.flink.core.fs.RefCountedFileWithStream
  • org.apache.flink.core.fs.RefCountedTmpFileCreator (implements org.apache.flink.util.function.FunctionWithException<T,R,E>)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.io.IOException
        • org.apache.flink.core.fs.LimitedConnectionsFileSystem.StreamTimeoutException
        • org.apache.flink.core.fs.UnsupportedFileSystemSchemeException

Interface Hierarchy

• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.flink.core.fs.WrappingProxyCloseable<T> (also extends org.apache.flink.util.WrappingProxy<T>)
• java.lang.Comparable<T>
  • org.apache.flink.core.fs.BlockLocation
• org.apache.flink.core.fs.DuplicatingFileSystem
• org.apache.flink.core.fs.DuplicatingFileSystem.CopyRequest
• org.apache.flink.core.fs.EntropyInjectingFileSystem
• org.apache.flink.core.fs.FileStatus
  • org.apache.flink.core.fs.LocatedFileStatus
• org.apache.flink.core.plugin.Plugin
  • org.apache.flink.core.fs.FileSystemFactory
• org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer
• org.apache.flink.core.fs.RecoverableWriter
• org.apache.flink.core.fs.RecoverableWriter.CommitRecoverable
  • org.apache.flink.core.fs.RecoverableWriter.ResumeRecoverable
• org.apache.flink.util.WrappingProxy<T>
  • org.apache.flink.core.fs.WrappingProxyCloseable<T> (also extends java.io.Closeable)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.core.fs.FileSystem.WriteMode
    • org.apache.flink.core.fs.FileSystemKind