File tree
440 files changed
+905
-886
lines changed- BytesToBytesMap
- ConsoleProgressBar
- DriverLogger
- ExecutorDeadException
- FileCommitProtocol
- HadoopMapRedCommitProtocol
- HadoopMapRedWriteConfigUtil
- HadoopMapReduceCommitProtocol
- HadoopMapReduceWriteConfigUtil
- HadoopWriteConfigUtil
- HeartbeatReceiver
- InterruptibleIterator
- ListenerBus
- OutputCommitCoordinator
- SparkConf
- SparkContext-creating-instance-internals
- SparkContext
- SparkCoreErrors
- SparkEnv
- SparkFiles
- SparkHadoopWriter
- SparkListenerBus
- SparkListenerEvent
- SparkListenerInterface
- SparkListenerTaskEnd
- SparkListener
- SparkStatusTracker
- SpillListener
- StatsReportListener
- TaskCompletionListener
- TaskFailureListener
- Utils
- accumulators
- AccumulableInfo
- AccumulatorContext
- AccumulatorSource
- AccumulatorV2
- InternalAccumulator
- architecture
- barrier-execution-mode
- BarrierCoordinatorMessage
- BarrierCoordinator
- BarrierJobAllocationFailed
- BarrierJobSlotsNumberCheckFailed
- BarrierTaskContext
- ContextBarrierState
- RDDBarrier
- RequestMethod
- RequestToSync
- broadcast-variables
- BroadcastFactory
- BroadcastManager
- Broadcast
- TorrentBroadcastFactory
- TorrentBroadcast
- configuration-properties
- core
- BlockFetchStarter
- BlockFetchingListener
- CleanerListener
- ContextCleaner
- InMemoryStore
- KVStore
- LevelDB
- RetryingBlockFetcher
- demo
- diskblockmanager-and-block-data
- developer-api
- driver
- dynamic-allocation
- ExecutorAllocationClient
- ExecutorAllocationListener
- ExecutorAllocationManagerSource
- ExecutorAllocationManager
- ExecutorMonitor
- Tracker
- configuration-properties
- executor
- CoarseGrainedExecutorBackend
- ExecutorBackend
- ExecutorLogUrlHandler
- ExecutorMetricType
- ExecutorMetricsPoller
- ExecutorMetricsSource
- ExecutorMetrics
- ExecutorSource
- Executor
- ShuffleReadMetrics
- ShuffleWriteMetrics
- TaskMetrics
- TaskRunner
- exercises
- spark-examples-wordcount-spark-shell
- spark-exercise-custom-scheduler-listener
- spark-exercise-dataframe-jdbc-postgresql
- spark-exercise-failing-stage
- spark-exercise-pairrddfunctions-oneliners
- spark-exercise-standalone-master-ha
- spark-exercise-take-multiple-jobs
- spark-first-app
- spark-hello-world-using-spark-shell
- spark-sql-hive-orc-example
- external-shuffle-service
- ExecutorShuffleInfo
- ExternalBlockHandler
- ExternalShuffleBlockResolver
- ExternalShuffleService
- configuration-properties
- features
- history-server
- ApplicationCacheOperations
- ApplicationCache
- ApplicationHistoryProvider
- EventLogFileWriter
- EventLoggingListener
- FsHistoryProvider
- HistoryAppStatusStore
- HistoryServerArguments
- HistoryServerDiskManager
- HistoryServer
- JsonProtocol
- ReplayListenerBus
- SQLHistoryListener
- configuration-properties
- local-properties
- local
- LauncherBackend
- LocalEndpoint
- LocalSchedulerBackend
- master
- memory
- ExecutionMemoryPool
- MemoryAllocator
- MemoryConsumer
- MemoryManager
- MemoryPool
- StorageMemoryPool
- TaskMemoryManager
- UnifiedMemoryManager
- UnsafeExternalSorter
- UnsafeInMemorySorter
- UnsafeSorterSpillReader
- UnsafeSorterSpillWriter
- metrics
- JvmSource
- MetricsConfig
- MetricsServlet
- MetricsSystem
- PrometheusServlet
- Sink
- Source
- configuration-properties
- network
- SparkTransportConf
- TransportClientFactory
- TransportConf
- TransportContext
- overview
- plugins
- DriverPluginContainer
- DriverPlugin
- ExecutorPluginContainer
- ExecutorPlugin
- PluginContainer
- PluginContextImpl
- SparkPlugin
- push-based-shuffle
- rdd
- Aggregator
- AsyncRDDActions
- CheckpointRDD
- CoGroupedRDD
- CoalescedRDD
- Dependency
- HadoopRDD
- HashPartitioner
- LocalCheckpointRDD
- LocalRDDCheckpointData
- MapPartitionsRDD
- NarrowDependency
- NewHadoopRDD
- OrderedRDDFunctions
- PairRDDFunctions
- ParallelCollectionRDD
- Partitioner
- Partition
- RDDCheckpointData
- RDDOperationScope
- RDD
- RangePartitioner
- ReliableCheckpointRDD
- ReliableRDDCheckpointData
- ShuffleDependency
- ShuffledRDD
- SubtractedRDD
- checkpointing
- lineage
- spark-rdd-actions
- spark-rdd-caching
- spark-rdd-operations
- spark-rdd-partitions
- spark-rdd-transformations
- rest
- AbstractApplicationResource
- ApiRequestContext
- ApiRootResource
- ApplicationListResource
- BaseAppResource
- OneApplicationAttemptResource
- OneApplicationResource
- StagesResource
- UIRootFromServletContext
- UIRoot
- rpc
- NettyRpcEnvFactory
- NettyRpcEnv
- RpcAddress
- RpcEndpointAddress
- RpcEndpointRef
- RpcEndpoint
- RpcEnvConfig
- RpcEnvFactory
- RpcEnvFileServer
- RpcEnv
- RpcUtils
- spark-rpc-netty
- scheduler
- ActiveJob
- BlacklistTracker
- CoarseGrainedSchedulerBackend
- CompressedMapStatus
- DAGSchedulerEventProcessLoop
- DAGSchedulerEvent
- DAGSchedulerSource
- DAGScheduler
- DriverEndpoint
- ExecutorData
- ExternalClusterManager
- FIFOSchedulableBuilder
- FairSchedulableBuilder
- HighlyCompressedMapStatus
- JobListener
- JobWaiter
- LiveListenerBus
- MapOutputStatistics
- MapOutputTrackerMasterEndpoint
- MapOutputTrackerMaster
- MapOutputTrackerWorker
- MapOutputTracker
- MapStatus
- Pool
- ResultStage
- ResultTask
- SchedulableBuilder
- Schedulable
- SchedulerBackendUtils
- SchedulerBackend
- SchedulingMode
- ShuffleMapStage
- ShuffleMapTask
- ShuffleStatus
- StageInfo
- Stage
- TaskContextImpl
- TaskContext
- TaskDescription
- TaskInfo
- TaskLocation
- TaskResultGetter
- TaskResult
- TaskSchedulerImpl
- TaskScheduler
- TaskSetBlacklist
- TaskSetManager
- TaskSet
- Task
- search
- serializer
- DeserializationStream
- JavaSerializerInstance
- KryoSerializerInstance
- KryoSerializer
- SerializationStream
- SerializerInstance
- SerializerManager
- Serializer
- shuffle
- BaseShuffleHandle
- BlockStoreShuffleReader
- BypassMergeSortShuffleHandle
- BypassMergeSortShuffleWriter
- DownloadFileManager
- ExecutorDiskUtils
- ExternalAppendOnlyMap
- ExternalSorter
- FetchFailedException
- IndexShuffleBlockResolver
- LocalDiskShuffleDataIO
- LocalDiskShuffleExecutorComponents
- LocalDiskShuffleMapOutputWriter
- LocalDiskSingleSpillMapOutputWriter
- MigratableResolver
- SerializedShuffleHandle
- ShuffleBlockPusher
- ShuffleBlockResolver
- ShuffleDataIOUtils
- ShuffleDataIO
- ShuffleDriverComponents
- ShuffleExecutorComponents
- ShuffleExternalSorter
- ShuffleHandle
- ShuffleInMemorySorter
- ShuffleManager
- ShuffleMapOutputWriter
- ShuffleReader
- ShuffleWriteMetricsReporter
- ShuffleWriteProcessor
- ShuffleWriter
- SingleSpillShuffleMapOutputWriter
- SortShuffleManager
- SortShuffleWriter
- Spillable
- UnsafeShuffleWriter
- spark-debugging
- spark-logging
- spark-properties
- spark-tips-and-tricks-access-private-members-spark-shell
- spark-tips-and-tricks-running-spark-windows
- spark-tips-and-tricks-sparkexception-task-not-serializable
- spark-tips-and-tricks
- speculative-execution-of-tasks
- stage-level-scheduling
- ExecutorResourceInfo
- ExecutorResourceRequests
- ExecutorResourceRequest
- ResourceAllocator
- ResourceID
- ResourceProfileBuilder
- ResourceProfileManager
- ResourceProfile
- ResourceUtils
- SparkListenerResourceProfileAdded
- TaskResourceProfile
- TaskResourceRequests
- TaskResourceRequest
- status
- AppStatusListener
- AppStatusSource
- AppStatusStore
- ElementTrackingStore
- LiveEntity
- storage
- BlockDataManager
- BlockData
- BlockEvictionHandler
- BlockId
- BlockInfoManager
- BlockInfo
- BlockManagerDecommissioner
- BlockManagerId
- BlockManagerInfo
- BlockManagerMasterEndpoint
- BlockManagerMasterHeartbeatEndpoint
- BlockManagerMaster
- BlockManagerSlaveEndpoint
- BlockManagerSource
- BlockManagerStorageEndpoint
- BlockManager
- BlockReplicationPolicy
- BlockStoreClient
- BlockStoreUpdater
- BlockTransferService
- ByteBufferBlockStoreUpdater
- DiskBlockManager
- DiskBlockObjectWriter
- DiskStore
- ExternalBlockStoreClient
- FallbackStorage
- MemoryStore
- NettyBlockRpcServer
- NettyBlockTransferService
- OneForOneBlockFetcher
- RDDInfo
- RandomBlockReplicationPolicy
- ShuffleBlockFetcherIterator
- ShuffleFetchCompletionListener
- ShuffleMetricsSource
- ShuffleMigrationRunnable
- StorageLevel
- StorageStatus
- StorageUtils
- TempFileBasedBlockStoreUpdater
- tools
- AbstractCommandBuilder
- AbstractLauncher
- DependencyUtils
- JavaMainApplication
- Main
- SparkApplication
- SparkClassCommandBuilder
- SparkLauncher
- pyspark
- spark-class
- spark-shell
- spark-submit
- SparkSubmitArguments
- SparkSubmitCommandBuilder.OptionParser
- SparkSubmitCommandBuilder
- SparkSubmitOperation
- SparkSubmitOptionParser
- SparkSubmitUtils
- SparkSubmit
- webui
- AllJobsPage
- AllStagesPage
- EnvironmentPage
- EnvironmentTab
- ExecutorThreadDumpPage
- ExecutorsPage
- ExecutorsTab
- JettyUtils
- JobPage
- JobsTab
- PoolPage
- PrometheusResource
- RDDPage
- SparkUITab
- SparkUI
- StagePage
- StagesTab
- StoragePage
- StorageTab
- UIUtils
- WebUIPage
- WebUITab
- WebUI
- configuration-properties
- workers
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
440 files changed
+905
-886
lines changedLines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.
0 commit comments