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, hasOneofboolean 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.