CoarseGrainedClusterMessages |
|
CoarseGrainedClusterMessages.AddWebUIFilter |
|
CoarseGrainedClusterMessages.AddWebUIFilter$ |
|
CoarseGrainedClusterMessages.KillExecutors |
|
CoarseGrainedClusterMessages.KillExecutors$ |
|
CoarseGrainedClusterMessages.KillTask |
|
CoarseGrainedClusterMessages.KillTask$ |
|
CoarseGrainedClusterMessages.LaunchTask |
|
CoarseGrainedClusterMessages.LaunchTask$ |
|
CoarseGrainedClusterMessages.RegisterClusterManager$ |
|
CoarseGrainedClusterMessages.RegisteredExecutor$ |
|
CoarseGrainedClusterMessages.RegisterExecutor |
|
CoarseGrainedClusterMessages.RegisterExecutor$ |
|
CoarseGrainedClusterMessages.RegisterExecutorFailed |
|
CoarseGrainedClusterMessages.RegisterExecutorFailed$ |
|
CoarseGrainedClusterMessages.RemoveExecutor |
|
CoarseGrainedClusterMessages.RemoveExecutor$ |
|
CoarseGrainedClusterMessages.RequestExecutors |
|
CoarseGrainedClusterMessages.RequestExecutors$ |
|
CoarseGrainedClusterMessages.RetrieveSparkProps$ |
|
CoarseGrainedClusterMessages.ReviveOffers$ |
Alternate factory method that takes a ByteBuffer directly for the data field
|
CoarseGrainedClusterMessages.StatusUpdate |
|
CoarseGrainedClusterMessages.StatusUpdate$ |
|
CoarseGrainedClusterMessages.StopDriver$ |
|
CoarseGrainedClusterMessages.StopExecutor$ |
|
CoarseGrainedClusterMessages.StopExecutors$ |
|
CoarseGrainedSchedulerBackend |
A scheduler backend that waits for coarse grained executors to connect to it through Akka.
|
ExecutorData |
Grouping of data for an executor used by CoarseGrainedSchedulerBackend.
|
ExecutorInfo |
:: DeveloperApi ::
Stores information about an executor to pass from the scheduler to SparkListeners.
|
SimrSchedulerBackend |
|
SparkDeploySchedulerBackend |
|
YarnSchedulerBackend |
Abstract Yarn scheduler backend that contains common logic
between the client and cluster Yarn scheduler backends.
|