public static final class StoreTypes.ExecutorSummary.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder> implements StoreTypes.ExecutorSummaryOrBuilder
org.apache.spark.status.protobuf.ExecutorSummary| Modifier and Type | Method and Description |
|---|---|
StoreTypes.ExecutorSummary.Builder |
addAllBlacklistedInStages(Iterable<? extends Long> values)
repeated int64 blacklisted_in_stages = 25; |
StoreTypes.ExecutorSummary.Builder |
addAllExcludedInStages(Iterable<? extends Long> values)
repeated int64 excluded_in_stages = 31; |
StoreTypes.ExecutorSummary.Builder |
addBlacklistedInStages(long value)
repeated int64 blacklisted_in_stages = 25; |
StoreTypes.ExecutorSummary.Builder |
addExcludedInStages(long value)
repeated int64 excluded_in_stages = 31; |
StoreTypes.ExecutorSummary.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
StoreTypes.ExecutorSummary |
build() |
StoreTypes.ExecutorSummary |
buildPartial() |
StoreTypes.ExecutorSummary.Builder |
clear() |
StoreTypes.ExecutorSummary.Builder |
clearActiveTasks()
int32 active_tasks = 9; |
StoreTypes.ExecutorSummary.Builder |
clearAddTime()
int64 add_time = 20; |
StoreTypes.ExecutorSummary.Builder |
clearAttributes() |
StoreTypes.ExecutorSummary.Builder |
clearBlacklistedInStages()
repeated int64 blacklisted_in_stages = 25; |
StoreTypes.ExecutorSummary.Builder |
clearCompletedTasks()
int32 completed_tasks = 11; |
StoreTypes.ExecutorSummary.Builder |
clearDiskUsed()
int64 disk_used = 6; |
StoreTypes.ExecutorSummary.Builder |
clearExcludedInStages()
repeated int64 excluded_in_stages = 31; |
StoreTypes.ExecutorSummary.Builder |
clearExecutorLogs() |
StoreTypes.ExecutorSummary.Builder |
clearFailedTasks()
int32 failed_tasks = 10; |
StoreTypes.ExecutorSummary.Builder |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
StoreTypes.ExecutorSummary.Builder |
clearHostPort()
optional string host_port = 2; |
StoreTypes.ExecutorSummary.Builder |
clearId()
optional string id = 1; |
StoreTypes.ExecutorSummary.Builder |
clearIsActive()
bool is_active = 3; |
StoreTypes.ExecutorSummary.Builder |
clearIsBlacklisted()
bool is_blacklisted = 18; |
StoreTypes.ExecutorSummary.Builder |
clearIsExcluded()
bool is_excluded = 30; |
StoreTypes.ExecutorSummary.Builder |
clearMaxMemory()
int64 max_memory = 19; |
StoreTypes.ExecutorSummary.Builder |
clearMaxTasks()
int32 max_tasks = 8; |
StoreTypes.ExecutorSummary.Builder |
clearMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24; |
StoreTypes.ExecutorSummary.Builder |
clearMemoryUsed()
int64 memory_used = 5; |
StoreTypes.ExecutorSummary.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
StoreTypes.ExecutorSummary.Builder |
clearPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
StoreTypes.ExecutorSummary.Builder |
clearRddBlocks()
int32 rdd_blocks = 4; |
StoreTypes.ExecutorSummary.Builder |
clearRemoveReason()
optional string remove_reason = 22; |
StoreTypes.ExecutorSummary.Builder |
clearRemoveTime()
optional int64 remove_time = 21; |
StoreTypes.ExecutorSummary.Builder |
clearResourceProfileId()
int32 resource_profile_id = 29; |
StoreTypes.ExecutorSummary.Builder |
clearResources() |
StoreTypes.ExecutorSummary.Builder |
clearTotalCores()
int32 total_cores = 7; |
StoreTypes.ExecutorSummary.Builder |
clearTotalDuration()
int64 total_duration = 13; |
StoreTypes.ExecutorSummary.Builder |
clearTotalGcTime()
int64 total_gc_time = 14; |
StoreTypes.ExecutorSummary.Builder |
clearTotalInputBytes()
int64 total_input_bytes = 15; |
StoreTypes.ExecutorSummary.Builder |
clearTotalShuffleRead()
int64 total_shuffle_read = 16; |
StoreTypes.ExecutorSummary.Builder |
clearTotalShuffleWrite()
int64 total_shuffle_write = 17; |
StoreTypes.ExecutorSummary.Builder |
clearTotalTasks()
int32 total_tasks = 12; |
StoreTypes.ExecutorSummary.Builder |
clone() |
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; |
StoreTypes.ExecutorSummary |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
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.MemoryMetrics.Builder |
getMemoryMetricsBuilder()
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; |
java.util.Map<String,String> |
getMutableAttributes()
Deprecated.
|
java.util.Map<String,String> |
getMutableExecutorLogs()
Deprecated.
|
java.util.Map<String,StoreTypes.ResourceInformation> |
getMutableResources()
Deprecated.
|
StoreTypes.ExecutorMetrics |
getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
StoreTypes.ExecutorMetrics.Builder |
getPeakMemoryMetricsBuilder()
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; |
boolean |
isInitialized() |
StoreTypes.ExecutorSummary.Builder |
mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
StoreTypes.ExecutorSummary.Builder |
mergeFrom(com.google.protobuf.Message other) |
StoreTypes.ExecutorSummary.Builder |
mergeFrom(StoreTypes.ExecutorSummary other) |
StoreTypes.ExecutorSummary.Builder |
mergeMemoryMetrics(StoreTypes.MemoryMetrics value)
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24; |
StoreTypes.ExecutorSummary.Builder |
mergePeakMemoryMetrics(StoreTypes.ExecutorMetrics value)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
StoreTypes.ExecutorSummary.Builder |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
StoreTypes.ExecutorSummary.Builder |
putAllAttributes(java.util.Map<String,String> values)
map<string, string> attributes = 27; |
StoreTypes.ExecutorSummary.Builder |
putAllExecutorLogs(java.util.Map<String,String> values)
map<string, string> executor_logs = 23; |
StoreTypes.ExecutorSummary.Builder |
putAllResources(java.util.Map<String,StoreTypes.ResourceInformation> values)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
StoreTypes.ExecutorSummary.Builder |
putAttributes(String key,
String value)
map<string, string> attributes = 27; |
StoreTypes.ExecutorSummary.Builder |
putExecutorLogs(String key,
String value)
map<string, string> executor_logs = 23; |
StoreTypes.ExecutorSummary.Builder |
putResources(String key,
StoreTypes.ResourceInformation value)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
StoreTypes.ExecutorSummary.Builder |
removeAttributes(String key)
map<string, string> attributes = 27; |
StoreTypes.ExecutorSummary.Builder |
removeExecutorLogs(String key)
map<string, string> executor_logs = 23; |
StoreTypes.ExecutorSummary.Builder |
removeResources(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28; |
StoreTypes.ExecutorSummary.Builder |
setActiveTasks(int value)
int32 active_tasks = 9; |
StoreTypes.ExecutorSummary.Builder |
setAddTime(long value)
int64 add_time = 20; |
StoreTypes.ExecutorSummary.Builder |
setBlacklistedInStages(int index,
long value)
repeated int64 blacklisted_in_stages = 25; |
StoreTypes.ExecutorSummary.Builder |
setCompletedTasks(int value)
int32 completed_tasks = 11; |
StoreTypes.ExecutorSummary.Builder |
setDiskUsed(long value)
int64 disk_used = 6; |
StoreTypes.ExecutorSummary.Builder |
setExcludedInStages(int index,
long value)
repeated int64 excluded_in_stages = 31; |
StoreTypes.ExecutorSummary.Builder |
setFailedTasks(int value)
int32 failed_tasks = 10; |
StoreTypes.ExecutorSummary.Builder |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
StoreTypes.ExecutorSummary.Builder |
setHostPort(String value)
optional string host_port = 2; |
StoreTypes.ExecutorSummary.Builder |
setHostPortBytes(com.google.protobuf.ByteString value)
optional string host_port = 2; |
StoreTypes.ExecutorSummary.Builder |
setId(String value)
optional string id = 1; |
StoreTypes.ExecutorSummary.Builder |
setIdBytes(com.google.protobuf.ByteString value)
optional string id = 1; |
StoreTypes.ExecutorSummary.Builder |
setIsActive(boolean value)
bool is_active = 3; |
StoreTypes.ExecutorSummary.Builder |
setIsBlacklisted(boolean value)
bool is_blacklisted = 18; |
StoreTypes.ExecutorSummary.Builder |
setIsExcluded(boolean value)
bool is_excluded = 30; |
StoreTypes.ExecutorSummary.Builder |
setMaxMemory(long value)
int64 max_memory = 19; |
StoreTypes.ExecutorSummary.Builder |
setMaxTasks(int value)
int32 max_tasks = 8; |
StoreTypes.ExecutorSummary.Builder |
setMemoryMetrics(StoreTypes.MemoryMetrics.Builder builderForValue)
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24; |
StoreTypes.ExecutorSummary.Builder |
setMemoryMetrics(StoreTypes.MemoryMetrics value)
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24; |
StoreTypes.ExecutorSummary.Builder |
setMemoryUsed(long value)
int64 memory_used = 5; |
StoreTypes.ExecutorSummary.Builder |
setPeakMemoryMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
StoreTypes.ExecutorSummary.Builder |
setPeakMemoryMetrics(StoreTypes.ExecutorMetrics value)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26; |
StoreTypes.ExecutorSummary.Builder |
setRddBlocks(int value)
int32 rdd_blocks = 4; |
StoreTypes.ExecutorSummary.Builder |
setRemoveReason(String value)
optional string remove_reason = 22; |
StoreTypes.ExecutorSummary.Builder |
setRemoveReasonBytes(com.google.protobuf.ByteString value)
optional string remove_reason = 22; |
StoreTypes.ExecutorSummary.Builder |
setRemoveTime(long value)
optional int64 remove_time = 21; |
StoreTypes.ExecutorSummary.Builder |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
StoreTypes.ExecutorSummary.Builder |
setResourceProfileId(int value)
int32 resource_profile_id = 29; |
StoreTypes.ExecutorSummary.Builder |
setTotalCores(int value)
int32 total_cores = 7; |
StoreTypes.ExecutorSummary.Builder |
setTotalDuration(long value)
int64 total_duration = 13; |
StoreTypes.ExecutorSummary.Builder |
setTotalGcTime(long value)
int64 total_gc_time = 14; |
StoreTypes.ExecutorSummary.Builder |
setTotalInputBytes(long value)
int64 total_input_bytes = 15; |
StoreTypes.ExecutorSummary.Builder |
setTotalShuffleRead(long value)
int64 total_shuffle_read = 16; |
StoreTypes.ExecutorSummary.Builder |
setTotalShuffleWrite(long value)
int64 total_shuffle_write = 17; |
StoreTypes.ExecutorSummary.Builder |
setTotalTasks(int value)
int32 total_tasks = 12; |
StoreTypes.ExecutorSummary.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForFieldfindInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toStringpublic static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.ExecutorSummary.Builder clear()
clear in interface com.google.protobuf.Message.Builderclear in interface com.google.protobuf.MessageLite.Builderclear in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType in interface com.google.protobuf.Message.BuildergetDescriptorForType in interface com.google.protobuf.MessageOrBuildergetDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderpublic StoreTypes.ExecutorSummary build()
build in interface com.google.protobuf.Message.Builderbuild in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.ExecutorSummary buildPartial()
buildPartial in interface com.google.protobuf.Message.BuilderbuildPartial in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.ExecutorSummary.Builder clone()
clone in interface com.google.protobuf.Message.Builderclone in interface com.google.protobuf.MessageLite.Builderclone in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField in interface com.google.protobuf.Message.BuildersetField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField in interface com.google.protobuf.Message.BuilderclearField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof in interface com.google.protobuf.Message.BuilderclearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField in interface com.google.protobuf.Message.BuildersetRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField in interface com.google.protobuf.Message.BuilderaddRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder mergeFrom(StoreTypes.ExecutorSummary other)
public final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public StoreTypes.ExecutorSummary.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in interface com.google.protobuf.MessageLite.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.ExecutorSummary.Builder>java.io.IOExceptionpublic boolean hasId()
optional string id = 1;hasId in interface StoreTypes.ExecutorSummaryOrBuilderpublic String getId()
optional string id = 1;getId in interface StoreTypes.ExecutorSummaryOrBuilderpublic com.google.protobuf.ByteString getIdBytes()
optional string id = 1;getIdBytes in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setId(String value)
optional string id = 1;value - The id to set.public StoreTypes.ExecutorSummary.Builder clearId()
optional string id = 1;public StoreTypes.ExecutorSummary.Builder setIdBytes(com.google.protobuf.ByteString value)
optional string id = 1;value - The bytes for id to set.public boolean hasHostPort()
optional string host_port = 2;hasHostPort in interface StoreTypes.ExecutorSummaryOrBuilderpublic String getHostPort()
optional string host_port = 2;getHostPort in interface StoreTypes.ExecutorSummaryOrBuilderpublic com.google.protobuf.ByteString getHostPortBytes()
optional string host_port = 2;getHostPortBytes in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setHostPort(String value)
optional string host_port = 2;value - The hostPort to set.public StoreTypes.ExecutorSummary.Builder clearHostPort()
optional string host_port = 2;public StoreTypes.ExecutorSummary.Builder setHostPortBytes(com.google.protobuf.ByteString value)
optional string host_port = 2;value - The bytes for hostPort to set.public boolean getIsActive()
bool is_active = 3;getIsActive in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setIsActive(boolean value)
bool is_active = 3;value - The isActive to set.public StoreTypes.ExecutorSummary.Builder clearIsActive()
bool is_active = 3;public int getRddBlocks()
int32 rdd_blocks = 4;getRddBlocks in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setRddBlocks(int value)
int32 rdd_blocks = 4;value - The rddBlocks to set.public StoreTypes.ExecutorSummary.Builder clearRddBlocks()
int32 rdd_blocks = 4;public long getMemoryUsed()
int64 memory_used = 5;getMemoryUsed in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setMemoryUsed(long value)
int64 memory_used = 5;value - The memoryUsed to set.public StoreTypes.ExecutorSummary.Builder clearMemoryUsed()
int64 memory_used = 5;public long getDiskUsed()
int64 disk_used = 6;getDiskUsed in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setDiskUsed(long value)
int64 disk_used = 6;value - The diskUsed to set.public StoreTypes.ExecutorSummary.Builder clearDiskUsed()
int64 disk_used = 6;public int getTotalCores()
int32 total_cores = 7;getTotalCores in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setTotalCores(int value)
int32 total_cores = 7;value - The totalCores to set.public StoreTypes.ExecutorSummary.Builder clearTotalCores()
int32 total_cores = 7;public int getMaxTasks()
int32 max_tasks = 8;getMaxTasks in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setMaxTasks(int value)
int32 max_tasks = 8;value - The maxTasks to set.public StoreTypes.ExecutorSummary.Builder clearMaxTasks()
int32 max_tasks = 8;public int getActiveTasks()
int32 active_tasks = 9;getActiveTasks in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setActiveTasks(int value)
int32 active_tasks = 9;value - The activeTasks to set.public StoreTypes.ExecutorSummary.Builder clearActiveTasks()
int32 active_tasks = 9;public int getFailedTasks()
int32 failed_tasks = 10;getFailedTasks in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setFailedTasks(int value)
int32 failed_tasks = 10;value - The failedTasks to set.public StoreTypes.ExecutorSummary.Builder clearFailedTasks()
int32 failed_tasks = 10;public int getCompletedTasks()
int32 completed_tasks = 11;getCompletedTasks in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setCompletedTasks(int value)
int32 completed_tasks = 11;value - The completedTasks to set.public StoreTypes.ExecutorSummary.Builder clearCompletedTasks()
int32 completed_tasks = 11;public int getTotalTasks()
int32 total_tasks = 12;getTotalTasks in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setTotalTasks(int value)
int32 total_tasks = 12;value - The totalTasks to set.public StoreTypes.ExecutorSummary.Builder clearTotalTasks()
int32 total_tasks = 12;public long getTotalDuration()
int64 total_duration = 13;getTotalDuration in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setTotalDuration(long value)
int64 total_duration = 13;value - The totalDuration to set.public StoreTypes.ExecutorSummary.Builder clearTotalDuration()
int64 total_duration = 13;public long getTotalGcTime()
int64 total_gc_time = 14;getTotalGcTime in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setTotalGcTime(long value)
int64 total_gc_time = 14;value - The totalGcTime to set.public StoreTypes.ExecutorSummary.Builder clearTotalGcTime()
int64 total_gc_time = 14;public long getTotalInputBytes()
int64 total_input_bytes = 15;getTotalInputBytes in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setTotalInputBytes(long value)
int64 total_input_bytes = 15;value - The totalInputBytes to set.public StoreTypes.ExecutorSummary.Builder clearTotalInputBytes()
int64 total_input_bytes = 15;public long getTotalShuffleRead()
int64 total_shuffle_read = 16;getTotalShuffleRead in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setTotalShuffleRead(long value)
int64 total_shuffle_read = 16;value - The totalShuffleRead to set.public StoreTypes.ExecutorSummary.Builder clearTotalShuffleRead()
int64 total_shuffle_read = 16;public long getTotalShuffleWrite()
int64 total_shuffle_write = 17;getTotalShuffleWrite in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setTotalShuffleWrite(long value)
int64 total_shuffle_write = 17;value - The totalShuffleWrite to set.public StoreTypes.ExecutorSummary.Builder clearTotalShuffleWrite()
int64 total_shuffle_write = 17;public boolean getIsBlacklisted()
bool is_blacklisted = 18;getIsBlacklisted in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setIsBlacklisted(boolean value)
bool is_blacklisted = 18;value - The isBlacklisted to set.public StoreTypes.ExecutorSummary.Builder clearIsBlacklisted()
bool is_blacklisted = 18;public long getMaxMemory()
int64 max_memory = 19;getMaxMemory in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setMaxMemory(long value)
int64 max_memory = 19;value - The maxMemory to set.public StoreTypes.ExecutorSummary.Builder clearMaxMemory()
int64 max_memory = 19;public long getAddTime()
int64 add_time = 20;getAddTime in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setAddTime(long value)
int64 add_time = 20;value - The addTime to set.public StoreTypes.ExecutorSummary.Builder clearAddTime()
int64 add_time = 20;public boolean hasRemoveTime()
optional int64 remove_time = 21;hasRemoveTime in interface StoreTypes.ExecutorSummaryOrBuilderpublic long getRemoveTime()
optional int64 remove_time = 21;getRemoveTime in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setRemoveTime(long value)
optional int64 remove_time = 21;value - The removeTime to set.public StoreTypes.ExecutorSummary.Builder clearRemoveTime()
optional int64 remove_time = 21;public boolean hasRemoveReason()
optional string remove_reason = 22;hasRemoveReason in interface StoreTypes.ExecutorSummaryOrBuilderpublic String getRemoveReason()
optional string remove_reason = 22;getRemoveReason in interface StoreTypes.ExecutorSummaryOrBuilderpublic com.google.protobuf.ByteString getRemoveReasonBytes()
optional string remove_reason = 22;getRemoveReasonBytes in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setRemoveReason(String value)
optional string remove_reason = 22;value - The removeReason to set.public StoreTypes.ExecutorSummary.Builder clearRemoveReason()
optional string remove_reason = 22;public StoreTypes.ExecutorSummary.Builder setRemoveReasonBytes(com.google.protobuf.ByteString value)
optional string remove_reason = 22;value - The bytes for removeReason to set.public int getExecutorLogsCount()
StoreTypes.ExecutorSummaryOrBuildermap<string, string> executor_logs = 23;getExecutorLogsCount in interface StoreTypes.ExecutorSummaryOrBuilderpublic boolean containsExecutorLogs(String key)
map<string, string> executor_logs = 23;containsExecutorLogs in interface StoreTypes.ExecutorSummaryOrBuilder@Deprecated public java.util.Map<String,String> getExecutorLogs()
getExecutorLogsMap() instead.getExecutorLogs in interface StoreTypes.ExecutorSummaryOrBuilderpublic java.util.Map<String,String> getExecutorLogsMap()
map<string, string> executor_logs = 23;getExecutorLogsMap in interface StoreTypes.ExecutorSummaryOrBuilderpublic String getExecutorLogsOrDefault(String key,
String defaultValue)
map<string, string> executor_logs = 23;getExecutorLogsOrDefault in interface StoreTypes.ExecutorSummaryOrBuilderpublic String getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 23;getExecutorLogsOrThrow in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder clearExecutorLogs()
public StoreTypes.ExecutorSummary.Builder removeExecutorLogs(String key)
map<string, string> executor_logs = 23;@Deprecated public java.util.Map<String,String> getMutableExecutorLogs()
public StoreTypes.ExecutorSummary.Builder putExecutorLogs(String key, String value)
map<string, string> executor_logs = 23;public StoreTypes.ExecutorSummary.Builder putAllExecutorLogs(java.util.Map<String,String> values)
map<string, string> executor_logs = 23;public boolean hasMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;hasMemoryMetrics in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.MemoryMetrics getMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;getMemoryMetrics in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setMemoryMetrics(StoreTypes.MemoryMetrics value)
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;public StoreTypes.ExecutorSummary.Builder setMemoryMetrics(StoreTypes.MemoryMetrics.Builder builderForValue)
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;public StoreTypes.ExecutorSummary.Builder mergeMemoryMetrics(StoreTypes.MemoryMetrics value)
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;public StoreTypes.ExecutorSummary.Builder clearMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;public StoreTypes.MemoryMetrics.Builder getMemoryMetricsBuilder()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;public StoreTypes.MemoryMetricsOrBuilder getMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;getMemoryMetricsOrBuilder in interface StoreTypes.ExecutorSummaryOrBuilderpublic java.util.List<Long> getBlacklistedInStagesList()
repeated int64 blacklisted_in_stages = 25;getBlacklistedInStagesList in interface StoreTypes.ExecutorSummaryOrBuilderpublic int getBlacklistedInStagesCount()
repeated int64 blacklisted_in_stages = 25;getBlacklistedInStagesCount in interface StoreTypes.ExecutorSummaryOrBuilderpublic long getBlacklistedInStages(int index)
repeated int64 blacklisted_in_stages = 25;getBlacklistedInStages in interface StoreTypes.ExecutorSummaryOrBuilderindex - The index of the element to return.public StoreTypes.ExecutorSummary.Builder setBlacklistedInStages(int index, long value)
repeated int64 blacklisted_in_stages = 25;index - The index to set the value at.value - The blacklistedInStages to set.public StoreTypes.ExecutorSummary.Builder addBlacklistedInStages(long value)
repeated int64 blacklisted_in_stages = 25;value - The blacklistedInStages to add.public StoreTypes.ExecutorSummary.Builder addAllBlacklistedInStages(Iterable<? extends Long> values)
repeated int64 blacklisted_in_stages = 25;values - The blacklistedInStages to add.public StoreTypes.ExecutorSummary.Builder clearBlacklistedInStages()
repeated int64 blacklisted_in_stages = 25;public boolean hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;hasPeakMemoryMetrics in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;getPeakMemoryMetrics in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setPeakMemoryMetrics(StoreTypes.ExecutorMetrics value)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;public StoreTypes.ExecutorSummary.Builder setPeakMemoryMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;public StoreTypes.ExecutorSummary.Builder mergePeakMemoryMetrics(StoreTypes.ExecutorMetrics value)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;public StoreTypes.ExecutorSummary.Builder clearPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;public StoreTypes.ExecutorMetrics.Builder getPeakMemoryMetricsBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;public StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;getPeakMemoryMetricsOrBuilder in interface StoreTypes.ExecutorSummaryOrBuilderpublic int getAttributesCount()
StoreTypes.ExecutorSummaryOrBuildermap<string, string> attributes = 27;getAttributesCount in interface StoreTypes.ExecutorSummaryOrBuilderpublic boolean containsAttributes(String key)
map<string, string> attributes = 27;containsAttributes in interface StoreTypes.ExecutorSummaryOrBuilder@Deprecated public java.util.Map<String,String> getAttributes()
getAttributesMap() instead.getAttributes in interface StoreTypes.ExecutorSummaryOrBuilderpublic java.util.Map<String,String> getAttributesMap()
map<string, string> attributes = 27;getAttributesMap in interface StoreTypes.ExecutorSummaryOrBuilderpublic String getAttributesOrDefault(String key,
String defaultValue)
map<string, string> attributes = 27;getAttributesOrDefault in interface StoreTypes.ExecutorSummaryOrBuilderpublic String getAttributesOrThrow(String key)
map<string, string> attributes = 27;getAttributesOrThrow in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder clearAttributes()
public StoreTypes.ExecutorSummary.Builder removeAttributes(String key)
map<string, string> attributes = 27;@Deprecated public java.util.Map<String,String> getMutableAttributes()
public StoreTypes.ExecutorSummary.Builder putAttributes(String key, String value)
map<string, string> attributes = 27;public StoreTypes.ExecutorSummary.Builder putAllAttributes(java.util.Map<String,String> values)
map<string, string> attributes = 27;public int getResourcesCount()
StoreTypes.ExecutorSummaryOrBuildermap<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;getResourcesCount in interface StoreTypes.ExecutorSummaryOrBuilderpublic boolean containsResources(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;containsResources in interface StoreTypes.ExecutorSummaryOrBuilder@Deprecated public java.util.Map<String,StoreTypes.ResourceInformation> getResources()
getResourcesMap() instead.getResources in interface StoreTypes.ExecutorSummaryOrBuilderpublic java.util.Map<String,StoreTypes.ResourceInformation> getResourcesMap()
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;getResourcesMap in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ResourceInformation getResourcesOrDefault(String key, StoreTypes.ResourceInformation defaultValue)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;getResourcesOrDefault in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ResourceInformation getResourcesOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;getResourcesOrThrow in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder clearResources()
public StoreTypes.ExecutorSummary.Builder removeResources(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;@Deprecated public java.util.Map<String,StoreTypes.ResourceInformation> getMutableResources()
public StoreTypes.ExecutorSummary.Builder putResources(String key, StoreTypes.ResourceInformation value)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;public StoreTypes.ExecutorSummary.Builder putAllResources(java.util.Map<String,StoreTypes.ResourceInformation> values)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;public int getResourceProfileId()
int32 resource_profile_id = 29;getResourceProfileId in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setResourceProfileId(int value)
int32 resource_profile_id = 29;value - The resourceProfileId to set.public StoreTypes.ExecutorSummary.Builder clearResourceProfileId()
int32 resource_profile_id = 29;public boolean getIsExcluded()
bool is_excluded = 30;getIsExcluded in interface StoreTypes.ExecutorSummaryOrBuilderpublic StoreTypes.ExecutorSummary.Builder setIsExcluded(boolean value)
bool is_excluded = 30;value - The isExcluded to set.public StoreTypes.ExecutorSummary.Builder clearIsExcluded()
bool is_excluded = 30;public java.util.List<Long> getExcludedInStagesList()
repeated int64 excluded_in_stages = 31;getExcludedInStagesList in interface StoreTypes.ExecutorSummaryOrBuilderpublic int getExcludedInStagesCount()
repeated int64 excluded_in_stages = 31;getExcludedInStagesCount in interface StoreTypes.ExecutorSummaryOrBuilderpublic long getExcludedInStages(int index)
repeated int64 excluded_in_stages = 31;getExcludedInStages in interface StoreTypes.ExecutorSummaryOrBuilderindex - The index of the element to return.public StoreTypes.ExecutorSummary.Builder setExcludedInStages(int index, long value)
repeated int64 excluded_in_stages = 31;index - The index to set the value at.value - The excludedInStages to set.public StoreTypes.ExecutorSummary.Builder addExcludedInStages(long value)
repeated int64 excluded_in_stages = 31;value - The excludedInStages to add.public StoreTypes.ExecutorSummary.Builder addAllExcludedInStages(Iterable<? extends Long> values)
repeated int64 excluded_in_stages = 31;values - The excludedInStages to add.public StoreTypes.ExecutorSummary.Builder clearExcludedInStages()
repeated int64 excluded_in_stages = 31;public final StoreTypes.ExecutorSummary.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields in interface com.google.protobuf.Message.BuildersetUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>public final StoreTypes.ExecutorSummary.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields in interface com.google.protobuf.Message.BuildermergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>