Class CoarseGrainedClusterMessages.RequestExecutors

Object
org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RequestExecutors
All Implemented Interfaces:
Serializable, CoarseGrainedClusterMessage, scala.Equals, scala.Product, scala.Serializable
Enclosing class:
CoarseGrainedClusterMessages

public static class CoarseGrainedClusterMessages.RequestExecutors extends Object implements CoarseGrainedClusterMessage, scala.Product, scala.Serializable
See Also:
  • Constructor Details

    • RequestExecutors

      public RequestExecutors(scala.collection.immutable.Map<ResourceProfile,Object> resourceProfileToTotalExecs, scala.collection.immutable.Map<Object,Object> numLocalityAwareTasksPerResourceProfileId, scala.collection.immutable.Map<Object,scala.collection.immutable.Map<String,Object>> hostToLocalTaskCount, scala.collection.immutable.Set<String> excludedNodes)
  • Method Details

    • resourceProfileToTotalExecs

      public scala.collection.immutable.Map<ResourceProfile,Object> resourceProfileToTotalExecs()
    • numLocalityAwareTasksPerResourceProfileId

      public scala.collection.immutable.Map<Object,Object> numLocalityAwareTasksPerResourceProfileId()
    • hostToLocalTaskCount

      public scala.collection.immutable.Map<Object,scala.collection.immutable.Map<String,Object>> hostToLocalTaskCount()
    • excludedNodes

      public scala.collection.immutable.Set<String> excludedNodes()