Package org.apache.spark.status.protobuf

Class StoreTypes.ExecutorSummary.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.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.GeneratedMessage.Builder<StoreTypes.ExecutorSummary.Builder>
implements StoreTypes.ExecutorSummaryOrBuilder

Protobuf type org.apache.spark.status.protobuf.ExecutorSummary

Method Summary

Modifier and Type	Method	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	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	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	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;
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;
Map<String,String>	getAttributes()	Deprecated.
int	getAttributesCount()	map<string, string> attributes = 27;
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;
List<Long>	getBlacklistedInStagesList()	repeated int64 blacklisted_in_stages = 25;
int	getCompletedTasks()	int32 completed_tasks = 11;
StoreTypes.ExecutorSummary	getDefaultInstanceForType()
static final 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;
List<Long>	getExcludedInStagesList()	repeated int64 excluded_in_stages = 31;
Map<String,String>	getExecutorLogs()	Deprecated.
int	getExecutorLogsCount()	map<string, string> executor_logs = 23;
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;
Map<String,String>	getMutableAttributes()	Deprecated.
Map<String,String>	getMutableExecutorLogs()	Deprecated.
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;
Map<String,StoreTypes.ResourceInformation>	getResources()	Deprecated.
int	getResourcesCount()	map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
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;
final 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	putAllAttributes(Map<String,String> values)	map<string, string> attributes = 27;
StoreTypes.ExecutorSummary.Builder	putAllExecutorLogs(Map<String,String> values)	map<string, string> executor_logs = 23;
StoreTypes.ExecutorSummary.Builder	putAllResources(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.ResourceInformation.Builder	putResourcesBuilderIfAbsent(String key)	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	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 value)	optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
StoreTypes.ExecutorSummary.Builder	setMemoryMetrics(StoreTypes.MemoryMetrics.Builder builderForValue)	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 value)	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
StoreTypes.ExecutorSummary.Builder	setPeakMemoryMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue)	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	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;

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, mergeUnknownFields, newBuilderForField, setField, setRepeatedField, setUnknownFields

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.Message.Builder

mergeDelimitedFrom, mergeDelimitedFrom

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

public StoreTypes.ExecutorSummary.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ExecutorSummary.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ExecutorSummary.Builder>

getDefaultInstanceForType

public StoreTypes.ExecutorSummary getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.ExecutorSummary build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public StoreTypes.ExecutorSummary buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public StoreTypes.ExecutorSummary.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.ExecutorSummary.Builder>

mergeFrom

