Package org.apache.spark.status.protobuf

Class StoreTypes.ExecutorSummary

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessageV3

org.apache.spark.status.protobuf.StoreTypes.ExecutorSummary

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable, StoreTypes.ExecutorSummaryOrBuilder

Enclosing class:

StoreTypes

public static final class StoreTypes.ExecutorSummary
extends com.google.protobuf.GeneratedMessageV3
implements StoreTypes.ExecutorSummaryOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	StoreTypes.ExecutorSummary.Builder	Protobuf type org.apache.spark.status.protobuf.ExecutorSummary

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3

com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ACTIVE_TASKS_FIELD_NUMBER
static final int	ADD_TIME_FIELD_NUMBER
static final int	ATTRIBUTES_FIELD_NUMBER
static final int	BLACKLISTED_IN_STAGES_FIELD_NUMBER
static final int	COMPLETED_TASKS_FIELD_NUMBER
static final int	DISK_USED_FIELD_NUMBER
static final int	EXCLUDED_IN_STAGES_FIELD_NUMBER
static final int	EXECUTOR_LOGS_FIELD_NUMBER
static final int	FAILED_TASKS_FIELD_NUMBER
static final int	HOST_PORT_FIELD_NUMBER
static final int	ID_FIELD_NUMBER
static final int	IS_ACTIVE_FIELD_NUMBER
static final int	IS_BLACKLISTED_FIELD_NUMBER
static final int	IS_EXCLUDED_FIELD_NUMBER
static final int	MAX_MEMORY_FIELD_NUMBER
static final int	MAX_TASKS_FIELD_NUMBER
static final int	MEMORY_METRICS_FIELD_NUMBER
static final int	MEMORY_USED_FIELD_NUMBER
static final int	PEAK_MEMORY_METRICS_FIELD_NUMBER
static final int	RDD_BLOCKS_FIELD_NUMBER
static final int	REMOVE_REASON_FIELD_NUMBER
static final int	REMOVE_TIME_FIELD_NUMBER
static final int	RESOURCE_PROFILE_ID_FIELD_NUMBER
static final int	RESOURCES_FIELD_NUMBER
static final int	TOTAL_CORES_FIELD_NUMBER
static final int	TOTAL_DURATION_FIELD_NUMBER
static final int	TOTAL_GC_TIME_FIELD_NUMBER
static final int	TOTAL_INPUT_BYTES_FIELD_NUMBER
static final int	TOTAL_SHUFFLE_READ_FIELD_NUMBER
static final int	TOTAL_SHUFFLE_WRITE_FIELD_NUMBER
static final int	TOTAL_TASKS_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	containsAttributes(String key)	map<string, string> attributes = 27;
boolean	containsExecutorLogs(String key)	map<string, string> executor_logs = 23;
boolean	containsResources(String key)	map<string, .org.apache.spark.status.protobuf.ResourceInformation> resources = 28;
boolean	equals(Object obj)
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;
static StoreTypes.ExecutorSummary	getDefaultInstance()
StoreTypes.ExecutorSummary	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
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.MemoryMetricsOrBuilder	getMemoryMetricsOrBuilder()	optional .org.apache.spark.status.protobuf.MemoryMetrics memory_metrics = 24;
long	getMemoryUsed()	int64 memory_used = 5;
com.google.protobuf.Parser<StoreTypes.ExecutorSummary>	getParserForType()
StoreTypes.ExecutorMetrics	getPeakMemoryMetrics()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
StoreTypes.ExecutorMetricsOrBuilder	getPeakMemoryMetricsOrBuilder()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 26;
int	getRddBlocks()	int32 rdd_blocks = 4;
String	getRemoveReason()	optional string remove_reason = 22;
com.google.protobuf.ByteString	getRemoveReasonBytes()	optional string remove_reason = 22;
long	getRemoveTime()	optional int64 remove_time = 21;
int	getResourceProfileId()	int32 resource_profile_id = 29;
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	getSerializedSize()
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;
int	hashCode()
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()
static StoreTypes.ExecutorSummary.Builder	newBuilder()
static StoreTypes.ExecutorSummary.Builder	newBuilder(StoreTypes.ExecutorSummary prototype)
StoreTypes.ExecutorSummary.Builder	newBuilderForType()
static StoreTypes.ExecutorSummary	parseDelimitedFrom(InputStream input)
static StoreTypes.ExecutorSummary	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorSummary	parseFrom(byte[] data)
static StoreTypes.ExecutorSummary	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorSummary	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.ExecutorSummary	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorSummary	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.ExecutorSummary	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorSummary	parseFrom(InputStream input)
static StoreTypes.ExecutorSummary	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorSummary	parseFrom(ByteBuffer data)
static StoreTypes.ExecutorSummary	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.ExecutorSummary>	parser()
StoreTypes.ExecutorSummary.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessageV3

getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Field Details

ID_FIELD_NUMBER

public static final int ID_FIELD_NUMBER

See Also:

• Constant Field Values

HOST_PORT_FIELD_NUMBER

public static final int HOST_PORT_FIELD_NUMBER

See Also:

• Constant Field Values

IS_ACTIVE_FIELD_NUMBER

public static final int IS_ACTIVE_FIELD_NUMBER

See Also:

• Constant Field Values

RDD_BLOCKS_FIELD_NUMBER

public static final int RDD_BLOCKS_FIELD_NUMBER

See Also:

• Constant Field Values

MEMORY_USED_FIELD_NUMBER

public static final int MEMORY_USED_FIELD_NUMBER

See Also:

• Constant Field Values

DISK_USED_FIELD_NUMBER

public static final int DISK_USED_FIELD_NUMBER

See Also:

• Constant Field Values

TOTAL_CORES_FIELD_NUMBER

public static final int TOTAL_CORES_FIELD_NUMBER

See Also:

• Constant Field Values

MAX_TASKS_FIELD_NUMBER

public static final int MAX_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

ACTIVE_TASKS_FIELD_NUMBER

public static final int ACTIVE_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

FAILED_TASKS_FIELD_NUMBER

public static final int FAILED_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

COMPLETED_TASKS_FIELD_NUMBER

public static final int COMPLETED_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

TOTAL_TASKS_FIELD_NUMBER

public static final int TOTAL_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

TOTAL_DURATION_FIELD_NUMBER

public static final int TOTAL_DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

TOTAL_GC_TIME_FIELD_NUMBER

public static final int TOTAL_GC_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

TOTAL_INPUT_BYTES_FIELD_NUMBER

public static final int TOTAL_INPUT_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

TOTAL_SHUFFLE_READ_FIELD_NUMBER

public static final int TOTAL_SHUFFLE_READ_FIELD_NUMBER

See Also:

• Constant Field Values

TOTAL_SHUFFLE_WRITE_FIELD_NUMBER

public static final int TOTAL_SHUFFLE_WRITE_FIELD_NUMBER

See Also:

• Constant Field Values

IS_BLACKLISTED_FIELD_NUMBER

public static final int IS_BLACKLISTED_FIELD_NUMBER

See Also:

• Constant Field Values

MAX_MEMORY_FIELD_NUMBER

public static final int MAX_MEMORY_FIELD_NUMBER

See Also:

• Constant Field Values

ADD_TIME_FIELD_NUMBER

public static final int ADD_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

REMOVE_TIME_FIELD_NUMBER

public static final int REMOVE_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

REMOVE_REASON_FIELD_NUMBER

public static final int REMOVE_REASON_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_LOGS_FIELD_NUMBER

public static final int EXECUTOR_LOGS_FIELD_NUMBER

See Also:

• Constant Field Values

MEMORY_METRICS_FIELD_NUMBER

public static final int MEMORY_METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

BLACKLISTED_IN_STAGES_FIELD_NUMBER

public static final int BLACKLISTED_IN_STAGES_FIELD_NUMBER

See Also:

• Constant Field Values

PEAK_MEMORY_METRICS_FIELD_NUMBER

public static final int PEAK_MEMORY_METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

ATTRIBUTES_FIELD_NUMBER

public static final int ATTRIBUTES_FIELD_NUMBER

See Also:

• Constant Field Values

RESOURCES_FIELD_NUMBER

public static final int RESOURCES_FIELD_NUMBER

See Also:

• Constant Field Values

RESOURCE_PROFILE_ID_FIELD_NUMBER

public static final int RESOURCE_PROFILE_ID_FIELD_NUMBER

See Also:

• Constant Field Values

IS_EXCLUDED_FIELD_NUMBER

public static final int IS_EXCLUDED_FIELD_NUMBER

See Also:

• Constant Field Values

EXCLUDED_IN_STAGES_FIELD_NUMBER

public static final int EXCLUDED_IN_STAGES_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

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.

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.

getIsActive

public boolean getIsActive()

bool is_active = 3;

Specified by:

getIsActive in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The isActive.

getRddBlocks

public int getRddBlocks()

