Skip to content
The Internals of Spark Core
CoalescedRDD
Initializing search
spark-internals
Spark Core
Features
Internals
Shared Variables
Monitoring
Tools
RDD
Demos
Web UIs
The Internals of Spark Core
spark-internals
Spark Core
Features
Features
Barrier Execution Mode
Barrier Scheduling
Barrier Execution Mode
BarrierCoordinator
BarrierCoordinatorMessage
BarrierJobAllocationFailed
BarrierJobSlotsNumberCheckFailed
BarrierTaskContext
ContextBarrierState
RDDBarrier
RequestMethod
RequestToSync
Configuration Properties
Developer API
Logging
Plugin Framework
Plugin Framework
DriverPlugin
DriverPluginContainer
ExecutorPlugin
ExecutorPluginContainer
PluginContainer
PluginContextImpl
SparkPlugin
Push-Based Shuffle
Stage-Level Scheduling
Stage-Level Scheduling
ExecutorResourceInfo
ExecutorResourceRequest
ExecutorResourceRequests
ResourceAllocator
ResourceID
ResourceProfile
ResourceProfileBuilder
ResourceProfileManager
ResourceUtils
SparkListenerResourceProfileAdded
TaskResourceProfile
TaskResourceRequest
TaskResourceRequests
Internals
Internals
Overview
SparkEnv
SparkConf
SparkContext
SparkCoreErrors
Local Properties
Inside Creating SparkContext
SparkFiles
Spark Properties
Executor
Executor
CoarseGrainedExecutorBackend
Executor
ExecutorBackend
ExecutorLogUrlHandler
ExecutorMetrics
ExecutorMetricsPoller
ExecutorMetricsSource
ExecutorMetricType
ExecutorSource
ShuffleReadMetrics
ShuffleWriteMetrics
TaskMetrics
TaskRunner
External Shuffle Service
External Shuffle Service
Configuration Properties
ExternalShuffleService
ExternalBlockHandler
ExternalShuffleBlockResolver
ExecutorShuffleInfo
MapOutputTracker
MapOutputTracker
MapOutputStatistics
MapOutputTracker
MapOutputTrackerMaster
MapOutputTrackerMasterEndpoint
MapOutputTrackerWorker
ShuffleStatus
Shuffle System
Shuffle System
BaseShuffleHandle
BlockStoreShuffleReader
BypassMergeSortShuffleHandle
BypassMergeSortShuffleWriter
DownloadFileManager
FetchFailedException
IndexShuffleBlockResolver
MigratableResolver
SerializedShuffleHandle
ShuffleBlockPusher
ShuffleBlockResolver
ShuffleExternalSorter
ShuffleHandle
ShuffleInMemorySorter
ShuffleManager
ShuffleReader
ShuffleWriteMetricsReporter
ShuffleWriteProcessor
ShuffleWriter
SortShuffleManager
SortShuffleWriter
UnsafeShuffleWriter
Spillable Collections
Spillable Collections
Spillable
ExternalAppendOnlyMap
ExternalSorter
ShuffleDataIOs
ShuffleDataIOs
ShuffleDataIO
LocalDiskShuffleDataIO
ShuffleDriverComponents
ShuffleExecutorComponents
ShuffleMapOutputWriter
LocalDiskShuffleMapOutputWriter
ExecutorDiskUtils
SingleSpillShuffleMapOutputWriter
LocalDiskShuffleExecutorComponents
LocalDiskSingleSpillMapOutputWriter
ShuffleDataIOUtils
Dynamic Resource Allocation
Dynamic Resource Allocation
Configuration Properties
ExecutorAllocationManager
ExecutorMonitor
Tracker
ExecutorAllocationClient
ExecutorAllocationManagerSource
ExecutorAllocationListener
Core
Core
ContextCleaner
CleanerListener
BlockFetchingListener
RetryingBlockFetcher
BlockFetchStarter
KVStore
InMemoryStore
LevelDB
OutputCommitCoordinator
Scheduler
Scheduler
ActiveJob
BlacklistTracker
CoarseGrainedSchedulerBackend
DAGScheduler
DAGSchedulerEvent
DAGSchedulerEventProcessLoop
DAGSchedulerSource
DriverEndpoint
ExecutorData
ExternalClusterManager
FairSchedulableBuilder
FIFOSchedulableBuilder
JobListener
JobWaiter
LiveListenerBus
MapStatuses
MapStatuses
MapStatus
CompressedMapStatus
HighlyCompressedMapStatus
Pool
ResultStage
ResultTask
Schedulable
SchedulableBuilder
SchedulerBackend
SchedulerBackendUtils
SchedulingMode
ShuffleMapStage
ShuffleMapTask
Stage
StageInfo
TaskScheduler
TaskSchedulerImpl
Task
TaskContext
TaskContextImpl
TaskDescription
TaskInfo
TaskLocation
TaskResult
TaskResultGetter
TaskSet
TaskSetBlacklist
TaskSetManager
RPC
RPC
RpcEnv
NettyRpcEnv
RpcEnvConfig
RpcEndpoint
RpcEndpointRef
RpcAddress
RpcEndpointAddress
RpcEnvFactory
NettyRpcEnvFactory
RpcEnvFileServer
spark-rpc-netty
RpcUtils
Memory
Memory
ExecutionMemoryPool
MemoryAllocator
MemoryConsumer
MemoryManager
MemoryPool
StorageMemoryPool
TaskMemoryManager
UnifiedMemoryManager
UnsafeExternalSorter
UnsafeInMemorySorter
UnsafeSorterSpillReader
UnsafeSorterSpillWriter
Storage
Storage
BlockData
BlockDataManager
BlockEvictionHandler
BlockId
BlockInfo
BlockInfoManager
BlockManager
BlockManagerDecommissioner
BlockManagerStorageEndpoint
BlockManagerId
BlockManagerInfo
BlockManagerMaster
BlockManagerMasterEndpoint
BlockManagerMasterHeartbeatEndpoint
BlockManagerSlaveEndpoint
BlockManagerSource
BlockReplicationPolicy
BlockStoreClient
BlockStoreUpdater
BlockTransferService
ByteBufferBlockStoreUpdater
DiskBlockObjectWriter
DiskStore
DiskBlockManager
ExternalBlockStoreClient
FallbackStorage
MemoryStore
ShuffleMetricsSource
NettyBlockTransferService
NettyBlockRpcServer
OneForOneBlockFetcher
RandomBlockReplicationPolicy
RDDInfo
ShuffleBlockFetcherIterator
ShuffleFetchCompletionListener
ShuffleMigrationRunnable
StorageLevel
StorageStatus
StorageUtils
TempFileBasedBlockStoreUpdater
Serialization
Serialization
DeserializationStream
JavaSerializerInstance
KryoSerializer
KryoSerializerInstance
SerializationStream
Serializer
SerializerInstance
SerializerManager
Speculative Execution of Tasks
Deployment Architecture
Deployment Architecture
Architecture
Driver
Master
Workers
Writers and Committers
Writers and Committers
SparkHadoopWriter
HadoopWriteConfigUtil
FileCommitProtocol
HadoopMapReduceCommitProtocol
HadoopMapRedCommitProtocol
HadoopMapReduceWriteConfigUtil
HadoopMapRedWriteConfigUtil
Status
Status
AppStatusListener
AppStatusSource
AppStatusStore
ElementTrackingStore
LiveEntity
Network
Network
SparkTransportConf
TransportClientFactory
TransportContext
TransportConf
Misc
Misc
BytesToBytesMap
ExecutorDeadException
HeartbeatReceiver
InterruptibleIterator
PartitionEvaluatorFactory
PartitionEvaluator
Utils
Spark Tips and Tricks
Spark Tips and Tricks
Spark Tips and Tricks
Access private members in Scala in Spark shell
Task not serializable Exception
Running Spark Applications on Windows
Spark Local
Spark Local
LocalSchedulerBackend
LocalEndpoint
LauncherBackend
Shared Variables
Shared Variables
Accumulators
Accumulators
AccumulatorV2
AccumulatorContext
InternalAccumulator
AccumulatorSource
AccumulableInfo
Broadcast Variables
Broadcast Variables
Broadcast
BroadcastFactory
BroadcastManager
TorrentBroadcast
TorrentBroadcastFactory
Monitoring
Monitoring
ConsoleProgressBar
Debugging Spark
DriverLogger
ListenerBus
SparkListener
SparkListenerBus
SparkListenerEvents
SparkListenerEvents
SparkListenerEvent
SparkListenerTaskEnd
SparkListenerInterface
SparkStatusTracker
SpillListener
StatsReportListener
TaskCompletionListener
TaskFailureListener
Spark History Server
Spark History Server
Configuration Properties
HistoryServer
HistoryAppStatusStore
HistoryServerDiskManager
EventLoggingListener
SQLHistoryListener
ApplicationHistoryProvider
FsHistoryProvider
HistoryServerArguments
ApplicationCacheOperations
ApplicationCache
ReplayListenerBus
EventLogFileWriter
JsonProtocol
Status REST API
Status REST API
ApiRootResource
ApplicationListResource
OneApplicationResource
StagesResource
OneApplicationAttemptResource
AbstractApplicationResource
BaseAppResource
ApiRequestContext
UIRoot
UIRootFromServletContext
Metrics
Metrics
Configuration Properties
MetricsSystem
MetricsConfig
Source
Sink
Sources
Sources
JvmSource
Sinks
Sinks
MetricsServlet
PrometheusServlet
Tools
Tools
AbstractLauncher
Main
pyspark
spark-submit
spark-submit
SparkSubmit
SparkSubmitArguments
SparkSubmitCommandBuilder.OptionParser
SparkSubmitCommandBuilder
SparkSubmitOperation
SparkSubmitOptionParser
SparkSubmitUtils
SparkApplication
JavaMainApplication
spark-shell
spark-class
SparkLauncher
SparkClassCommandBuilder
DependencyUtils
AbstractCommandBuilder
RDD
RDD
CoalescedRDD
CheckpointRDD
CoGroupedRDD
Dependency
HadoopRDD
LocalCheckpointRDD
MapPartitionsRDD
NarrowDependency
NewHadoopRDD
ParallelCollectionRDD
RDD
Resilient Distributed Dataset
RDDOperationScope
ReliableCheckpointRDD
ShuffleDependency
ShuffledRDD
Operators
Operators
Operators
Transformations
OrderedRDDFunctions
PairRDDFunctions
AsyncRDDActions
Actions
Partitioners
Partitioners
Partitioner
HashPartitioner
RangePartitioner
RDD Lineage
Caching and Persistence
Partitions and Partitioning
Partition
RDD Checkpointing
RDDCheckpointData
LocalRDDCheckpointData
MapPartitionsWithEvaluatorRDD
ReliableRDDCheckpointData
ZippedPartitionsWithEvaluatorRDD
Aggregator
Demos
Demos
DiskBlockManager and Block Data
Exercises
Exercises
One-liners using PairRDDFunctions
Learning Jobs and Partitions Using take Action
Spark Standalone - Using ZooKeeper for High-Availability of Master
Spark's Hello World using Spark shell and Scala
WordCount using Spark shell
Your first complete Spark application (using Scala and sbt)
Using Spark SQL to update data in Hive using ORC files
Developing Custom SparkListener to monitor DAGScheduler in Scala
Working with Datasets from JDBC Data Sources (and PostgreSQL)
Causing Stage to Fail
Web UIs
Web UIs
Configuration Properties
WebUI
WebUIPage
WebUITab
Spark UI
Spark UI
SparkUI
SparkUITab
Environment
Environment
EnvironmentTab
EnvironmentPage
Executors
Executors
ExecutorsTab
ExecutorsPage
ExecutorThreadDumpPage
Jobs
Jobs
JobsTab
AllJobsPage
JobPage
Stages
Stages
StagesTab
AllStagesPage
StagePage
PoolPage
Storage
Storage
StorageTab
StoragePage
RDDPage
PrometheusResource
UIUtils
JettyUtils
Spark Core
RDD
CoalescedRDD
¶
CoalescedRDD
is...FIXME
Back to top