| BlockId |
:: DeveloperApi ::
Identifies a particular Block of data, usually associated with a single file.
|
| BlockManagerId |
:: DeveloperApi ::
This class represent an unique identifier for a BlockManager.
|
| BlockManagerMessages |
|
| BlockManagerMessages.BlockManagerHeartbeat |
|
| BlockManagerMessages.BlockManagerHeartbeat$ |
|
| BlockManagerMessages.GetBlockStatus |
|
| BlockManagerMessages.GetBlockStatus$ |
|
| BlockManagerMessages.GetExecutorEndpointRef |
|
| BlockManagerMessages.GetExecutorEndpointRef$ |
|
| BlockManagerMessages.GetLocations |
|
| BlockManagerMessages.GetLocations$ |
|
| BlockManagerMessages.GetLocationsMultipleBlockIds |
|
| BlockManagerMessages.GetLocationsMultipleBlockIds$ |
|
| BlockManagerMessages.GetMatchingBlockIds |
|
| BlockManagerMessages.GetMatchingBlockIds$ |
|
| BlockManagerMessages.GetMemoryStatus$ |
|
| BlockManagerMessages.GetPeers |
|
| BlockManagerMessages.GetPeers$ |
|
| BlockManagerMessages.GetStorageStatus$ |
|
| BlockManagerMessages.HasCachedBlocks |
|
| BlockManagerMessages.HasCachedBlocks$ |
|
| 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.StopBlockManagerMaster$ |
|
| BlockManagerMessages.TriggerThreadDump$ |
Driver to Executor message to trigger a thread dump.
|
| BlockManagerMessages.UpdateBlockInfo |
|
| BlockManagerMessages.UpdateBlockInfo$ |
|
| BlockStatus |
|
| BlockUpdatedInfo |
:: DeveloperApi ::
Stores information about a block status in a block manager.
|
| BroadcastBlockId |
|
| BufferReleasingInputStream |
Helper class that ensures a ManagedBuffer is released upon InputStream.close()
|
| DefaultTopologyMapper |
A TopologyMapper that assumes all nodes are in the same rack
|
| FileBasedTopologyMapper |
A simple file based topology mapper.
|
| RandomBlockReplicationPolicy |
|
| RDDBlockId |
|
| RDDInfo |
|
| ShuffleBlockId |
|
| ShuffleDataBlockId |
|
| ShuffleIndexBlockId |
|
| StorageLevel |
:: DeveloperApi ::
Flags for controlling the storage of an RDD.
|
| StorageStatus |
:: DeveloperApi ::
Storage information for each BlockManager.
|
| StorageStatusListener |
:: DeveloperApi ::
A SparkListener that maintains executor storage status.
|
| StorageUtils |
Helper methods for storage-related objects.
|
| StreamBlockId |
|
| TaskResultBlockId |
|
| TimeTrackingOutputStream |
Intercepts write calls and tracks total time spent writing in order to update shuffle write
metrics.
|
| TopologyMapper |
::DeveloperApi::
TopologyMapper provides topology information for a given host
param: conf SparkConf to get required properties, if needed
|