org.apache.spark.storage

Interfaces

• BlockData
• BlockManagerMessages.ToBlockManagerMaster
• BlockManagerMessages.ToBlockManagerMasterStorageEndpoint
• BlockReplicationPolicy

Classes

• BasicBlockReplicationPolicy
• BlockId
• BlockInfoWrapper
• BlockManagerId
• BlockManagerMessages
• BlockManagerMessages.BlockLocationsAndStatus
• BlockManagerMessages.BlockLocationsAndStatus$
• BlockManagerMessages.BlockManagerHeartbeat
• BlockManagerMessages.BlockManagerHeartbeat$
• BlockManagerMessages.DecommissionBlockManager$
• BlockManagerMessages.DecommissionBlockManagers
• BlockManagerMessages.DecommissionBlockManagers$
• BlockManagerMessages.GetBlockStatus
• BlockManagerMessages.GetBlockStatus$
• BlockManagerMessages.GetExecutorEndpointRef
• BlockManagerMessages.GetExecutorEndpointRef$
• BlockManagerMessages.GetLocations
• BlockManagerMessages.GetLocations$
• BlockManagerMessages.GetLocationsAndStatus
• BlockManagerMessages.GetLocationsAndStatus$
• BlockManagerMessages.GetLocationsMultipleBlockIds
• BlockManagerMessages.GetLocationsMultipleBlockIds$
• BlockManagerMessages.GetMatchingBlockIds
• BlockManagerMessages.GetMatchingBlockIds$
• BlockManagerMessages.GetMemoryStatus$
• BlockManagerMessages.GetPeers
• BlockManagerMessages.GetPeers$
• BlockManagerMessages.GetReplicateInfoForRDDBlocks
• BlockManagerMessages.GetReplicateInfoForRDDBlocks$
• BlockManagerMessages.GetShufflePushMergerLocations
• BlockManagerMessages.GetShufflePushMergerLocations$
• BlockManagerMessages.GetStorageStatus$
• BlockManagerMessages.IsExecutorAlive
• BlockManagerMessages.IsExecutorAlive$
• BlockManagerMessages.RegisterBlockManager
• BlockManagerMessages.RegisterBlockManager$
• BlockManagerMessages.RemoveBlock
• BlockManagerMessages.RemoveBlock$
• BlockManagerMessages.RemoveBroadcast
• BlockManagerMessages.RemoveBroadcast$
• BlockManagerMessages.RemoveExecutor
• BlockManagerMessages.RemoveExecutor$
• BlockManagerMessages.RemoveRdd
• BlockManagerMessages.RemoveRdd$
• BlockManagerMessages.RemoveShuffle
• BlockManagerMessages.RemoveShuffle$
• BlockManagerMessages.RemoveShufflePushMergerLocation
• BlockManagerMessages.RemoveShufflePushMergerLocation$
• BlockManagerMessages.ReplicateBlock
• BlockManagerMessages.ReplicateBlock$
• BlockManagerMessages.StopBlockManagerMaster$
• BlockManagerMessages.TriggerThreadDump$
• BlockManagerMessages.UpdateBlockInfo
• BlockManagerMessages.UpdateBlockInfo$
• BlockReplicationUtils
• BlockStatus
• BlockUpdatedInfo
• BroadcastBlockId
• BufferReleasingInputStream
• CountingWritableChannel
• DefaultTopologyMapper
• DiskBlockData
• FileBasedTopologyMapper
• PushBasedFetchHelper
• RandomBlockReplicationPolicy
• RDDBlockId
• RDDInfo
• ReadableChannelFileRegion
• ShuffleBlockBatchId
• ShuffleBlockChunkId
• ShuffleBlockId
• ShuffleChecksumBlockId
• ShuffleDataBlockId
• ShuffleFetchCompletionListener
• ShuffleIndexBlockId
• ShuffleMergedBlockId
• ShuffleMergedDataBlockId
• ShuffleMergedIndexBlockId
• ShuffleMergedMetaBlockId
• ShufflePushBlockId
• StorageLevel
• StorageUtils
• StreamBlockId
• TaskResultBlockId
• TimeTrackingOutputStream
• TopologyMapper

Exceptions

• BlockNotFoundException
• UnrecognizedBlockId