int32 rdd_blocks = 4;

Specified by:

getRddBlocks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The rddBlocks.

getMemoryUsed

public long getMemoryUsed()

int64 memory_used = 5;

Specified by:

getMemoryUsed in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The memoryUsed.

getDiskUsed

public long getDiskUsed()

int64 disk_used = 6;

Specified by:

getDiskUsed in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The diskUsed.

getTotalCores

public int getTotalCores()

int32 total_cores = 7;

Specified by:

getTotalCores in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalCores.

getMaxTasks

public int getMaxTasks()

int32 max_tasks = 8;

Specified by:

getMaxTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The maxTasks.

getActiveTasks

public int getActiveTasks()

int32 active_tasks = 9;

Specified by:

getActiveTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The activeTasks.

getFailedTasks

public int getFailedTasks()

int32 failed_tasks = 10;

Specified by:

getFailedTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The failedTasks.

getCompletedTasks

public int getCompletedTasks()

int32 completed_tasks = 11;

Specified by:

getCompletedTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The completedTasks.

getTotalTasks

public int getTotalTasks()

int32 total_tasks = 12;

Specified by:

getTotalTasks in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalTasks.

getTotalDuration

public long getTotalDuration()

int64 total_duration = 13;

Specified by:

getTotalDuration in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalDuration.

getTotalGcTime

public long getTotalGcTime()

int64 total_gc_time = 14;

Specified by:

getTotalGcTime in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalGcTime.

getTotalInputBytes

public long getTotalInputBytes()

int64 total_input_bytes = 15;

Specified by:

getTotalInputBytes in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalInputBytes.

getTotalShuffleRead

public long getTotalShuffleRead()

int64 total_shuffle_read = 16;

Specified by:

getTotalShuffleRead in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalShuffleRead.

getTotalShuffleWrite

public long getTotalShuffleWrite()

int64 total_shuffle_write = 17;

Specified by:

getTotalShuffleWrite in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The totalShuffleWrite.

getIsBlacklisted

public boolean getIsBlacklisted()

bool is_blacklisted = 18;

Specified by:

getIsBlacklisted in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The isBlacklisted.

getMaxMemory

public long getMaxMemory()

int64 max_memory = 19;

Specified by:

getMaxMemory in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The maxMemory.

getAddTime

public long getAddTime()

int64 add_time = 20;

Specified by:

getAddTime in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The addTime.

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.

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.

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

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.

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.

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.

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

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

getResourceProfileId

public int getResourceProfileId()

int32 resource_profile_id = 29;

Specified by:

getResourceProfileId in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The resourceProfileId.

getIsExcluded

public boolean getIsExcluded()

bool is_excluded = 30;

Specified by:

getIsExcluded in interface StoreTypes.ExecutorSummaryOrBuilder

Returns:

The isExcluded.

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.

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessageV3

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.GeneratedMessageV3

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessageV3

equals

public boolean equals(Object obj)

Specified by:

equals in interface com.google.protobuf.Message

Overrides:

equals in class com.google.protobuf.AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface com.google.protobuf.Message

Overrides:

hashCode in class com.google.protobuf.AbstractMessage

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(ByteBuffer data)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(ByteBuffer data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(com.google.protobuf.ByteString data)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(com.google.protobuf.ByteString data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(byte[] data)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(byte[] data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(InputStream input)
                                            throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.ExecutorSummary parseDelimitedFrom(InputStream input)
                                                     throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.ExecutorSummary parseDelimitedFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                     throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(com.google.protobuf.CodedInputStream input)
                                            throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.ExecutorSummary parseFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                            throws IOException

Throws:

IOException

newBuilderForType

public StoreTypes.ExecutorSummary.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.ExecutorSummary.Builder newBuilder()

newBuilder

public static StoreTypes.ExecutorSummary.Builder newBuilder(StoreTypes.ExecutorSummary prototype)

toBuilder

public StoreTypes.ExecutorSummary.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.ExecutorSummary getDefaultInstance()

parser

public static com.google.protobuf.Parser<StoreTypes.ExecutorSummary> parser()

getParserForType

public com.google.protobuf.Parser<StoreTypes.ExecutorSummary> getParserForType()

Specified by:

getParserForType in interface com.google.protobuf.Message

Specified by:

getParserForType in interface com.google.protobuf.MessageLite

Overrides:

getParserForType in class com.google.protobuf.GeneratedMessageV3

getDefaultInstanceForType

public StoreTypes.ExecutorSummary getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder