org.apache.spark.scheduler.cluster

Class CoarseGrainedClusterMessages.RegisterExecutor

Object

org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RegisterExecutor

All Implemented Interfaces:

java.io.Serializable, CoarseGrainedClusterMessage, scala.Equals, scala.Product

Enclosing class:

CoarseGrainedClusterMessages

public static class CoarseGrainedClusterMessages.RegisterExecutor
extends Object
implements CoarseGrainedClusterMessage, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

RegisterExecutor

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)

Method Detail

executorId

public String executorId()

executorRef

public org.apache.spark.rpc.RpcEndpointRef executorRef()

hostname

public String hostname()

cores

public int cores()

logUrls

public scala.collection.immutable.Map<String,String> logUrls()

attributes

public scala.collection.immutable.Map<String,String> attributes()

resources

public scala.collection.immutable.Map<String,ResourceInformation> resources()

resourceProfileId

public int resourceProfileId()