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, newBuilderForField
findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.ExecutorSummary.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
public StoreTypes.ExecutorSummary getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public StoreTypes.ExecutorSummary build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.ExecutorSummary buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.ExecutorSummary.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
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.Builder
setField
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.Builder
clearField
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.Builder
clearOneof
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.Builder
setRepeatedField
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.Builder
addRepeatedField
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.Builder
mergeFrom
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.MessageLiteOrBuilder
isInitialized
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.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.ExecutorSummary.Builder>
java.io.IOException
public boolean hasId()
optional string id = 1;
hasId
in interface StoreTypes.ExecutorSummaryOrBuilder
public String getId()
optional string id = 1;
getId
in interface StoreTypes.ExecutorSummaryOrBuilder
public com.google.protobuf.ByteString getIdBytes()
optional string id = 1;
getIdBytes
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public String getHostPort()
optional string host_port = 2;
getHostPort
in interface StoreTypes.ExecutorSummaryOrBuilder
public com.google.protobuf.ByteString getHostPortBytes()
optional string host_port = 2;
getHostPortBytes
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public long getRemoveTime()
optional int64 remove_time = 21;
getRemoveTime
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public String getRemoveReason()
optional string remove_reason = 22;
getRemoveReason
in interface StoreTypes.ExecutorSummaryOrBuilder
public com.google.protobuf.ByteString getRemoveReasonBytes()
optional string remove_reason = 22;
getRemoveReasonBytes
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
map<string, string> executor_logs = 23;
getExecutorLogsCount
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public java.util.Map<String,String> getExecutorLogsMap()
map<string, string> executor_logs = 23;
getExecutorLogsMap
in interface StoreTypes.ExecutorSummaryOrBuilder
public String getExecutorLogsOrDefault(String key, String defaultValue)
map<string, string> executor_logs = 23;
getExecutorLogsOrDefault
in interface StoreTypes.ExecutorSummaryOrBuilder
public String getExecutorLogsOrThrow(String key)
map<string, string> executor_logs = 23;
getExecutorLogsOrThrow
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public StoreTypes.MemoryMetrics getMemoryMetrics()
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
getMemoryMetrics
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public java.util.List<Long> getBlacklistedInStagesList()
repeated int64 blacklisted_in_stages = 25;
getBlacklistedInStagesList
in interface StoreTypes.ExecutorSummaryOrBuilder
public int getBlacklistedInStagesCount()
repeated int64 blacklisted_in_stages = 25;
getBlacklistedInStagesCount
in interface StoreTypes.ExecutorSummaryOrBuilder
public long getBlacklistedInStages(int index)
repeated int64 blacklisted_in_stages = 25;
getBlacklistedInStages
in interface StoreTypes.ExecutorSummaryOrBuilder
index
- 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.ExecutorSummaryOrBuilder
public StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
getPeakMemoryMetrics
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public int getAttributesCount()
StoreTypes.ExecutorSummaryOrBuilder
map<string, string> attributes = 27;
getAttributesCount
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public java.util.Map<String,String> getAttributesMap()
map<string, string> attributes = 27;
getAttributesMap
in interface StoreTypes.ExecutorSummaryOrBuilder
public String getAttributesOrDefault(String key, String defaultValue)
map<string, string> attributes = 27;
getAttributesOrDefault
in interface StoreTypes.ExecutorSummaryOrBuilder
public String getAttributesOrThrow(String key)
map<string, string> attributes = 27;
getAttributesOrThrow
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
getResourcesCount
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public java.util.Map<String,StoreTypes.ResourceInformation> getResourcesMap()
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
getResourcesMap
in interface StoreTypes.ExecutorSummaryOrBuilder
public StoreTypes.ResourceInformation getResourcesOrDefault(String key, StoreTypes.ResourceInformation defaultValue)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
getResourcesOrDefault
in interface StoreTypes.ExecutorSummaryOrBuilder
public StoreTypes.ResourceInformation getResourcesOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
getResourcesOrThrow
in interface StoreTypes.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public 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.ExecutorSummaryOrBuilder
public int getExcludedInStagesCount()
repeated int64 excluded_in_stages = 31;
getExcludedInStagesCount
in interface StoreTypes.ExecutorSummaryOrBuilder
public long getExcludedInStages(int index)
repeated int64 excluded_in_stages = 31;
getExcludedInStages
in interface StoreTypes.ExecutorSummaryOrBuilder
index
- 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.Builder
setUnknownFields
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.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>