Hierarchy For Package org.apache.spark.storage

Package Hierarchies:

• All Packages

Class Hierarchy

• Object
  • scala.runtime.AbstractFunction1<T1,R> (implements scala.Function1<T1,R>)
    • org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetExecutorEndpointRef$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetLocations$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetLocationsAndStatus$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetLocationsMultipleBlockIds$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetPeers$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.HasCachedBlocks$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveBlock$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveExecutor$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveRdd$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveShuffle$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction2<T1,T2,R> (implements scala.Function2<T1,T2,R>)
    • org.apache.spark.storage.BlockManagerMessages.BlockLocationsAndStatus$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetBlockStatus$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.GetMatchingBlockIds$ (implements scala.Serializable)
    • org.apache.spark.storage.BlockManagerMessages.RemoveBroadcast$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>)
    • org.apache.spark.storage.BlockManagerMessages.ReplicateBlock$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction4<T1,T2,T3,T4,R> (implements scala.Function4<T1,T2,T3,T4,R>)
    • org.apache.spark.storage.BlockManagerMessages.RegisterBlockManager$ (implements scala.Serializable)
  • scala.runtime.AbstractFunction5<T1,T2,T3,T4,T5,R> (implements scala.Function5<T1,T2,T3,T4,T5,R>)
    • org.apache.spark.storage.BlockManagerMessages.UpdateBlockInfo$ (implements scala.Serializable)
  • io.netty.util.AbstractReferenceCounted (implements io.netty.util.ReferenceCounted)
    • org.apache.spark.network.util.AbstractFileRegion (implements io.netty.channel.FileRegion)
      • org.apache.spark.storage.ReadableChannelFileRegion
  • org.apache.spark.storage.BasicBlockReplicationPolicy (implements org.apache.spark.storage.BlockReplicationPolicy, org.apache.spark.internal.Logging)
  • org.apache.spark.storage.BlockId
    • org.apache.spark.storage.BroadcastBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.RDDBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.ShuffleBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.ShuffleDataBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.ShuffleIndexBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.StreamBlockId (implements scala.Product, scala.Serializable)
    • org.apache.spark.storage.TaskResultBlockId (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerId (implements java.io.Externalizable)
  • org.apache.spark.storage.BlockManagerMessages
  • org.apache.spark.storage.BlockManagerMessages.BlockLocationsAndStatus (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.BlockManagerHeartbeat (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetBlockStatus (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetExecutorEndpointRef (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetLocations (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetLocationsAndStatus (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetLocationsMultipleBlockIds (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetMatchingBlockIds (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetMemoryStatus$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetPeers (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.GetStorageStatus$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.HasCachedBlocks (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.RegisterBlockManager (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.RemoveBlock (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.RemoveBroadcast (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.RemoveExecutor (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.RemoveRdd (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.RemoveShuffle (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.ReplicateBlock (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.StopBlockManagerMaster$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.TriggerThreadDump$ (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockManagerMessages.UpdateBlockInfo (implements org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster, java.io.Externalizable, scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockReplicationUtils
  • org.apache.spark.storage.BlockStatus (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.BlockUpdatedInfo (implements scala.Product, scala.Serializable)
  • org.apache.spark.storage.CountingWritableChannel (implements java.nio.channels.WritableByteChannel)
  • org.apache.spark.storage.DiskBlockData
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.spark.storage.BufferReleasingInputStream
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.spark.storage.TimeTrackingOutputStream
  • org.apache.spark.storage.RandomBlockReplicationPolicy (implements org.apache.spark.storage.BlockReplicationPolicy, org.apache.spark.internal.Logging)
  • org.apache.spark.storage.RDDInfo (implements scala.math.Ordered<A>)
  • org.apache.spark.storage.StorageLevel (implements java.io.Externalizable)
  • org.apache.spark.storage.StorageUtils
  • Throwable (implements java.io.Serializable)
    • Exception
      • org.apache.spark.storage.BlockNotFoundException
      • org.apache.spark.SparkException
        • org.apache.spark.storage.UnrecognizedBlockId
  • org.apache.spark.storage.TopologyMapper
    • org.apache.spark.storage.DefaultTopologyMapper (implements org.apache.spark.internal.Logging)
    • org.apache.spark.storage.FileBasedTopologyMapper (implements org.apache.spark.internal.Logging)

Interface Hierarchy

• org.apache.spark.storage.BlockManagerMessages.ToBlockManagerMaster
• org.apache.spark.storage.BlockManagerMessages.ToBlockManagerSlave
• org.apache.spark.storage.BlockReplicationPolicy