Package org.apache.spark.status.protobuf
Class StoreTypes.ExecutorSummary.Builder
Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderType>
com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
org.apache.spark.status.protobuf.StoreTypes.ExecutorSummary.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder
,com.google.protobuf.MessageLite.Builder
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Cloneable
,StoreTypes.ExecutorSummaryOrBuilder
- Enclosing class:
- StoreTypes.ExecutorSummary
public static final class StoreTypes.ExecutorSummary.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
implements StoreTypes.ExecutorSummaryOrBuilder
Protobuf type
org.apache.spark.status.protobuf.ExecutorSummary
-
Method Summary
Modifier and TypeMethodDescriptionaddAllBlacklistedInStages
(Iterable<? extends Long> values) repeated int64 blacklisted_in_stages = 25;
addAllExcludedInStages
(Iterable<? extends Long> values) repeated int64 excluded_in_stages = 31;
addBlacklistedInStages
(long value) repeated int64 blacklisted_in_stages = 25;
addExcludedInStages
(long value) repeated int64 excluded_in_stages = 31;
addRepeatedField
(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) build()
clear()
int32 active_tasks = 9;
int64 add_time = 20;
repeated int64 blacklisted_in_stages = 25;
int32 completed_tasks = 11;
int64 disk_used = 6;
repeated int64 excluded_in_stages = 31;
int32 failed_tasks = 10;
clearField
(com.google.protobuf.Descriptors.FieldDescriptor field) optional string host_port = 2;
clearId()
optional string id = 1;
bool is_active = 3;
bool is_blacklisted = 18;
bool is_excluded = 30;
int64 max_memory = 19;
int32 max_tasks = 8;
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
int64 memory_used = 5;
clearOneof
(com.google.protobuf.Descriptors.OneofDescriptor oneof) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
int32 rdd_blocks = 4;
optional string remove_reason = 22;
optional int64 remove_time = 21;
int32 resource_profile_id = 29;
int32 total_cores = 7;
int64 total_duration = 13;
int64 total_gc_time = 14;
int64 total_input_bytes = 15;
int64 total_shuffle_read = 16;
int64 total_shuffle_write = 17;
int32 total_tasks = 12;
clone()
boolean
containsAttributes
(String key) map<string, string> attributes = 27;
boolean
map<string, string> executor_logs = 23;
boolean
containsResources
(String key) map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
int
int32 active_tasks = 9;
long
int64 add_time = 20;
Deprecated.int
map<string, string> attributes = 27;
map<string, string> attributes = 27;
getAttributesOrDefault
(String key, String defaultValue) map<string, string> attributes = 27;
map<string, string> attributes = 27;
long
getBlacklistedInStages
(int index) repeated int64 blacklisted_in_stages = 25;
int
repeated int64 blacklisted_in_stages = 25;
repeated int64 blacklisted_in_stages = 25;
int
int32 completed_tasks = 11;
static final com.google.protobuf.Descriptors.Descriptor
com.google.protobuf.Descriptors.Descriptor
long
int64 disk_used = 6;
long
getExcludedInStages
(int index) repeated int64 excluded_in_stages = 31;
int
repeated int64 excluded_in_stages = 31;
repeated int64 excluded_in_stages = 31;
Deprecated.int
map<string, string> executor_logs = 23;
map<string, string> executor_logs = 23;
getExecutorLogsOrDefault
(String key, String defaultValue) map<string, string> executor_logs = 23;
map<string, string> executor_logs = 23;
int
int32 failed_tasks = 10;
optional string host_port = 2;
com.google.protobuf.ByteString
optional string host_port = 2;
getId()
optional string id = 1;
com.google.protobuf.ByteString
optional string id = 1;
boolean
bool is_active = 3;
boolean
bool is_blacklisted = 18;
boolean
bool is_excluded = 30;
long
int64 max_memory = 19;
int
int32 max_tasks = 8;
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
long
int64 memory_used = 5;
Deprecated.Deprecated.Deprecated.optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
int
int32 rdd_blocks = 4;
optional string remove_reason = 22;
com.google.protobuf.ByteString
optional string remove_reason = 22;
long
optional int64 remove_time = 21;
int
int32 resource_profile_id = 29;
Deprecated.int
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
getResourcesOrDefault
(String key, StoreTypes.ResourceInformation defaultValue) map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
int
int32 total_cores = 7;
long
int64 total_duration = 13;
long
int64 total_gc_time = 14;
long
int64 total_input_bytes = 15;
long
int64 total_shuffle_read = 16;
long
int64 total_shuffle_write = 17;
int
int32 total_tasks = 12;
boolean
optional string host_port = 2;
boolean
hasId()
optional string id = 1;
boolean
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
boolean
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
boolean
optional string remove_reason = 22;
boolean
optional int64 remove_time = 21;
final boolean
mergeFrom
(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom
(com.google.protobuf.Message other) optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
mergeUnknownFields
(com.google.protobuf.UnknownFieldSet unknownFields) putAllAttributes
(Map<String, String> values) map<string, string> attributes = 27;
putAllExecutorLogs
(Map<String, String> values) map<string, string> executor_logs = 23;
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
putAttributes
(String key, String value) map<string, string> attributes = 27;
putExecutorLogs
(String key, String value) map<string, string> executor_logs = 23;
putResources
(String key, StoreTypes.ResourceInformation value) map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
removeAttributes
(String key) map<string, string> attributes = 27;
removeExecutorLogs
(String key) map<string, string> executor_logs = 23;
removeResources
(String key) map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
setActiveTasks
(int value) int32 active_tasks = 9;
setAddTime
(long value) int64 add_time = 20;
setBlacklistedInStages
(int index, long value) repeated int64 blacklisted_in_stages = 25;
setCompletedTasks
(int value) int32 completed_tasks = 11;
setDiskUsed
(long value) int64 disk_used = 6;
setExcludedInStages
(int index, long value) repeated int64 excluded_in_stages = 31;
setFailedTasks
(int value) int32 failed_tasks = 10;
setHostPort
(String value) optional string host_port = 2;
setHostPortBytes
(com.google.protobuf.ByteString value) optional string host_port = 2;
optional string id = 1;
setIdBytes
(com.google.protobuf.ByteString value) optional string id = 1;
setIsActive
(boolean value) bool is_active = 3;
setIsBlacklisted
(boolean value) bool is_blacklisted = 18;
setIsExcluded
(boolean value) bool is_excluded = 30;
setMaxMemory
(long value) int64 max_memory = 19;
setMaxTasks
(int value) int32 max_tasks = 8;
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
setMemoryMetrics
(StoreTypes.MemoryMetrics.Builder builderForValue) optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
setMemoryUsed
(long value) int64 memory_used = 5;
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
setPeakMemoryMetrics
(StoreTypes.ExecutorMetrics.Builder builderForValue) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
setRddBlocks
(int value) int32 rdd_blocks = 4;
setRemoveReason
(String value) optional string remove_reason = 22;
setRemoveReasonBytes
(com.google.protobuf.ByteString value) optional string remove_reason = 22;
setRemoveTime
(long value) optional int64 remove_time = 21;
setRepeatedField
(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) setResourceProfileId
(int value) int32 resource_profile_id = 29;
setTotalCores
(int value) int32 total_cores = 7;
setTotalDuration
(long value) int64 total_duration = 13;
setTotalGcTime
(long value) int64 total_gc_time = 14;
setTotalInputBytes
(long value) int64 total_input_bytes = 15;
setTotalShuffleRead
(long value) int64 total_shuffle_read = 16;
setTotalShuffleWrite
(long value) int64 total_shuffle_write = 17;
setTotalTasks
(int value) int32 total_tasks = 12;
setUnknownFields
(com.google.protobuf.UnknownFieldSet unknownFields) Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForField
Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
mergeFrom
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFrom
Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
clear
- Specified by:
clear
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clear
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clear
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.Message.Builder
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getDescriptorForType
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
build
in interfacecom.google.protobuf.Message.Builder
- Specified by:
build
in interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartial
in interfacecom.google.protobuf.Message.Builder
- Specified by:
buildPartial
in interfacecom.google.protobuf.MessageLite.Builder
-
clone
- Specified by:
clone
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clone
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clone
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
setField
public StoreTypes.ExecutorSummary.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
setField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
clearField
public StoreTypes.ExecutorSummary.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) - Specified by:
clearField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
clearOneof
public StoreTypes.ExecutorSummary.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) - Specified by:
clearOneof
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearOneof
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
setRepeatedField
public StoreTypes.ExecutorSummary.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) - Specified by:
setRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
addRepeatedField
public StoreTypes.ExecutorSummary.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
addRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
addRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
mergeFrom
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<StoreTypes.ExecutorSummary.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
mergeFrom
public StoreTypes.ExecutorSummary.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Specified by:
mergeFrom
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<StoreTypes.ExecutorSummary.Builder>
- Throws:
IOException
-
hasId
public boolean hasId()optional string id = 1;
- Specified by:
hasId
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- Whether the id field is set.
-
getId
optional string id = 1;
- Specified by:
getId
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The id.
-
getIdBytes
public com.google.protobuf.ByteString getIdBytes()optional string id = 1;
- Specified by:
getIdBytes
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The bytes for id.
-
setId
optional string id = 1;
- Parameters:
value
- The id to set.- Returns:
- This builder for chaining.
-
clearId
optional string id = 1;
- Returns:
- This builder for chaining.
-
setIdBytes
optional string id = 1;
- Parameters:
value
- The bytes for id to set.- Returns:
- This builder for chaining.
-
hasHostPort
public boolean hasHostPort()optional string host_port = 2;
- Specified by:
hasHostPort
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- Whether the hostPort field is set.
-
getHostPort
optional string host_port = 2;
- Specified by:
getHostPort
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The hostPort.
-
getHostPortBytes
public com.google.protobuf.ByteString getHostPortBytes()optional string host_port = 2;
- Specified by:
getHostPortBytes
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The bytes for hostPort.
-
setHostPort
optional string host_port = 2;
- Parameters:
value
- The hostPort to set.- Returns:
- This builder for chaining.
-
clearHostPort
optional string host_port = 2;
- Returns:
- This builder for chaining.
-
setHostPortBytes
optional string host_port = 2;
- Parameters:
value
- The bytes for hostPort to set.- Returns:
- This builder for chaining.
-
getIsActive
public boolean getIsActive()bool is_active = 3;
- Specified by:
getIsActive
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The isActive.
-
setIsActive
bool is_active = 3;
- Parameters:
value
- The isActive to set.- Returns:
- This builder for chaining.
-
clearIsActive
bool is_active = 3;
- Returns:
- This builder for chaining.
-
getRddBlocks
public int getRddBlocks()int32 rdd_blocks = 4;
- Specified by:
getRddBlocks
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The rddBlocks.
-
setRddBlocks
int32 rdd_blocks = 4;
- Parameters:
value
- The rddBlocks to set.- Returns:
- This builder for chaining.
-
clearRddBlocks
int32 rdd_blocks = 4;
- Returns:
- This builder for chaining.
-
getMemoryUsed
public long getMemoryUsed()int64 memory_used = 5;
- Specified by:
getMemoryUsed
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The memoryUsed.
-
setMemoryUsed
int64 memory_used = 5;
- Parameters:
value
- The memoryUsed to set.- Returns:
- This builder for chaining.
-
clearMemoryUsed
int64 memory_used = 5;
- Returns:
- This builder for chaining.
-
getDiskUsed
public long getDiskUsed()int64 disk_used = 6;
- Specified by:
getDiskUsed
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The diskUsed.
-
setDiskUsed
int64 disk_used = 6;
- Parameters:
value
- The diskUsed to set.- Returns:
- This builder for chaining.
-
clearDiskUsed
int64 disk_used = 6;
- Returns:
- This builder for chaining.
-
getTotalCores
public int getTotalCores()int32 total_cores = 7;
- Specified by:
getTotalCores
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The totalCores.
-
setTotalCores
int32 total_cores = 7;
- Parameters:
value
- The totalCores to set.- Returns:
- This builder for chaining.
-
clearTotalCores
int32 total_cores = 7;
- Returns:
- This builder for chaining.
-
getMaxTasks
public int getMaxTasks()int32 max_tasks = 8;
- Specified by:
getMaxTasks
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The maxTasks.
-
setMaxTasks
int32 max_tasks = 8;
- Parameters:
value
- The maxTasks to set.- Returns:
- This builder for chaining.
-
clearMaxTasks
int32 max_tasks = 8;
- Returns:
- This builder for chaining.
-
getActiveTasks
public int getActiveTasks()int32 active_tasks = 9;
- Specified by:
getActiveTasks
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The activeTasks.
-
setActiveTasks
int32 active_tasks = 9;
- Parameters:
value
- The activeTasks to set.- Returns:
- This builder for chaining.
-
clearActiveTasks
int32 active_tasks = 9;
- Returns:
- This builder for chaining.
-
getFailedTasks
public int getFailedTasks()int32 failed_tasks = 10;
- Specified by:
getFailedTasks
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The failedTasks.
-
setFailedTasks
int32 failed_tasks = 10;
- Parameters:
value
- The failedTasks to set.- Returns:
- This builder for chaining.
-
clearFailedTasks
int32 failed_tasks = 10;
- Returns:
- This builder for chaining.
-
getCompletedTasks
public int getCompletedTasks()int32 completed_tasks = 11;
- Specified by:
getCompletedTasks
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The completedTasks.
-
setCompletedTasks
int32 completed_tasks = 11;
- Parameters:
value
- The completedTasks to set.- Returns:
- This builder for chaining.
-
clearCompletedTasks
int32 completed_tasks = 11;
- Returns:
- This builder for chaining.
-
getTotalTasks
public int getTotalTasks()int32 total_tasks = 12;
- Specified by:
getTotalTasks
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The totalTasks.
-
setTotalTasks
int32 total_tasks = 12;
- Parameters:
value
- The totalTasks to set.- Returns:
- This builder for chaining.
-
clearTotalTasks
int32 total_tasks = 12;
- Returns:
- This builder for chaining.
-
getTotalDuration
public long getTotalDuration()int64 total_duration = 13;
- Specified by:
getTotalDuration
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The totalDuration.
-
setTotalDuration
int64 total_duration = 13;
- Parameters:
value
- The totalDuration to set.- Returns:
- This builder for chaining.
-
clearTotalDuration
int64 total_duration = 13;
- Returns:
- This builder for chaining.
-
getTotalGcTime
public long getTotalGcTime()int64 total_gc_time = 14;
- Specified by:
getTotalGcTime
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The totalGcTime.
-
setTotalGcTime
int64 total_gc_time = 14;
- Parameters:
value
- The totalGcTime to set.- Returns:
- This builder for chaining.
-
clearTotalGcTime
int64 total_gc_time = 14;
- Returns:
- This builder for chaining.
-
getTotalInputBytes
public long getTotalInputBytes()int64 total_input_bytes = 15;
- Specified by:
getTotalInputBytes
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The totalInputBytes.
-
setTotalInputBytes
int64 total_input_bytes = 15;
- Parameters:
value
- The totalInputBytes to set.- Returns:
- This builder for chaining.
-
clearTotalInputBytes
int64 total_input_bytes = 15;
- Returns:
- This builder for chaining.
-
getTotalShuffleRead
public long getTotalShuffleRead()int64 total_shuffle_read = 16;
- Specified by:
getTotalShuffleRead
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The totalShuffleRead.
-
setTotalShuffleRead
int64 total_shuffle_read = 16;
- Parameters:
value
- The totalShuffleRead to set.- Returns:
- This builder for chaining.
-
clearTotalShuffleRead
int64 total_shuffle_read = 16;
- Returns:
- This builder for chaining.
-
getTotalShuffleWrite
public long getTotalShuffleWrite()int64 total_shuffle_write = 17;
- Specified by:
getTotalShuffleWrite
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The totalShuffleWrite.
-
setTotalShuffleWrite
int64 total_shuffle_write = 17;
- Parameters:
value
- The totalShuffleWrite to set.- Returns:
- This builder for chaining.
-
clearTotalShuffleWrite
int64 total_shuffle_write = 17;
- Returns:
- This builder for chaining.
-
getIsBlacklisted
public boolean getIsBlacklisted()bool is_blacklisted = 18;
- Specified by:
getIsBlacklisted
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The isBlacklisted.
-
setIsBlacklisted
bool is_blacklisted = 18;
- Parameters:
value
- The isBlacklisted to set.- Returns:
- This builder for chaining.
-
clearIsBlacklisted
bool is_blacklisted = 18;
- Returns:
- This builder for chaining.
-
getMaxMemory
public long getMaxMemory()int64 max_memory = 19;
- Specified by:
getMaxMemory
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The maxMemory.
-
setMaxMemory
int64 max_memory = 19;
- Parameters:
value
- The maxMemory to set.- Returns:
- This builder for chaining.
-
clearMaxMemory
int64 max_memory = 19;
- Returns:
- This builder for chaining.
-
getAddTime
public long getAddTime()int64 add_time = 20;
- Specified by:
getAddTime
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The addTime.
-
setAddTime
int64 add_time = 20;
- Parameters:
value
- The addTime to set.- Returns:
- This builder for chaining.
-
clearAddTime
int64 add_time = 20;
- Returns:
- This builder for chaining.
-
hasRemoveTime
public boolean hasRemoveTime()optional int64 remove_time = 21;
- Specified by:
hasRemoveTime
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- Whether the removeTime field is set.
-
getRemoveTime
public long getRemoveTime()optional int64 remove_time = 21;
- Specified by:
getRemoveTime
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The removeTime.
-
setRemoveTime
optional int64 remove_time = 21;
- Parameters:
value
- The removeTime to set.- Returns:
- This builder for chaining.
-
clearRemoveTime
optional int64 remove_time = 21;
- Returns:
- This builder for chaining.
-
hasRemoveReason
public boolean hasRemoveReason()optional string remove_reason = 22;
- Specified by:
hasRemoveReason
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- Whether the removeReason field is set.
-
getRemoveReason
optional string remove_reason = 22;
- Specified by:
getRemoveReason
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The removeReason.
-
getRemoveReasonBytes
public com.google.protobuf.ByteString getRemoveReasonBytes()optional string remove_reason = 22;
- Specified by:
getRemoveReasonBytes
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The bytes for removeReason.
-
setRemoveReason
optional string remove_reason = 22;
- Parameters:
value
- The removeReason to set.- Returns:
- This builder for chaining.
-
clearRemoveReason
optional string remove_reason = 22;
- Returns:
- This builder for chaining.
-
setRemoveReasonBytes
public StoreTypes.ExecutorSummary.Builder setRemoveReasonBytes(com.google.protobuf.ByteString value) optional string remove_reason = 22;
- Parameters:
value
- The bytes for removeReason to set.- Returns:
- This builder for chaining.
-
getExecutorLogsCount
public int getExecutorLogsCount()Description copied from interface:StoreTypes.ExecutorSummaryOrBuilder
map<string, string> executor_logs = 23;
- Specified by:
getExecutorLogsCount
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
containsExecutorLogs
map<string, string> executor_logs = 23;
- Specified by:
containsExecutorLogs
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getExecutorLogs
Deprecated.UsegetExecutorLogsMap()
instead.- Specified by:
getExecutorLogs
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getExecutorLogsMap
map<string, string> executor_logs = 23;
- Specified by:
getExecutorLogsMap
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getExecutorLogsOrDefault
map<string, string> executor_logs = 23;
- Specified by:
getExecutorLogsOrDefault
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getExecutorLogsOrThrow
map<string, string> executor_logs = 23;
- Specified by:
getExecutorLogsOrThrow
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
clearExecutorLogs
-
removeExecutorLogs
map<string, string> executor_logs = 23;
-
getMutableExecutorLogs
Deprecated.Use alternate mutation accessors instead. -
putExecutorLogs
map<string, string> executor_logs = 23;
-
putAllExecutorLogs
map<string, string> executor_logs = 23;
-
hasMemoryMetrics
public boolean hasMemoryMetrics()optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
- Specified by:
hasMemoryMetrics
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- Whether the memoryMetrics field is set.
-
getMemoryMetrics
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
- Specified by:
getMemoryMetrics
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The memoryMetrics.
-
setMemoryMetrics
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
-
setMemoryMetrics
public StoreTypes.ExecutorSummary.Builder setMemoryMetrics(StoreTypes.MemoryMetrics.Builder builderForValue) optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
-
mergeMemoryMetrics
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
-
clearMemoryMetrics
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
-
getMemoryMetricsBuilder
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
-
getMemoryMetricsOrBuilder
optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
- Specified by:
getMemoryMetricsOrBuilder
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getBlacklistedInStagesList
repeated int64 blacklisted_in_stages = 25;
- Specified by:
getBlacklistedInStagesList
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- A list containing the blacklistedInStages.
-
getBlacklistedInStagesCount
public int getBlacklistedInStagesCount()repeated int64 blacklisted_in_stages = 25;
- Specified by:
getBlacklistedInStagesCount
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The count of blacklistedInStages.
-
getBlacklistedInStages
public long getBlacklistedInStages(int index) repeated int64 blacklisted_in_stages = 25;
- Specified by:
getBlacklistedInStages
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Parameters:
index
- The index of the element to return.- Returns:
- The blacklistedInStages at the given index.
-
setBlacklistedInStages
repeated int64 blacklisted_in_stages = 25;
- Parameters:
index
- The index to set the value at.value
- The blacklistedInStages to set.- Returns:
- This builder for chaining.
-
addBlacklistedInStages
repeated int64 blacklisted_in_stages = 25;
- Parameters:
value
- The blacklistedInStages to add.- Returns:
- This builder for chaining.
-
addAllBlacklistedInStages
public StoreTypes.ExecutorSummary.Builder addAllBlacklistedInStages(Iterable<? extends Long> values) repeated int64 blacklisted_in_stages = 25;
- Parameters:
values
- The blacklistedInStages to add.- Returns:
- This builder for chaining.
-
clearBlacklistedInStages
repeated int64 blacklisted_in_stages = 25;
- Returns:
- This builder for chaining.
-
hasPeakMemoryMetrics
public boolean hasPeakMemoryMetrics()optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
- Specified by:
hasPeakMemoryMetrics
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- Whether the peakMemoryMetrics field is set.
-
getPeakMemoryMetrics
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
- Specified by:
getPeakMemoryMetrics
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The peakMemoryMetrics.
-
setPeakMemoryMetrics
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
-
setPeakMemoryMetrics
public StoreTypes.ExecutorSummary.Builder setPeakMemoryMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
-
mergePeakMemoryMetrics
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
-
clearPeakMemoryMetrics
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
-
getPeakMemoryMetricsBuilder
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
-
getPeakMemoryMetricsOrBuilder
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
- Specified by:
getPeakMemoryMetricsOrBuilder
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getAttributesCount
public int getAttributesCount()Description copied from interface:StoreTypes.ExecutorSummaryOrBuilder
map<string, string> attributes = 27;
- Specified by:
getAttributesCount
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
containsAttributes
map<string, string> attributes = 27;
- Specified by:
containsAttributes
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getAttributes
Deprecated.UsegetAttributesMap()
instead.- Specified by:
getAttributes
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getAttributesMap
map<string, string> attributes = 27;
- Specified by:
getAttributesMap
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getAttributesOrDefault
map<string, string> attributes = 27;
- Specified by:
getAttributesOrDefault
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getAttributesOrThrow
map<string, string> attributes = 27;
- Specified by:
getAttributesOrThrow
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
clearAttributes
-
removeAttributes
map<string, string> attributes = 27;
-
getMutableAttributes
Deprecated.Use alternate mutation accessors instead. -
putAttributes
map<string, string> attributes = 27;
-
putAllAttributes
map<string, string> attributes = 27;
-
getResourcesCount
public int getResourcesCount()Description copied from interface:StoreTypes.ExecutorSummaryOrBuilder
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
- Specified by:
getResourcesCount
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
containsResources
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
- Specified by:
containsResources
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getResources
Deprecated.UsegetResourcesMap()
instead.- Specified by:
getResources
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getResourcesMap
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
- Specified by:
getResourcesMap
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getResourcesOrDefault
public StoreTypes.ResourceInformation getResourcesOrDefault(String key, StoreTypes.ResourceInformation defaultValue) map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
- Specified by:
getResourcesOrDefault
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
getResourcesOrThrow
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
- Specified by:
getResourcesOrThrow
in interfaceStoreTypes.ExecutorSummaryOrBuilder
-
clearResources
-
removeResources
map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
-
getMutableResources
Deprecated.Use alternate mutation accessors instead. -
putResources
public StoreTypes.ExecutorSummary.Builder putResources(String key, StoreTypes.ResourceInformation value) map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
-
putAllResources
public StoreTypes.ExecutorSummary.Builder putAllResources(Map<String, StoreTypes.ResourceInformation> values) map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
-
getResourceProfileId
public int getResourceProfileId()int32 resource_profile_id = 29;
- Specified by:
getResourceProfileId
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The resourceProfileId.
-
setResourceProfileId
int32 resource_profile_id = 29;
- Parameters:
value
- The resourceProfileId to set.- Returns:
- This builder for chaining.
-
clearResourceProfileId
int32 resource_profile_id = 29;
- Returns:
- This builder for chaining.
-
getIsExcluded
public boolean getIsExcluded()bool is_excluded = 30;
- Specified by:
getIsExcluded
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The isExcluded.
-
setIsExcluded
bool is_excluded = 30;
- Parameters:
value
- The isExcluded to set.- Returns:
- This builder for chaining.
-
clearIsExcluded
bool is_excluded = 30;
- Returns:
- This builder for chaining.
-
getExcludedInStagesList
repeated int64 excluded_in_stages = 31;
- Specified by:
getExcludedInStagesList
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- A list containing the excludedInStages.
-
getExcludedInStagesCount
public int getExcludedInStagesCount()repeated int64 excluded_in_stages = 31;
- Specified by:
getExcludedInStagesCount
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Returns:
- The count of excludedInStages.
-
getExcludedInStages
public long getExcludedInStages(int index) repeated int64 excluded_in_stages = 31;
- Specified by:
getExcludedInStages
in interfaceStoreTypes.ExecutorSummaryOrBuilder
- Parameters:
index
- The index of the element to return.- Returns:
- The excludedInStages at the given index.
-
setExcludedInStages
repeated int64 excluded_in_stages = 31;
- Parameters:
index
- The index to set the value at.value
- The excludedInStages to set.- Returns:
- This builder for chaining.
-
addExcludedInStages
repeated int64 excluded_in_stages = 31;
- Parameters:
value
- The excludedInStages to add.- Returns:
- This builder for chaining.
-
addAllExcludedInStages
repeated int64 excluded_in_stages = 31;
- Parameters:
values
- The excludedInStages to add.- Returns:
- This builder for chaining.
-
clearExcludedInStages
repeated int64 excluded_in_stages = 31;
- Returns:
- This builder for chaining.
-
setUnknownFields
public final StoreTypes.ExecutorSummary.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
setUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-
mergeUnknownFields
public final StoreTypes.ExecutorSummary.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
mergeUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.ExecutorSummary.Builder>
-