Skip to content
Apache Spark 源码解读
ShuffleMigrationRunnable
Initializing search
spark-internals
Home
Internals
Shared Variables
Spark Standalone
Monitoring
Tools
RDD
Demos
Web UIs
Apache Spark 源码解读
spark-internals
Home
Internals
Internals
Overview
SparkEnv
SparkConf
SparkContext
Local Properties
Inside Creating SparkContext
SparkStatusTracker
SparkFiles
Configuration Properties
Spark Properties
External Shuffle Service
External Shuffle Service
Configuration Properties
ExternalShuffleService
ExternalBlockHandler
ExternalShuffleBlockResolver
ExecutorShuffleInfo
MapOutputTracker
MapOutputTracker
MapOutputTracker
MapOutputTrackerMaster
MapOutputTrackerMasterEndpoint
MapOutputTrackerWorker
ShuffleStatus
Shuffle System
Shuffle System
BaseShuffleHandle
BlockStoreShuffleReader
BypassMergeSortShuffleHandle
BypassMergeSortShuffleWriter
DownloadFileManager
FetchFailedException
IndexShuffleBlockResolver
MigratableResolver
SerializedShuffleHandle
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
Network
Network
TransportContext
MessageHandler
TransportRequestHandler
TransportConf
SparkTransportConf
TransportClientFactory
TransportServer
RpcHandler
StreamManager
OneForOneStreamManager
ManagedBuffer
RpcResponseCallback
Core
Core
ContextCleaner
CleanerListener
BlockFetchingListener
RetryingBlockFetcher
BlockFetchStarter
KVStore
InMemoryStore
LevelDB
OutputCommitCoordinator
Scheduler
Scheduler
DAGScheduler
Stage
ResultStage
ShuffleMapStage
BlacklistTracker
StageInfo
JobListener
JobWaiter
TaskScheduler
TaskSchedulerImpl
SchedulerBackend
CoarseGrainedSchedulerBackend
DriverEndpoint
SchedulerBackendUtils
Task
ShuffleMapTask
ResultTask
TaskSet
TaskSetManager
ActiveJob
SchedulableBuilder
FIFOSchedulableBuilder
FairSchedulableBuilder
Schedulable
Pool
SchedulingMode
TaskInfo
MapStatuses
MapStatuses
MapStatus
CompressedMapStatus
HighlyCompressedMapStatus
TaskDescription
TaskResultGetter
TaskContext
BarrierTaskContext
TaskContextImpl
TaskResult
TaskSetBlacklist
TaskLocation
ExternalClusterManager
LiveListenerBus
DAGSchedulerEvent
DAGSchedulerEventProcessLoop
DAGSchedulerSource
ExecutorData
RPC
RPC
RpcEnv
NettyRpcEnv
NettyStreamManager
RpcEnvConfig
RpcEndpoint
RpcEndpointRef
RpcAddress
RpcEndpointAddress
RpcEnvFactory
NettyRpcEnvFactory
RpcEnvFileServer
spark-rpc-netty
RpcUtils
Memory
Memory
BytesToBytesMap
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
Executor
Executor
Executor
TaskRunner
ExecutorSource
ExecutorBackend
CoarseGrainedExecutorBackend
TaskMetrics
ShuffleWriteMetrics
ShuffleReadMetrics
ExecutorLogUrlHandler
ExecutorMetricsPoller
Barrier Execution Mode
Barrier Execution Mode
barrier-execution-mode
RDDBarrier
Speculative Execution of Tasks
Deployment Architecture
Deployment Architecture
Architecture
Driver
Master
Workers
Internal IO
Internal IO
SparkHadoopWriter
HadoopWriteConfigUtil
FileCommitProtocol
HadoopMapReduceCommitProtocol
HadoopMapRedCommitProtocol
HadoopMapReduceWriteConfigUtil
HadoopMapRedWriteConfigUtil
Stage-Level Scheduling
Stage-Level Scheduling
ResourceProfile
ResourceProfileBuilder
Status
Status
AppStatusListener
AppStatusSource
AppStatusStore
ElementTrackingStore
LiveEntity
Misc
Misc
Deployment Environments
Building from Sources
InterruptibleIterator
Deploy Mode
HeartbeatReceiver
Data Locality
CompressionCodec
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
Spark Standalone
Spark Standalone
Configuration Properties
ClientApp
ClientEndpoint
CreateSubmissionRequest
ExecutorRunner
LocalSparkCluster
Master
RestSubmissionClient
RestSubmissionServer
StandaloneAppClient
StandaloneAppClientListener
StandaloneRestServer
StandaloneSchedulerBackend
Worker
Monitoring
Monitoring
Logging
ListenerBus
SparkListener
SparkListenerBus
SparkListenerEvents
SparkListenerEvents
SparkListenerEvent
SparkListenerTaskEnd
SparkListenerInterface
SpillListener
StatsReportListener
AsyncEventQueue
spark-debugging
ConsoleProgressBar
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
Plugin Framework
Plugin Framework
DriverPlugin
DriverPluginContainer
ExecutorPlugin
ExecutorPluginContainer
PluginContainer
PluginContextImpl
SparkPlugin
Dropwizard Metrics
Dropwizard Metrics
Configuration Properties
MetricsSystem
MetricsConfig
Source
Sink
Sources
Sources
JvmSource
Sinks
Sinks
MetricsServlet
Tools
Tools
spark-submit
spark-submit
spark-submit
SparkSubmit
SparkSubmitOperation
SparkSubmitUtils
SparkApplication
JavaMainApplication
spark-shell
spark-class
SparkLauncher
Internals
Internals
SparkSubmitArguments
DependencyUtils
SparkSubmitOptionParser
SparkSubmitCommandBuilder
Main
AbstractCommandBuilder
RDD
RDD
CoalescedRDD
CheckpointRDD
CoGroupedRDD
HadoopRDD
LocalCheckpointRDD
MapPartitionsRDD
NewHadoopRDD
ParallelCollectionRDD
RDD
ReliableCheckpointRDD
ShuffledRDD
SubtractedRDD
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
ReliableRDDCheckpointData
Shuffling
Dependencies
NarrowDependency
ShuffleDependency
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
ShuffleMigrationRunnable
¶
ShuffleMigrationRunnable
is...FIXME
Back to top