public static class CoarseGrainedClusterMessages.RegisterExecutor extends Object implements CoarseGrainedClusterMessage, scala.Product, scala.Serializable
Constructor and Description |
---|
RegisterExecutor(String executorId,
org.apache.spark.rpc.RpcEndpointRef executorRef,
String hostname,
int cores,
scala.collection.immutable.Map<String,String> logUrls,
scala.collection.immutable.Map<String,String> attributes,
scala.collection.immutable.Map<String,ResourceInformation> resources,
int resourceProfileId) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.Map<String,String> |
attributes() |
int |
cores() |
String |
executorId() |
org.apache.spark.rpc.RpcEndpointRef |
executorRef() |
String |
hostname() |
scala.collection.immutable.Map<String,String> |
logUrls() |
int |
resourceProfileId() |
scala.collection.immutable.Map<String,ResourceInformation> |
resources() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public RegisterExecutor(String executorId, org.apache.spark.rpc.RpcEndpointRef executorRef, String hostname, int cores, scala.collection.immutable.Map<String,String> logUrls, scala.collection.immutable.Map<String,String> attributes, scala.collection.immutable.Map<String,ResourceInformation> resources, int resourceProfileId)
public String executorId()
public org.apache.spark.rpc.RpcEndpointRef executorRef()
public String hostname()
public int cores()
public scala.collection.immutable.Map<String,String> logUrls()
public scala.collection.immutable.Map<String,String> attributes()
public scala.collection.immutable.Map<String,ResourceInformation> resources()
public int resourceProfileId()