public StoreTypes.ExecutorSummary.Builder mergeFrom(StoreTypes.ExecutorSummary other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.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 interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.ExecutorSummary.Builder>

Throws:

IOException

hasId

public boolean hasId()

optional string id = 1;

Specified by:

hasId in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

Whether the id field is set.

getId

public String getId()

optional string id = 1;

Specified by:

getId in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The id.

getIdBytes

public com.google.protobuf.ByteString getIdBytes()

optional string id = 1;

Specified by:

getIdBytes in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The bytes for id.

setId

public StoreTypes.ExecutorSummary.Builder setId(String value)

optional string id = 1;

Parameters:

value - The id to set.

Returns:

This builder for chaining.

clearId

public StoreTypes.ExecutorSummary.Builder clearId()

optional string id = 1;

Returns:

This builder for chaining.

setIdBytes

public StoreTypes.ExecutorSummary.Builder setIdBytes(com.google.protobuf.ByteString value)

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 interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

Whether the hostPort field is set.

getHostPort

public String getHostPort()

optional string host_port = 2;

Specified by:

getHostPort in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The hostPort.

getHostPortBytes

public com.google.protobuf.ByteString getHostPortBytes()

optional string host_port = 2;

Specified by:

getHostPortBytes in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The bytes for hostPort.

setHostPort

public StoreTypes.ExecutorSummary.Builder setHostPort(String value)

optional string host_port = 2;

Parameters:

value - The hostPort to set.

Returns:

This builder for chaining.

clearHostPort

public StoreTypes.ExecutorSummary.Builder clearHostPort()

optional string host_port = 2;

Returns:

This builder for chaining.

setHostPortBytes

public StoreTypes.ExecutorSummary.Builder setHostPortBytes(com.google.protobuf.ByteString value)

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 interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The isActive.

setIsActive

public StoreTypes.ExecutorSummary.Builder setIsActive(boolean value)

bool is_active = 3;

Parameters:

value - The isActive to set.

Returns:

This builder for chaining.

clearIsActive

public StoreTypes.ExecutorSummary.Builder clearIsActive()

bool is_active = 3;

Returns:

This builder for chaining.

getRddBlocks

public int getRddBlocks()

int32 rdd_blocks = 4;

Specified by:

getRddBlocks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The rddBlocks.

setRddBlocks

public StoreTypes.ExecutorSummary.Builder setRddBlocks(int value)

int32 rdd_blocks = 4;

Parameters:

value - The rddBlocks to set.

Returns:

This builder for chaining.

clearRddBlocks

public StoreTypes.ExecutorSummary.Builder clearRddBlocks()

int32 rdd_blocks = 4;

Returns:

This builder for chaining.

getMemoryUsed

public long getMemoryUsed()

int64 memory_used = 5;

Specified by:

getMemoryUsed in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The memoryUsed.

setMemoryUsed

public StoreTypes.ExecutorSummary.Builder setMemoryUsed(long value)

int64 memory_used = 5;

Parameters:

value - The memoryUsed to set.

Returns:

This builder for chaining.

clearMemoryUsed

public StoreTypes.ExecutorSummary.Builder clearMemoryUsed()

int64 memory_used = 5;

Returns:

This builder for chaining.

getDiskUsed

public long getDiskUsed()

int64 disk_used = 6;

Specified by:

getDiskUsed in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The diskUsed.

setDiskUsed

public StoreTypes.ExecutorSummary.Builder setDiskUsed(long value)

int64 disk_used = 6;

Parameters:

value - The diskUsed to set.

Returns:

This builder for chaining.

clearDiskUsed

public StoreTypes.ExecutorSummary.Builder clearDiskUsed()

int64 disk_used = 6;

Returns:

This builder for chaining.

getTotalCores

public int getTotalCores()

int32 total_cores = 7;

Specified by:

getTotalCores in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalCores.

setTotalCores

public StoreTypes.ExecutorSummary.Builder setTotalCores(int value)

int32 total_cores = 7;

Parameters:

value - The totalCores to set.

Returns:

This builder for chaining.

clearTotalCores

public StoreTypes.ExecutorSummary.Builder clearTotalCores()

int32 total_cores = 7;

Returns:

This builder for chaining.

getMaxTasks

public int getMaxTasks()

int32 max_tasks = 8;

Specified by:

getMaxTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The maxTasks.

setMaxTasks

public StoreTypes.ExecutorSummary.Builder setMaxTasks(int value)

int32 max_tasks = 8;

Parameters:

value - The maxTasks to set.

Returns:

This builder for chaining.

clearMaxTasks

public StoreTypes.ExecutorSummary.Builder clearMaxTasks()

int32 max_tasks = 8;

Returns:

This builder for chaining.

getActiveTasks

public int getActiveTasks()

int32 active_tasks = 9;

Specified by:

getActiveTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The activeTasks.

setActiveTasks

public StoreTypes.ExecutorSummary.Builder setActiveTasks(int value)

int32 active_tasks = 9;

Parameters:

value - The activeTasks to set.

Returns:

This builder for chaining.

clearActiveTasks

public StoreTypes.ExecutorSummary.Builder clearActiveTasks()

int32 active_tasks = 9;

Returns:

This builder for chaining.

getFailedTasks

public int getFailedTasks()

int32 failed_tasks = 10;

Specified by:

getFailedTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The failedTasks.

setFailedTasks

public StoreTypes.ExecutorSummary.Builder setFailedTasks(int value)

int32 failed_tasks = 10;

Parameters:

value - The failedTasks to set.

Returns:

This builder for chaining.

clearFailedTasks

public StoreTypes.ExecutorSummary.Builder clearFailedTasks()

int32 failed_tasks = 10;

Returns:

This builder for chaining.

getCompletedTasks

public int getCompletedTasks()

int32 completed_tasks = 11;

Specified by:

getCompletedTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The completedTasks.

setCompletedTasks

public StoreTypes.ExecutorSummary.Builder setCompletedTasks(int value)

int32 completed_tasks = 11;

Parameters:

value - The completedTasks to set.

Returns:

This builder for chaining.

clearCompletedTasks

public StoreTypes.ExecutorSummary.Builder clearCompletedTasks()

int32 completed_tasks = 11;

Returns:

This builder for chaining.

getTotalTasks

public int getTotalTasks()

int32 total_tasks = 12;

Specified by:

getTotalTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalTasks.

setTotalTasks

public StoreTypes.ExecutorSummary.Builder setTotalTasks(int value)

int32 total_tasks = 12;

Parameters:

value - The totalTasks to set.

Returns:

This builder for chaining.

clearTotalTasks

public StoreTypes.ExecutorSummary.Builder clearTotalTasks()

int32 total_tasks = 12;

Returns:

This builder for chaining.

getTotalDuration

public long getTotalDuration()

int64 total_duration = 13;

Specified by:

getTotalDuration in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalDuration.

setTotalDuration

public StoreTypes.ExecutorSummary.Builder setTotalDuration(long value)

int64 total_duration = 13;

Parameters:

value - The totalDuration to set.

Returns:

This builder for chaining.

clearTotalDuration

public StoreTypes.ExecutorSummary.Builder clearTotalDuration()

int64 total_duration = 13;

Returns:

This builder for chaining.

getTotalGcTime

public long getTotalGcTime()

int64 total_gc_time = 14;

Specified by:

getTotalGcTime in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalGcTime.

setTotalGcTime

public StoreTypes.ExecutorSummary.Builder setTotalGcTime(long value)

int64 total_gc_time = 14;

Parameters:

value - The totalGcTime to set.

Returns:

This builder for chaining.

clearTotalGcTime

public StoreTypes.ExecutorSummary.Builder clearTotalGcTime()

int64 total_gc_time = 14;

Returns:

This builder for chaining.

getTotalInputBytes

public long getTotalInputBytes()

int64 total_input_bytes = 15;

Specified by:

getTotalInputBytes in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalInputBytes.

setTotalInputBytes

public StoreTypes.ExecutorSummary.Builder setTotalInputBytes(long value)

int64 total_input_bytes = 15;

Parameters:

value - The totalInputBytes to set.

Returns:

This builder for chaining.

clearTotalInputBytes

public StoreTypes.ExecutorSummary.Builder clearTotalInputBytes()

int64 total_input_bytes = 15;

Returns:

This builder for chaining.

getTotalShuffleRead

public long getTotalShuffleRead()

int64 total_shuffle_read = 16;

Specified by:

getTotalShuffleRead in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalShuffleRead.

setTotalShuffleRead

public StoreTypes.ExecutorSummary.Builder setTotalShuffleRead(long value)

int64 total_shuffle_read = 16;

Parameters:

value - The totalShuffleRead to set.

Returns:

This builder for chaining.

clearTotalShuffleRead

public StoreTypes.ExecutorSummary.Builder clearTotalShuffleRead()

int64 total_shuffle_read = 16;

Returns:

This builder for chaining.

getTotalShuffleWrite

public long getTotalShuffleWrite()

int64 total_shuffle_write = 17;

Specified by:

getTotalShuffleWrite in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalShuffleWrite.

setTotalShuffleWrite

public StoreTypes.ExecutorSummary.Builder setTotalShuffleWrite(long value)

int64 total_shuffle_write = 17;

Parameters:

value - The totalShuffleWrite to set.

Returns:

This builder for chaining.

clearTotalShuffleWrite

public StoreTypes.ExecutorSummary.Builder clearTotalShuffleWrite()

int64 total_shuffle_write = 17;

Returns:

This builder for chaining.

getIsBlacklisted

public boolean getIsBlacklisted()

bool is_blacklisted = 18;

Specified by:

getIsBlacklisted in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The isBlacklisted.

setIsBlacklisted

public StoreTypes.ExecutorSummary.Builder setIsBlacklisted(boolean value)

bool is_blacklisted = 18;

Parameters:

value - The isBlacklisted to set.

Returns:

This builder for chaining.

clearIsBlacklisted

public StoreTypes.ExecutorSummary.Builder clearIsBlacklisted()

bool is_blacklisted = 18;

Returns:

This builder for chaining.

getMaxMemory

public long getMaxMemory()

int64 max_memory = 19;

Specified by:

getMaxMemory in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The maxMemory.

setMaxMemory

public StoreTypes.ExecutorSummary.Builder setMaxMemory(long value)

int64 max_memory = 19;

Parameters:

value - The maxMemory to set.

Returns:

This builder for chaining.

clearMaxMemory

public StoreTypes.ExecutorSummary.Builder clearMaxMemory()

int64 max_memory = 19;

Returns:

This builder for chaining.

getAddTime

public long getAddTime()

int64 add_time = 20;

Specified by:

getAddTime in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The addTime.

setAddTime

public StoreTypes.ExecutorSummary.Builder setAddTime(long value)

int64 add_time = 20;

Parameters:

value - The addTime to set.

Returns:

This builder for chaining.

clearAddTime

public StoreTypes.ExecutorSummary.Builder clearAddTime()

int64 add_time = 20;

Returns:

This builder for chaining.

hasRemoveTime

public boolean hasRemoveTime()

optional int64 remove_time = 21;

Specified by:

hasRemoveTime in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

Whether the removeTime field is set.

getRemoveTime

public long getRemoveTime()

optional int64 remove_time = 21;

Specified by:

getRemoveTime in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The removeTime.

setRemoveTime

public StoreTypes.ExecutorSummary.Builder setRemoveTime(long value)

optional int64 remove_time = 21;

Parameters:

value - The removeTime to set.

Returns:

This builder for chaining.

clearRemoveTime

public StoreTypes.ExecutorSummary.Builder clearRemoveTime()

optional int64 remove_time = 21;

Returns:

This builder for chaining.

hasRemoveReason

public boolean hasRemoveReason()

optional string remove_reason = 22;

Specified by:

hasRemoveReason in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

Whether the removeReason field is set.

getRemoveReason

public String getRemoveReason()

optional string remove_reason = 22;

Specified by:

getRemoveReason in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The removeReason.

getRemoveReasonBytes

public com.google.protobuf.ByteString getRemoveReasonBytes()

optional string remove_reason = 22;

Specified by:

getRemoveReasonBytes in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The bytes for removeReason.

setRemoveReason

public StoreTypes.ExecutorSummary.Builder setRemoveReason(String value)

optional string remove_reason = 22;

Parameters:

value - The removeReason to set.

Returns:

This builder for chaining.

clearRemoveReason

public StoreTypes.ExecutorSummary.Builder 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 interface StoreTypes.ExecutorSummaryOrBuilder

containsExecutorLogs

public boolean containsExecutorLogs(String key)

map<string, string> executor_logs = 23;

Specified by:

containsExecutorLogs in interface StoreTypes.ExecutorSummaryOrBuilder

getExecutorLogs

@Deprecated
public Map<String,String> getExecutorLogs()

Deprecated.

Use getExecutorLogsMap() instead.

Specified by:

getExecutorLogs in interface StoreTypes.ExecutorSummaryOrBuilder

getExecutorLogsMap

public Map<String,String> getExecutorLogsMap()

map<string, string> executor_logs = 23;

Specified by:

getExecutorLogsMap in interface StoreTypes.ExecutorSummaryOrBuilder

getExecutorLogsOrDefault

public String getExecutorLogsOrDefault(String key,
 String defaultValue)

map<string, string> executor_logs = 23;

Specified by:

getExecutorLogsOrDefault in interface StoreTypes.ExecutorSummaryOrBuilder

getExecutorLogsOrThrow

public String getExecutorLogsOrThrow(String key)

map<string, string> executor_logs = 23;

Specified by:

getExecutorLogsOrThrow in interface StoreTypes.ExecutorSummaryOrBuilder

clearExecutorLogs

public StoreTypes.ExecutorSummary.Builder clearExecutorLogs()

removeExecutorLogs

public StoreTypes.ExecutorSummary.Builder removeExecutorLogs(String key)

map<string, string> executor_logs = 23;

getMutableExecutorLogs

@Deprecated
public Map<String,String> getMutableExecutorLogs()

Deprecated.

Use alternate mutation accessors instead.

putExecutorLogs

public StoreTypes.ExecutorSummary.Builder putExecutorLogs(String key,
 String value)

map<string, string> executor_logs = 23;

putAllExecutorLogs

public StoreTypes.ExecutorSummary.Builder putAllExecutorLogs(Map<String,String> values)

map<string, string> executor_logs = 23;

hasMemoryMetrics

public boolean hasMemoryMetrics()

optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;

Specified by:

hasMemoryMetrics in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

Whether the memoryMetrics field is set.

getMemoryMetrics

public StoreTypes.MemoryMetrics getMemoryMetrics()

optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;

Specified by:

getMemoryMetrics in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The memoryMetrics.

setMemoryMetrics

public StoreTypes.ExecutorSummary.Builder setMemoryMetrics(StoreTypes.MemoryMetrics value)

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

public StoreTypes.ExecutorSummary.Builder mergeMemoryMetrics(StoreTypes.MemoryMetrics value)

optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;

clearMemoryMetrics

public StoreTypes.ExecutorSummary.Builder clearMemoryMetrics()

optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;

getMemoryMetricsBuilder

public StoreTypes.MemoryMetrics.Builder getMemoryMetricsBuilder()

optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;

getMemoryMetricsOrBuilder

public StoreTypes.MemoryMetricsOrBuilder getMemoryMetricsOrBuilder()

optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;

Specified by:

getMemoryMetricsOrBuilder in interface StoreTypes.ExecutorSummaryOrBuilder

getBlacklistedInStagesList

public List<Long> getBlacklistedInStagesList()

repeated int64 blacklisted_in_stages = 25;

Specified by:

getBlacklistedInStagesList in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

A list containing the blacklistedInStages.

getBlacklistedInStagesCount

public int getBlacklistedInStagesCount()

repeated int64 blacklisted_in_stages = 25;

Specified by:

getBlacklistedInStagesCount in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The count of blacklistedInStages.

getBlacklistedInStages

public long getBlacklistedInStages(int index)

repeated int64 blacklisted_in_stages = 25;

Specified by:

getBlacklistedInStages in interface StoreTypes.ExecutorSummaryOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The blacklistedInStages at the given index.

setBlacklistedInStages

public StoreTypes.ExecutorSummary.Builder setBlacklistedInStages(int index,
 long value)

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

public StoreTypes.ExecutorSummary.Builder addBlacklistedInStages(long value)

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

public StoreTypes.ExecutorSummary.Builder 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 interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

Whether the peakMemoryMetrics field is set.

getPeakMemoryMetrics

public StoreTypes.ExecutorMetrics getPeakMemoryMetrics()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;

Specified by:

getPeakMemoryMetrics in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The peakMemoryMetrics.

setPeakMemoryMetrics

public StoreTypes.ExecutorSummary.Builder setPeakMemoryMetrics(StoreTypes.ExecutorMetrics value)

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

public StoreTypes.ExecutorSummary.Builder mergePeakMemoryMetrics(StoreTypes.ExecutorMetrics value)

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;

clearPeakMemoryMetrics

public StoreTypes.ExecutorSummary.Builder clearPeakMemoryMetrics()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;

getPeakMemoryMetricsBuilder

public StoreTypes.ExecutorMetrics.Builder getPeakMemoryMetricsBuilder()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;

getPeakMemoryMetricsOrBuilder

public StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;

Specified by:

getPeakMemoryMetricsOrBuilder in interface StoreTypes.ExecutorSummaryOrBuilder

getAttributesCount

public int getAttributesCount()

Description copied from interface: StoreTypes.ExecutorSummaryOrBuilder

map<string, string> attributes = 27;

Specified by:

getAttributesCount in interface StoreTypes.ExecutorSummaryOrBuilder

containsAttributes

public boolean containsAttributes(String key)

map<string, string> attributes = 27;

Specified by:

containsAttributes in interface StoreTypes.ExecutorSummaryOrBuilder

getAttributes

@Deprecated
public Map<String,String> getAttributes()

Deprecated.

Use getAttributesMap() instead.

Specified by:

getAttributes in interface StoreTypes.ExecutorSummaryOrBuilder

getAttributesMap

public Map<String,String> getAttributesMap()

map<string, string> attributes = 27;

Specified by:

getAttributesMap in interface StoreTypes.ExecutorSummaryOrBuilder

getAttributesOrDefault

public String getAttributesOrDefault(String key,
 String defaultValue)

map<string, string> attributes = 27;

Specified by:

getAttributesOrDefault in interface StoreTypes.ExecutorSummaryOrBuilder

getAttributesOrThrow

public String getAttributesOrThrow(String key)

map<string, string> attributes = 27;

Specified by:

getAttributesOrThrow in interface StoreTypes.ExecutorSummaryOrBuilder

clearAttributes

public StoreTypes.ExecutorSummary.Builder clearAttributes()

removeAttributes

public StoreTypes.ExecutorSummary.Builder removeAttributes(String key)

map<string, string> attributes = 27;

getMutableAttributes

@Deprecated
public Map<String,String> getMutableAttributes()

Deprecated.

Use alternate mutation accessors instead.

putAttributes

public StoreTypes.ExecutorSummary.Builder putAttributes(String key,
 String value)

map<string, string> attributes = 27;

putAllAttributes

public StoreTypes.ExecutorSummary.Builder putAllAttributes(Map<String,String> values)

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 interface StoreTypes.ExecutorSummaryOrBuilder

containsResources

public boolean containsResources(String key)

map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

Specified by:

containsResources in interface StoreTypes.ExecutorSummaryOrBuilder

getResources

@Deprecated
public Map<String,StoreTypes.ResourceInformation> getResources()

Deprecated.

Use getResourcesMap() instead.

Specified by:

getResources in interface StoreTypes.ExecutorSummaryOrBuilder

getResourcesMap

public Map<String,StoreTypes.ResourceInformation> getResourcesMap()

map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

Specified by:

getResourcesMap in interface StoreTypes.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 interface StoreTypes.ExecutorSummaryOrBuilder

getResourcesOrThrow

public StoreTypes.ResourceInformation getResourcesOrThrow(String key)

map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

Specified by:

getResourcesOrThrow in interface StoreTypes.ExecutorSummaryOrBuilder

clearResources

public StoreTypes.ExecutorSummary.Builder clearResources()

removeResources

public StoreTypes.ExecutorSummary.Builder removeResources(String key)

map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

getMutableResources

@Deprecated
public Map<String,StoreTypes.ResourceInformation> 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;

putResourcesBuilderIfAbsent

public StoreTypes.ResourceInformation.Builder putResourcesBuilderIfAbsent(String key)

map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;

getResourceProfileId

public int getResourceProfileId()

int32 resource_profile_id = 29;

Specified by:

getResourceProfileId in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The resourceProfileId.

setResourceProfileId

public StoreTypes.ExecutorSummary.Builder setResourceProfileId(int value)

int32 resource_profile_id = 29;

Parameters:

value - The resourceProfileId to set.

Returns:

This builder for chaining.

clearResourceProfileId

public StoreTypes.ExecutorSummary.Builder clearResourceProfileId()

int32 resource_profile_id = 29;

Returns:

This builder for chaining.

getIsExcluded

public boolean getIsExcluded()

bool is_excluded = 30;

Specified by:

getIsExcluded in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The isExcluded.

setIsExcluded

public StoreTypes.ExecutorSummary.Builder setIsExcluded(boolean value)

bool is_excluded = 30;

Parameters:

value - The isExcluded to set.

Returns:

This builder for chaining.

clearIsExcluded

public StoreTypes.ExecutorSummary.Builder clearIsExcluded()

bool is_excluded = 30;

Returns:

This builder for chaining.

getExcludedInStagesList

public List<Long> getExcludedInStagesList()

repeated int64 excluded_in_stages = 31;

Specified by:

getExcludedInStagesList in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

A list containing the excludedInStages.

getExcludedInStagesCount

public int getExcludedInStagesCount()

repeated int64 excluded_in_stages = 31;

Specified by:

getExcludedInStagesCount in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The count of excludedInStages.

getExcludedInStages

public long getExcludedInStages(int index)

repeated int64 excluded_in_stages = 31;

Specified by:

getExcludedInStages in interface StoreTypes.ExecutorSummaryOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The excludedInStages at the given index.

setExcludedInStages

public StoreTypes.ExecutorSummary.Builder setExcludedInStages(int index,
 long value)

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

public StoreTypes.ExecutorSummary.Builder addExcludedInStages(long value)

repeated int64 excluded_in_stages = 31;

Parameters:

value - The excludedInStages to add.

Returns:

This builder for chaining.

addAllExcludedInStages

public StoreTypes.ExecutorSummary.Builder addAllExcludedInStages(Iterable<? extends Long> values)

repeated int64 excluded_in_stages = 31;

Parameters:

values - The excludedInStages to add.

Returns:

This builder for chaining.

clearExcludedInStages

public StoreTypes.ExecutorSummary.Builder clearExcludedInStages()

repeated int64 excluded_in_stages = 31;

Returns:

This builder for chaining.