org.apache.spark.scheduler.cluster

Interface CoarseGrainedClusterMessage

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

CoarseGrainedClusterMessages.AddWebUIFilter, CoarseGrainedClusterMessages.GetExecutorLossReason, CoarseGrainedClusterMessages.KillExecutors, CoarseGrainedClusterMessages.KillExecutorsOnHost, CoarseGrainedClusterMessages.KillTask, CoarseGrainedClusterMessages.LaunchedExecutor, CoarseGrainedClusterMessages.LaunchTask, CoarseGrainedClusterMessages.RegisterClusterManager, CoarseGrainedClusterMessages.RegisteredExecutor$, CoarseGrainedClusterMessages.RegisterExecutor, CoarseGrainedClusterMessages.RegisterExecutorFailed, CoarseGrainedClusterMessages.RemoveExecutor, CoarseGrainedClusterMessages.RemoveWorker, CoarseGrainedClusterMessages.RequestExecutors, CoarseGrainedClusterMessages.RetrieveDelegationTokens$, CoarseGrainedClusterMessages.RetrieveLastAllocatedExecutorId$, CoarseGrainedClusterMessages.RetrieveSparkAppConfig$, CoarseGrainedClusterMessages.ReviveOffers$, CoarseGrainedClusterMessages.SetupDriver, CoarseGrainedClusterMessages.Shutdown$, CoarseGrainedClusterMessages.SparkAppConfig, CoarseGrainedClusterMessages.StatusUpdate, CoarseGrainedClusterMessages.StopDriver$, CoarseGrainedClusterMessages.StopExecutor$, CoarseGrainedClusterMessages.StopExecutors$, CoarseGrainedClusterMessages.UpdateDelegationTokens

public interface CoarseGrainedClusterMessage
extends scala.Serializable