Package org.apache.spark
Class SparkExecutorInfoImpl
Object
org.apache.spark.SparkExecutorInfoImpl
- All Implemented Interfaces:
Serializable
,SparkExecutorInfo
- See Also:
-
Constructor Summary
ConstructorDescriptionSparkExecutorInfoImpl
(String host, int port, long cacheSize, int numRunningTasks, long usedOnHeapStorageMemory, long usedOffHeapStorageMemory, long totalOnHeapStorageMemory, long totalOffHeapStorageMemory) -
Method Summary
-
Constructor Details
-
SparkExecutorInfoImpl
public SparkExecutorInfoImpl(String host, int port, long cacheSize, int numRunningTasks, long usedOnHeapStorageMemory, long usedOffHeapStorageMemory, long totalOnHeapStorageMemory, long totalOffHeapStorageMemory)
-
-
Method Details
-
cacheSize
public long cacheSize()- Specified by:
cacheSize
in interfaceSparkExecutorInfo
-
host
- Specified by:
host
in interfaceSparkExecutorInfo
-
numRunningTasks
public int numRunningTasks()- Specified by:
numRunningTasks
in interfaceSparkExecutorInfo
-
port
public int port()- Specified by:
port
in interfaceSparkExecutorInfo
-
totalOffHeapStorageMemory
public long totalOffHeapStorageMemory()- Specified by:
totalOffHeapStorageMemory
in interfaceSparkExecutorInfo
-
totalOnHeapStorageMemory
public long totalOnHeapStorageMemory()- Specified by:
totalOnHeapStorageMemory
in interfaceSparkExecutorInfo
-
usedOffHeapStorageMemory
public long usedOffHeapStorageMemory()- Specified by:
usedOffHeapStorageMemory
in interfaceSparkExecutorInfo
-
usedOnHeapStorageMemory
public long usedOnHeapStorageMemory()- Specified by:
usedOnHeapStorageMemory
in interfaceSparkExecutorInfo
-