public static interface StoreTypes.ExecutorSummaryOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
boolean |
containsAttributes(String key)
map<string, string> attributes = 27; |
boolean |
containsExecutorLogs(String key)
map<string, string> executor_logs = 23; |
boolean |
containsResources(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
int |
getActiveTasks()
int32 active_tasks = 9; |
long |
getAddTime()
int64 add_time = 20; |
java.util.Map<String,String> |
getAttributes()
Deprecated.
|
int |
getAttributesCount()
map<string, string> attributes = 27; |
java.util.Map<String,String> |
getAttributesMap()
map<string, string> attributes = 27; |
String |
getAttributesOrDefault(String key,
String defaultValue)
map<string, string> attributes = 27; |
String |
getAttributesOrThrow(String key)
map<string, string> attributes = 27; |
long |
getBlacklistedInStages(int index)
repeated int64 blacklisted_in_stages = 25; |
int |
getBlacklistedInStagesCount()
repeated int64 blacklisted_in_stages = 25; |
java.util.List<Long> |
getBlacklistedInStagesList()
repeated int64 blacklisted_in_stages = 25; |
int |
getCompletedTasks()
int32 completed_tasks = 11; |
long |
getDiskUsed()
int64 disk_used = 6; |
long |
getExcludedInStages(int index)
repeated int64 excluded_in_stages = 31; |
int |
getExcludedInStagesCount()
repeated int64 excluded_in_stages = 31; |
java.util.List<Long> |
getExcludedInStagesList()
repeated int64 excluded_in_stages = 31; |
java.util.Map<String,String> |
getExecutorLogs()
Deprecated.
|
int |
getExecutorLogsCount()
map<string, string> executor_logs = 23; |
java.util.Map<String,String> |
getExecutorLogsMap()
map<string, string> executor_logs = 23; |
String |
getExecutorLogsOrDefault(String key,
String defaultValue)
map<string, string> executor_logs = 23; |
String |
getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 23; |
int |
getFailedTasks()
int32 failed_tasks = 10; |
String |
getHostPort()
optional string host_port = 2; |
com.google.protobuf.ByteString |
getHostPortBytes()
optional string host_port = 2; |
String |
getId()
optional string id = 1; |
com.google.protobuf.ByteString |
getIdBytes()
optional string id = 1; |
boolean |
getIsActive()
bool is_active = 3; |
boolean |
getIsBlacklisted()
bool is_blacklisted = 18; |
boolean |
getIsExcluded()
bool is_excluded = 30; |
long |
getMaxMemory()
int64 max_memory = 19; |
int |
getMaxTasks()
int32 max_tasks = 8; |
StoreTypes.MemoryMetrics |
getMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24; |
StoreTypes.MemoryMetricsOrBuilder |
getMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24; |
long |
getMemoryUsed()
int64 memory_used = 5; |
StoreTypes.ExecutorMetrics |
getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
StoreTypes.ExecutorMetricsOrBuilder |
getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
int |
getRddBlocks()
int32 rdd_blocks = 4; |
String |
getRemoveReason()
optional string remove_reason = 22; |
com.google.protobuf.ByteString |
getRemoveReasonBytes()
optional string remove_reason = 22; |
long |
getRemoveTime()
optional int64 remove_time = 21; |
int |
getResourceProfileId()
int32 resource_profile_id = 29; |
java.util.Map<String,StoreTypes.ResourceInformation> |
getResources()
Deprecated.
|
int |
getResourcesCount()
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
java.util.Map<String,StoreTypes.ResourceInformation> |
getResourcesMap()
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
StoreTypes.ResourceInformation |
getResourcesOrDefault(String key,
StoreTypes.ResourceInformation defaultValue)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
StoreTypes.ResourceInformation |
getResourcesOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
int |
getTotalCores()
int32 total_cores = 7; |
long |
getTotalDuration()
int64 total_duration = 13; |
long |
getTotalGcTime()
int64 total_gc_time = 14; |
long |
getTotalInputBytes()
int64 total_input_bytes = 15; |
long |
getTotalShuffleRead()
int64 total_shuffle_read = 16; |
long |
getTotalShuffleWrite()
int64 total_shuffle_write = 17; |
int |
getTotalTasks()
int32 total_tasks = 12; |
boolean |
hasHostPort()
optional string host_port = 2; |
boolean |
hasId()
optional string id = 1; |
boolean |
hasMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24; |
boolean |
hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
boolean |
hasRemoveReason()
optional string remove_reason = 22; |
boolean |
hasRemoveTime()
optional int64 remove_time = 21; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
boolean hasId()
optional string id = 1;
String getId()
optional string id = 1;
com.google.protobuf.ByteString getIdBytes()
optional string id = 1;
boolean hasHostPort()
optional string host_port = 2;
String getHostPort()
optional string host_port = 2;
com.google.protobuf.ByteString getHostPortBytes()
optional string host_port = 2;
boolean getIsActive()
bool is_active = 3;
int getRddBlocks()
int32 rdd_blocks = 4;
long getMemoryUsed()
int64 memory_used = 5;
long getDiskUsed()
int64 disk_used = 6;
int getTotalCores()
int32 total_cores = 7;
int getMaxTasks()
int32 max_tasks = 8;
int getActiveTasks()
int32 active_tasks = 9;
int getFailedTasks()
int32 failed_tasks = 10;
int getCompletedTasks()
int32 completed_tasks = 11;
int getTotalTasks()
int32 total_tasks = 12;
long getTotalDuration()
int64 total_duration = 13;
long getTotalGcTime()
int64 total_gc_time = 14;
long getTotalInputBytes()
int64 total_input_bytes = 15;
long getTotalShuffleRead()
int64 total_shuffle_read = 16;
long getTotalShuffleWrite()
int64 total_shuffle_write = 17;
boolean getIsBlacklisted()
bool is_blacklisted = 18;
long getMaxMemory()
int64 max_memory = 19;
long getAddTime()
int64 add_time = 20;
boolean hasRemoveTime()
optional int64 remove_time = 21;
long getRemoveTime()
optional int64 remove_time = 21;
boolean hasRemoveReason()
optional string remove_reason = 22;
String getRemoveReason()
optional string remove_reason = 22;
com.google.protobuf.ByteString getRemoveReasonBytes()
optional string remove_reason = 22;
int getExecutorLogsCount()
map<string, string> executor_logs = 23;
boolean containsExecutorLogs(String key)
map<string, string> executor_logs = 23;
@Deprecated java.util.Map<String,String> getExecutorLogs()
getExecutorLogsMap()
instead.java.util.Map<String,String> getExecutorLogsMap()
map<string, string> executor_logs = 23;
String getExecutorLogsOrDefault(String key, String defaultValue)
map<string, string> executor_logs = 23;
String getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 23;
boolean hasMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
StoreTypes.MemoryMetrics getMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
StoreTypes.MemoryMetricsOrBuilder getMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
java.util.List<Long> getBlacklistedInStagesList()
repeated int64 blacklisted_in_stages = 25;
int getBlacklistedInStagesCount()
repeated int64 blacklisted_in_stages = 25;
long getBlacklistedInStages(int index)
repeated int64 blacklisted_in_stages = 25;
index
- The index of the element to return.boolean hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
int getAttributesCount()
map<string, string> attributes = 27;
boolean containsAttributes(String key)
map<string, string> attributes = 27;
@Deprecated java.util.Map<String,String> getAttributes()
getAttributesMap()
instead.java.util.Map<String,String> getAttributesMap()
map<string, string> attributes = 27;
String getAttributesOrDefault(String key, String defaultValue)
map<string, string> attributes = 27;
String getAttributesOrThrow(String key)
map<string, string> attributes = 27;
int getResourcesCount()
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
boolean containsResources(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
@Deprecated java.util.Map<String,StoreTypes.ResourceInformation> getResources()
getResourcesMap()
instead.java.util.Map<String,StoreTypes.ResourceInformation> getResourcesMap()
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
StoreTypes.ResourceInformation getResourcesOrDefault(String key, StoreTypes.ResourceInformation defaultValue)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
StoreTypes.ResourceInformation getResourcesOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
int getResourceProfileId()
int32 resource_profile_id = 29;
boolean getIsExcluded()
bool is_excluded = 30;
java.util.List<Long> getExcludedInStagesList()
repeated int64 excluded_in_stages = 31;
int getExcludedInStagesCount()
repeated int64 excluded_in_stages = 31;
long getExcludedInStages(int index)
repeated int64 excluded_in_stages = 31;
index
- The index of the element to return.