Package org.apache.spark.status.protobuf

Class StoreTypes.StageData

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

org.apache.spark.status.protobuf.StoreTypes.StageData

All Implemented Interfaces:

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

Enclosing class:

StoreTypes

public static final class StoreTypes.StageData
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.StageDataOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

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

com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ACCUMULATOR_UPDATES_FIELD_NUMBER
static final int	ATTEMPT_ID_FIELD_NUMBER
static final int	COMPLETION_TIME_FIELD_NUMBER
static final int	DESCRIPTION_FIELD_NUMBER
static final int	DETAILS_FIELD_NUMBER
static final int	DISK_BYTES_SPILLED_FIELD_NUMBER
static final int	EXECUTOR_CPU_TIME_FIELD_NUMBER
static final int	EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER
static final int	EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER
static final int	EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER
static final int	EXECUTOR_RUN_TIME_FIELD_NUMBER
static final int	EXECUTOR_SUMMARY_FIELD_NUMBER
static final int	FAILURE_REASON_FIELD_NUMBER
static final int	FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER
static final int	INPUT_BYTES_FIELD_NUMBER
static final int	INPUT_RECORDS_FIELD_NUMBER
static final int	IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER
static final int	JVM_GC_TIME_FIELD_NUMBER
static final int	KILLED_TASKS_SUMMARY_FIELD_NUMBER
static final int	MEMORY_BYTES_SPILLED_FIELD_NUMBER
static final int	NAME_FIELD_NUMBER
static final int	NUM_ACTIVE_TASKS_FIELD_NUMBER
static final int	NUM_COMPLETE_TASKS_FIELD_NUMBER
static final int	NUM_COMPLETED_INDICES_FIELD_NUMBER
static final int	NUM_FAILED_TASKS_FIELD_NUMBER
static final int	NUM_KILLED_TASKS_FIELD_NUMBER
static final int	NUM_TASKS_FIELD_NUMBER
static final int	OUTPUT_BYTES_FIELD_NUMBER
static final int	OUTPUT_RECORDS_FIELD_NUMBER
static final int	PEAK_EXECUTION_MEMORY_FIELD_NUMBER
static final int	PEAK_EXECUTOR_METRICS_FIELD_NUMBER
static final int	RDD_IDS_FIELD_NUMBER
static final int	RESOURCE_PROFILE_ID_FIELD_NUMBER
static final int	RESULT_SERIALIZATION_TIME_FIELD_NUMBER
static final int	RESULT_SIZE_FIELD_NUMBER
static final int	SCHEDULING_POOL_FIELD_NUMBER
static final int	SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER
static final int	SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER
static final int	SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER
static final int	SHUFFLE_MERGERS_COUNT_FIELD_NUMBER
static final int	SHUFFLE_READ_BYTES_FIELD_NUMBER
static final int	SHUFFLE_READ_RECORDS_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER
static final int	SHUFFLE_WRITE_BYTES_FIELD_NUMBER
static final int	SHUFFLE_WRITE_RECORDS_FIELD_NUMBER
static final int	SHUFFLE_WRITE_TIME_FIELD_NUMBER
static final int	SPECULATION_SUMMARY_FIELD_NUMBER
static final int	STAGE_ID_FIELD_NUMBER
static final int	STATUS_FIELD_NUMBER
static final int	SUBMISSION_TIME_FIELD_NUMBER
static final int	TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER
static final int	TASKS_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	containsExecutorSummary(String key)	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
boolean	containsKilledTasksSummary(String key)	map<string, int32> killed_tasks_summary = 48;
boolean	containsTasks(long key)	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
boolean	equals(Object obj)
StoreTypes.AccumulableInfo	getAccumulatorUpdates(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
int	getAccumulatorUpdatesCount()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
List<StoreTypes.AccumulableInfo>	getAccumulatorUpdatesList()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.AccumulableInfoOrBuilder	getAccumulatorUpdatesOrBuilder(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
List<? extends StoreTypes.AccumulableInfoOrBuilder>	getAccumulatorUpdatesOrBuilderList()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
int	getAttemptId()	int32 attempt_id = 3;
long	getCompletionTime()	optional int64 completion_time = 12;
static StoreTypes.StageData	getDefaultInstance()
StoreTypes.StageData	getDefaultInstanceForType()
String	getDescription()	optional string description = 40;
com.google.protobuf.ByteString	getDescriptionBytes()	optional string description = 40;
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
String	getDetails()	optional string details = 41;
com.google.protobuf.ByteString	getDetailsBytes()	optional string details = 41;
long	getDiskBytesSpilled()	int64 disk_bytes_spilled = 22;
long	getExecutorCpuTime()	int64 executor_cpu_time = 17;
long	getExecutorDeserializeCpuTime()	int64 executor_deserialize_cpu_time = 15;
long	getExecutorDeserializeTime()	int64 executor_deserialize_time = 14;
StoreTypes.ExecutorMetricsDistributions	getExecutorMetricsDistributions()	optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
StoreTypes.ExecutorMetricsDistributionsOrBuilder	getExecutorMetricsDistributionsOrBuilder()	optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
long	getExecutorRunTime()	int64 executor_run_time = 16;
Map<String,StoreTypes.ExecutorStageSummary>	getExecutorSummary()	Deprecated.
int	getExecutorSummaryCount()	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
Map<String,StoreTypes.ExecutorStageSummary>	getExecutorSummaryMap()	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
StoreTypes.ExecutorStageSummary	getExecutorSummaryOrDefault(String key, StoreTypes.ExecutorStageSummary defaultValue)	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
StoreTypes.ExecutorStageSummary	getExecutorSummaryOrThrow(String key)	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
String	getFailureReason()	optional string failure_reason = 13;
com.google.protobuf.ByteString	getFailureReasonBytes()	optional string failure_reason = 13;
long	getFirstTaskLaunchedTime()	optional int64 first_task_launched_time = 11;
long	getInputBytes()	int64 input_bytes = 24;
long	getInputRecords()	int64 input_records = 25;
boolean	getIsShufflePushEnabled()	bool is_shuffle_push_enabled = 63;
long	getJvmGcTime()	int64 jvm_gc_time = 19;
Map<String,Integer>	getKilledTasksSummary()	Deprecated.
int	getKilledTasksSummaryCount()	map<string, int32> killed_tasks_summary = 48;
Map<String,Integer>	getKilledTasksSummaryMap()	map<string, int32> killed_tasks_summary = 48;
int	getKilledTasksSummaryOrDefault(String key, int defaultValue)	map<string, int32> killed_tasks_summary = 48;
int	getKilledTasksSummaryOrThrow(String key)	map<string, int32> killed_tasks_summary = 48;
long	getMemoryBytesSpilled()	int64 memory_bytes_spilled = 21;
String	getName()	optional string name = 39;
com.google.protobuf.ByteString	getNameBytes()	optional string name = 39;
int	getNumActiveTasks()	int32 num_active_tasks = 5;
int	getNumCompletedIndices()	int32 num_completed_indices = 9;
int	getNumCompleteTasks()	int32 num_complete_tasks = 6;
int	getNumFailedTasks()	int32 num_failed_tasks = 7;
int	getNumKilledTasks()	int32 num_killed_tasks = 8;
int	getNumTasks()	int32 num_tasks = 4;
long	getOutputBytes()	int64 output_bytes = 26;
long	getOutputRecords()	int64 output_records = 27;
com.google.protobuf.Parser<StoreTypes.StageData>	getParserForType()
long	getPeakExecutionMemory()	int64 peak_execution_memory = 23;
StoreTypes.ExecutorMetrics	getPeakExecutorMetrics()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
StoreTypes.ExecutorMetricsOrBuilder	getPeakExecutorMetricsOrBuilder()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
long	getRddIds(int index)	repeated int64 rdd_ids = 43;
int	getRddIdsCount()	repeated int64 rdd_ids = 43;
List<Long>	getRddIdsList()	repeated int64 rdd_ids = 43;
int	getResourceProfileId()	int32 resource_profile_id = 49;
long	getResultSerializationTime()	int64 result_serialization_time = 20;
long	getResultSize()	int64 result_size = 18;
String	getSchedulingPool()	optional string scheduling_pool = 42;
com.google.protobuf.ByteString	getSchedulingPoolBytes()	optional string scheduling_pool = 42;
int	getSerializedSize()
long	getShuffleCorruptMergedBlockChunks()	int64 shuffle_corrupt_merged_block_chunks = 53;
long	getShuffleFetchWaitTime()	int64 shuffle_fetch_wait_time = 30;
long	getShuffleLocalBlocksFetched()	int64 shuffle_local_blocks_fetched = 29;
long	getShuffleLocalBytesRead()	int64 shuffle_local_bytes_read = 33;
long	getShuffleMergedFetchFallbackCount()	int64 shuffle_merged_fetch_fallback_count = 54;
long	getShuffleMergedLocalBlocksFetched()	int64 shuffle_merged_local_blocks_fetched = 56;
long	getShuffleMergedLocalBytesRead()	int64 shuffle_merged_local_bytes_read = 60;
long	getShuffleMergedLocalChunksFetched()	int64 shuffle_merged_local_chunks_fetched = 58;
long	getShuffleMergedRemoteBlocksFetched()	int64 shuffle_merged_remote_blocks_fetched = 55;
long	getShuffleMergedRemoteBytesRead()	int64 shuffle_merged_remote_bytes_read = 59;
long	getShuffleMergedRemoteChunksFetched()	int64 shuffle_merged_remote_chunks_fetched = 57;
long	getShuffleMergedRemoteReqsDuration()	int64 shuffle_merged_remote_reqs_duration = 62;
int	getShuffleMergersCount()	int32 shuffle_mergers_count = 64;
long	getShuffleReadBytes()	int64 shuffle_read_bytes = 34;
long	getShuffleReadRecords()	int64 shuffle_read_records = 35;
long	getShuffleRemoteBlocksFetched()	int64 shuffle_remote_blocks_fetched = 28;
long	getShuffleRemoteBytesRead()	int64 shuffle_remote_bytes_read = 31;
long	getShuffleRemoteBytesReadToDisk()	int64 shuffle_remote_bytes_read_to_disk = 32;
long	getShuffleRemoteReqsDuration()	int64 shuffle_remote_reqs_duration = 61;
long	getShuffleWriteBytes()	int64 shuffle_write_bytes = 36;
long	getShuffleWriteRecords()	int64 shuffle_write_records = 38;
long	getShuffleWriteTime()	int64 shuffle_write_time = 37;
StoreTypes.SpeculationStageSummary	getSpeculationSummary()	optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
StoreTypes.SpeculationStageSummaryOrBuilder	getSpeculationSummaryOrBuilder()	optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
long	getStageId()	int64 stage_id = 2;
StoreTypes.StageStatus	getStatus()	.org.apache.spark.status.protobuf.StageStatus status = 1;
int	getStatusValue()	.org.apache.spark.status.protobuf.StageStatus status = 1;
long	getSubmissionTime()	optional int64 submission_time = 10;
StoreTypes.TaskMetricDistributions	getTaskMetricsDistributions()	optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
StoreTypes.TaskMetricDistributionsOrBuilder	getTaskMetricsDistributionsOrBuilder()	optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
Map<Long,StoreTypes.TaskData>	getTasks()	Deprecated.
int	getTasksCount()	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
Map<Long,StoreTypes.TaskData>	getTasksMap()	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
StoreTypes.TaskData	getTasksOrDefault(long key, StoreTypes.TaskData defaultValue)	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
StoreTypes.TaskData	getTasksOrThrow(long key)	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
boolean	hasCompletionTime()	optional int64 completion_time = 12;
boolean	hasDescription()	optional string description = 40;
boolean	hasDetails()	optional string details = 41;
boolean	hasExecutorMetricsDistributions()	optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
boolean	hasFailureReason()	optional string failure_reason = 13;
boolean	hasFirstTaskLaunchedTime()	optional int64 first_task_launched_time = 11;
int	hashCode()
boolean	hasName()	optional string name = 39;
boolean	hasPeakExecutorMetrics()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
boolean	hasSchedulingPool()	optional string scheduling_pool = 42;
boolean	hasSpeculationSummary()	optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
boolean	hasSubmissionTime()	optional int64 submission_time = 10;
boolean	hasTaskMetricsDistributions()	optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
final boolean	isInitialized()
static StoreTypes.StageData.Builder	newBuilder()
static StoreTypes.StageData.Builder	newBuilder(StoreTypes.StageData prototype)
StoreTypes.StageData.Builder	newBuilderForType()
static StoreTypes.StageData	parseDelimitedFrom(InputStream input)
static StoreTypes.StageData	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.StageData	parseFrom(byte[] data)
static StoreTypes.StageData	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.StageData	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.StageData	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.StageData	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.StageData	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.StageData	parseFrom(InputStream input)
static StoreTypes.StageData	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.StageData	parseFrom(ByteBuffer data)
static StoreTypes.StageData	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.StageData>	parser()
StoreTypes.StageData.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessage

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

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

STATUS_FIELD_NUMBER

public static final int STATUS_FIELD_NUMBER

See Also:

• Constant Field Values

STAGE_ID_FIELD_NUMBER

public static final int STAGE_ID_FIELD_NUMBER

See Also:

• Constant Field Values

ATTEMPT_ID_FIELD_NUMBER

public static final int ATTEMPT_ID_FIELD_NUMBER

See Also:

• Constant Field Values

NUM_TASKS_FIELD_NUMBER

public static final int NUM_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

NUM_ACTIVE_TASKS_FIELD_NUMBER

public static final int NUM_ACTIVE_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

NUM_COMPLETE_TASKS_FIELD_NUMBER

public static final int NUM_COMPLETE_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

NUM_FAILED_TASKS_FIELD_NUMBER

public static final int NUM_FAILED_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

NUM_KILLED_TASKS_FIELD_NUMBER

public static final int NUM_KILLED_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

NUM_COMPLETED_INDICES_FIELD_NUMBER

public static final int NUM_COMPLETED_INDICES_FIELD_NUMBER

See Also:

• Constant Field Values

SUBMISSION_TIME_FIELD_NUMBER

public static final int SUBMISSION_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER

public static final int FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

COMPLETION_TIME_FIELD_NUMBER

public static final int COMPLETION_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

FAILURE_REASON_FIELD_NUMBER

public static final int FAILURE_REASON_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

public static final int EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

public static final int EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_RUN_TIME_FIELD_NUMBER

public static final int EXECUTOR_RUN_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_CPU_TIME_FIELD_NUMBER

public static final int EXECUTOR_CPU_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

RESULT_SIZE_FIELD_NUMBER

public static final int RESULT_SIZE_FIELD_NUMBER

See Also:

• Constant Field Values

JVM_GC_TIME_FIELD_NUMBER

public static final int JVM_GC_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

RESULT_SERIALIZATION_TIME_FIELD_NUMBER

public static final int RESULT_SERIALIZATION_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

MEMORY_BYTES_SPILLED_FIELD_NUMBER

public static final int MEMORY_BYTES_SPILLED_FIELD_NUMBER

See Also:

• Constant Field Values

DISK_BYTES_SPILLED_FIELD_NUMBER

public static final int DISK_BYTES_SPILLED_FIELD_NUMBER

See Also:

• Constant Field Values

PEAK_EXECUTION_MEMORY_FIELD_NUMBER

public static final int PEAK_EXECUTION_MEMORY_FIELD_NUMBER

See Also:

• Constant Field Values

INPUT_BYTES_FIELD_NUMBER

public static final int INPUT_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

INPUT_RECORDS_FIELD_NUMBER

public static final int INPUT_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

OUTPUT_BYTES_FIELD_NUMBER

public static final int OUTPUT_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

OUTPUT_RECORDS_FIELD_NUMBER

public static final int OUTPUT_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

public static final int SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_READ_BYTES_FIELD_NUMBER

public static final int SHUFFLE_READ_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_READ_RECORDS_FIELD_NUMBER

public static final int SHUFFLE_READ_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_BYTES_FIELD_NUMBER

public static final int SHUFFLE_WRITE_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_TIME_FIELD_NUMBER

public static final int SHUFFLE_WRITE_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_RECORDS_FIELD_NUMBER

public static final int SHUFFLE_WRITE_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

NAME_FIELD_NUMBER

public static final int NAME_FIELD_NUMBER

See Also:

• Constant Field Values

DESCRIPTION_FIELD_NUMBER

public static final int DESCRIPTION_FIELD_NUMBER

See Also:

• Constant Field Values

DETAILS_FIELD_NUMBER

public static final int DETAILS_FIELD_NUMBER

See Also:

• Constant Field Values

SCHEDULING_POOL_FIELD_NUMBER

public static final int SCHEDULING_POOL_FIELD_NUMBER

See Also:

• Constant Field Values

RDD_IDS_FIELD_NUMBER

public static final int RDD_IDS_FIELD_NUMBER

See Also:

• Constant Field Values

ACCUMULATOR_UPDATES_FIELD_NUMBER

public static final int ACCUMULATOR_UPDATES_FIELD_NUMBER

See Also:

• Constant Field Values

TASKS_FIELD_NUMBER

public static final int TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_SUMMARY_FIELD_NUMBER

public static final int EXECUTOR_SUMMARY_FIELD_NUMBER

See Also:

• Constant Field Values

SPECULATION_SUMMARY_FIELD_NUMBER

public static final int SPECULATION_SUMMARY_FIELD_NUMBER

See Also:

• Constant Field Values

KILLED_TASKS_SUMMARY_FIELD_NUMBER

public static final int KILLED_TASKS_SUMMARY_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

PEAK_EXECUTOR_METRICS_FIELD_NUMBER

public static final int PEAK_EXECUTOR_METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER

public static final int TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER

public static final int EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

public static final int SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

public static final int SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER

public static final int IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGERS_COUNT_FIELD_NUMBER

public static final int SHUFFLE_MERGERS_COUNT_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

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

getStatusValue

public int getStatusValue()

.org.apache.spark.status.protobuf.StageStatus status = 1;

Specified by:

getStatusValue in interface StoreTypes.StageDataOrBuilder

Returns:

The enum numeric value on the wire for status.

getStatus

public StoreTypes.StageStatus getStatus()

.org.apache.spark.status.protobuf.StageStatus status = 1;

Specified by:

getStatus in interface StoreTypes.StageDataOrBuilder

Returns:

The status.

getStageId

public long getStageId()

int64 stage_id = 2;

Specified by:

getStageId in interface StoreTypes.StageDataOrBuilder

Returns:

The stageId.

getAttemptId

public int getAttemptId()

int32 attempt_id = 3;

Specified by:

getAttemptId in interface StoreTypes.StageDataOrBuilder

Returns:

The attemptId.

getNumTasks

public int getNumTasks()

int32 num_tasks = 4;

Specified by:

getNumTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numTasks.

getNumActiveTasks

public int getNumActiveTasks()

int32 num_active_tasks = 5;

Specified by:

getNumActiveTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numActiveTasks.

getNumCompleteTasks

public int getNumCompleteTasks()

int32 num_complete_tasks = 6;

Specified by:

getNumCompleteTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numCompleteTasks.

getNumFailedTasks

public int getNumFailedTasks()

int32 num_failed_tasks = 7;

Specified by:

getNumFailedTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numFailedTasks.

getNumKilledTasks

public int getNumKilledTasks()

int32 num_killed_tasks = 8;

Specified by:

getNumKilledTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numKilledTasks.

getNumCompletedIndices

public int getNumCompletedIndices()

int32 num_completed_indices = 9;

Specified by:

getNumCompletedIndices in interface StoreTypes.StageDataOrBuilder

Returns:

The numCompletedIndices.

hasSubmissionTime

public boolean hasSubmissionTime()

optional int64 submission_time = 10;

Specified by:

hasSubmissionTime in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the submissionTime field is set.

getSubmissionTime

public long getSubmissionTime()

optional int64 submission_time = 10;

Specified by:

getSubmissionTime in interface StoreTypes.StageDataOrBuilder

Returns:

The submissionTime.

hasFirstTaskLaunchedTime

public boolean hasFirstTaskLaunchedTime()

optional int64 first_task_launched_time = 11;

Specified by:

hasFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the firstTaskLaunchedTime field is set.

getFirstTaskLaunchedTime

public long getFirstTaskLaunchedTime()

optional int64 first_task_launched_time = 11;

Specified by:

getFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilder

Returns:

The firstTaskLaunchedTime.

hasCompletionTime

public boolean hasCompletionTime()

optional int64 completion_time = 12;

Specified by:

hasCompletionTime in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the completionTime field is set.

getCompletionTime

public long getCompletionTime()

optional int64 completion_time = 12;

Specified by:

getCompletionTime in interface StoreTypes.StageDataOrBuilder

Returns:

The completionTime.

hasFailureReason

public boolean hasFailureReason()

optional string failure_reason = 13;

Specified by:

hasFailureReason in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the failureReason field is set.

getFailureReason

public String getFailureReason()

optional string failure_reason = 13;

Specified by:

getFailureReason in interface StoreTypes.StageDataOrBuilder

Returns:

The failureReason.

getFailureReasonBytes

public com.google.protobuf.ByteString getFailureReasonBytes()

optional string failure_reason = 13;

Specified by:

getFailureReasonBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The bytes for failureReason.

getExecutorDeserializeTime

public long getExecutorDeserializeTime()

int64 executor_deserialize_time = 14;

Specified by:

getExecutorDeserializeTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorDeserializeTime.

getExecutorDeserializeCpuTime

public long getExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 15;

Specified by:

getExecutorDeserializeCpuTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorDeserializeCpuTime.

getExecutorRunTime

public long getExecutorRunTime()

int64 executor_run_time = 16;

Specified by:

getExecutorRunTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorRunTime.

getExecutorCpuTime

public long getExecutorCpuTime()

int64 executor_cpu_time = 17;

Specified by:

getExecutorCpuTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorCpuTime.

getResultSize

public long getResultSize()

int64 result_size = 18;

Specified by:

getResultSize in interface StoreTypes.StageDataOrBuilder

Returns:

The resultSize.

getJvmGcTime

public long getJvmGcTime()

int64 jvm_gc_time = 19;

Specified by:

getJvmGcTime in interface StoreTypes.StageDataOrBuilder

Returns:

The jvmGcTime.

getResultSerializationTime

public long getResultSerializationTime()

int64 result_serialization_time = 20;

Specified by:

getResultSerializationTime in interface StoreTypes.StageDataOrBuilder

Returns:

The resultSerializationTime.

getMemoryBytesSpilled

public long getMemoryBytesSpilled()

int64 memory_bytes_spilled = 21;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.StageDataOrBuilder

Returns:

The memoryBytesSpilled.

getDiskBytesSpilled

public long getDiskBytesSpilled()

int64 disk_bytes_spilled = 22;

Specified by:

getDiskBytesSpilled in interface StoreTypes.StageDataOrBuilder

Returns:

The diskBytesSpilled.

getPeakExecutionMemory

public long getPeakExecutionMemory()

int64 peak_execution_memory = 23;

Specified by:

getPeakExecutionMemory in interface StoreTypes.StageDataOrBuilder

Returns:

The peakExecutionMemory.

getInputBytes

public long getInputBytes()

int64 input_bytes = 24;

Specified by:

getInputBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The inputBytes.

getInputRecords

public long getInputRecords()

int64 input_records = 25;

Specified by:

getInputRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The inputRecords.

getOutputBytes

public long getOutputBytes()

int64 output_bytes = 26;

Specified by:

getOutputBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The outputBytes.

getOutputRecords

public long getOutputRecords()

int64 output_records = 27;

Specified by:

getOutputRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The outputRecords.

getShuffleRemoteBlocksFetched

public long getShuffleRemoteBlocksFetched()

int64 shuffle_remote_blocks_fetched = 28;

Specified by:

getShuffleRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteBlocksFetched.

getShuffleLocalBlocksFetched

public long getShuffleLocalBlocksFetched()

int64 shuffle_local_blocks_fetched = 29;

Specified by:

getShuffleLocalBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleLocalBlocksFetched.

getShuffleFetchWaitTime

public long getShuffleFetchWaitTime()

int64 shuffle_fetch_wait_time = 30;

Specified by:

getShuffleFetchWaitTime in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleFetchWaitTime.

getShuffleRemoteBytesRead

public long getShuffleRemoteBytesRead()

int64 shuffle_remote_bytes_read = 31;

Specified by:

getShuffleRemoteBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteBytesRead.

getShuffleRemoteBytesReadToDisk

public long getShuffleRemoteBytesReadToDisk()

int64 shuffle_remote_bytes_read_to_disk = 32;

Specified by:

getShuffleRemoteBytesReadToDisk in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteBytesReadToDisk.

getShuffleLocalBytesRead

public long getShuffleLocalBytesRead()

int64 shuffle_local_bytes_read = 33;

Specified by:

getShuffleLocalBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleLocalBytesRead.

getShuffleReadBytes

public long getShuffleReadBytes()

int64 shuffle_read_bytes = 34;

Specified by:

getShuffleReadBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleReadBytes.

getShuffleReadRecords

public long getShuffleReadRecords()

int64 shuffle_read_records = 35;

Specified by:

getShuffleReadRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleReadRecords.

getShuffleWriteBytes

public long getShuffleWriteBytes()

int64 shuffle_write_bytes = 36;

Specified by:

getShuffleWriteBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleWriteBytes.

getShuffleWriteTime

public long getShuffleWriteTime()

int64 shuffle_write_time = 37;

Specified by:

getShuffleWriteTime in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleWriteTime.

getShuffleWriteRecords

public long getShuffleWriteRecords()

int64 shuffle_write_records = 38;

Specified by:

getShuffleWriteRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleWriteRecords.

hasName

public boolean hasName()

optional string name = 39;

Specified by:

hasName in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the name field is set.

getName

public String getName()

optional string name = 39;

Specified by:

getName in interface StoreTypes.StageDataOrBuilder

Returns:

The name.

getNameBytes

public com.google.protobuf.ByteString getNameBytes()

optional string name = 39;

Specified by:

getNameBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The bytes for name.

hasDescription

public boolean hasDescription()

optional string description = 40;

Specified by:

hasDescription in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the description field is set.

getDescription

public String getDescription()

optional string description = 40;

Specified by:

getDescription in interface StoreTypes.StageDataOrBuilder

Returns:

The description.

getDescriptionBytes

public com.google.protobuf.ByteString getDescriptionBytes()

optional string description = 40;

Specified by:

getDescriptionBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The bytes for description.

hasDetails

public boolean hasDetails()

optional string details = 41;

Specified by:

hasDetails in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the details field is set.

getDetails

public String getDetails()

optional string details = 41;

Specified by:

getDetails in interface StoreTypes.StageDataOrBuilder

Returns:

The details.

getDetailsBytes

public com.google.protobuf.ByteString getDetailsBytes()

optional string details = 41;

Specified by:

getDetailsBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The bytes for details.

hasSchedulingPool

public boolean hasSchedulingPool()

optional string scheduling_pool = 42;

Specified by:

hasSchedulingPool in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the schedulingPool field is set.

getSchedulingPool

public String getSchedulingPool()

optional string scheduling_pool = 42;

Specified by:

getSchedulingPool in interface StoreTypes.StageDataOrBuilder

Returns:

The schedulingPool.

getSchedulingPoolBytes

public com.google.protobuf.ByteString getSchedulingPoolBytes()

optional string scheduling_pool = 42;

Specified by:

getSchedulingPoolBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The bytes for schedulingPool.

getRddIdsList

public List<Long> getRddIdsList()

repeated int64 rdd_ids = 43;

Specified by:

getRddIdsList in interface StoreTypes.StageDataOrBuilder

Returns:

A list containing the rddIds.

getRddIdsCount

public int getRddIdsCount()

repeated int64 rdd_ids = 43;

Specified by:

getRddIdsCount in interface StoreTypes.StageDataOrBuilder

Returns:

The count of rddIds.

getRddIds

public long getRddIds(int index)

repeated int64 rdd_ids = 43;

Specified by:

getRddIds in interface StoreTypes.StageDataOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The rddIds at the given index.

getAccumulatorUpdatesList

public List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;

Specified by:

getAccumulatorUpdatesList in interface StoreTypes.StageDataOrBuilder

getAccumulatorUpdatesOrBuilderList

public List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;

Specified by:

getAccumulatorUpdatesOrBuilderList in interface StoreTypes.StageDataOrBuilder

getAccumulatorUpdatesCount

public int getAccumulatorUpdatesCount()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;

Specified by:

getAccumulatorUpdatesCount in interface StoreTypes.StageDataOrBuilder

getAccumulatorUpdates

public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;

Specified by:

getAccumulatorUpdates in interface StoreTypes.StageDataOrBuilder

getAccumulatorUpdatesOrBuilder

public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;

Specified by:

getAccumulatorUpdatesOrBuilder in interface StoreTypes.StageDataOrBuilder

getTasksCount

public int getTasksCount()

Description copied from interface: StoreTypes.StageDataOrBuilder

map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;

Specified by:

getTasksCount in interface StoreTypes.StageDataOrBuilder

containsTasks

public boolean containsTasks(long key)

map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;

Specified by:

containsTasks in interface StoreTypes.StageDataOrBuilder

getTasks

@Deprecated
public Map<Long,StoreTypes.TaskData> getTasks()

Deprecated.

Use getTasksMap() instead.

Specified by:

getTasks in interface StoreTypes.StageDataOrBuilder

getTasksMap

public Map<Long,StoreTypes.TaskData> getTasksMap()

map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;

Specified by:

getTasksMap in interface StoreTypes.StageDataOrBuilder

getTasksOrDefault

public StoreTypes.TaskData getTasksOrDefault(long key,
 StoreTypes.TaskData defaultValue)

map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;

Specified by:

getTasksOrDefault in interface StoreTypes.StageDataOrBuilder

getTasksOrThrow

public StoreTypes.TaskData getTasksOrThrow(long key)

map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;

Specified by:

getTasksOrThrow in interface StoreTypes.StageDataOrBuilder

getExecutorSummaryCount

public int getExecutorSummaryCount()

Description copied from interface: StoreTypes.StageDataOrBuilder

map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;

Specified by:

getExecutorSummaryCount in interface StoreTypes.StageDataOrBuilder

containsExecutorSummary

public boolean containsExecutorSummary(String key)

map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;

Specified by:

containsExecutorSummary in interface StoreTypes.StageDataOrBuilder

getExecutorSummary

@Deprecated
public Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummary()

Deprecated.

Use getExecutorSummaryMap() instead.

Specified by:

getExecutorSummary in interface StoreTypes.StageDataOrBuilder

getExecutorSummaryMap

public Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummaryMap()

map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;

Specified by:

getExecutorSummaryMap in interface StoreTypes.StageDataOrBuilder

getExecutorSummaryOrDefault

public StoreTypes.ExecutorStageSummary getExecutorSummaryOrDefault(String key,
 StoreTypes.ExecutorStageSummary defaultValue)

map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;

Specified by:

getExecutorSummaryOrDefault in interface StoreTypes.StageDataOrBuilder

getExecutorSummaryOrThrow

public StoreTypes.ExecutorStageSummary getExecutorSummaryOrThrow(String key)

map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;

Specified by:

getExecutorSummaryOrThrow in interface StoreTypes.StageDataOrBuilder

hasSpeculationSummary

public boolean hasSpeculationSummary()

optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;

Specified by:

hasSpeculationSummary in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the speculationSummary field is set.

getSpeculationSummary

public StoreTypes.SpeculationStageSummary getSpeculationSummary()

optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;

Specified by:

getSpeculationSummary in interface StoreTypes.StageDataOrBuilder

Returns:

The speculationSummary.

getSpeculationSummaryOrBuilder

public StoreTypes.SpeculationStageSummaryOrBuilder getSpeculationSummaryOrBuilder()

optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;

Specified by:

getSpeculationSummaryOrBuilder in interface StoreTypes.StageDataOrBuilder

getKilledTasksSummaryCount

public int getKilledTasksSummaryCount()

Description copied from interface: StoreTypes.StageDataOrBuilder

map<string, int32> killed_tasks_summary = 48;

Specified by:

getKilledTasksSummaryCount in interface StoreTypes.StageDataOrBuilder

containsKilledTasksSummary

public boolean containsKilledTasksSummary(String key)

map<string, int32> killed_tasks_summary = 48;

Specified by:

containsKilledTasksSummary in interface StoreTypes.StageDataOrBuilder

getKilledTasksSummary

@Deprecated
public Map<String,Integer> getKilledTasksSummary()

Deprecated.

Use getKilledTasksSummaryMap() instead.

Specified by:

getKilledTasksSummary in interface StoreTypes.StageDataOrBuilder

getKilledTasksSummaryMap

public Map<String,Integer> getKilledTasksSummaryMap()

map<string, int32> killed_tasks_summary = 48;

Specified by:

getKilledTasksSummaryMap in interface StoreTypes.StageDataOrBuilder

getKilledTasksSummaryOrDefault

public int getKilledTasksSummaryOrDefault(String key,
 int defaultValue)

map<string, int32> killed_tasks_summary = 48;

Specified by:

getKilledTasksSummaryOrDefault in interface StoreTypes.StageDataOrBuilder

getKilledTasksSummaryOrThrow

public int getKilledTasksSummaryOrThrow(String key)

map<string, int32> killed_tasks_summary = 48;

Specified by:

getKilledTasksSummaryOrThrow in interface StoreTypes.StageDataOrBuilder

getResourceProfileId

public int getResourceProfileId()

int32 resource_profile_id = 49;

Specified by:

getResourceProfileId in interface StoreTypes.StageDataOrBuilder

Returns:

The resourceProfileId.

hasPeakExecutorMetrics

public boolean hasPeakExecutorMetrics()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;

Specified by:

hasPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the peakExecutorMetrics field is set.

getPeakExecutorMetrics

public StoreTypes.ExecutorMetrics getPeakExecutorMetrics()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;

Specified by:

getPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilder

Returns:

The peakExecutorMetrics.

getPeakExecutorMetricsOrBuilder

public StoreTypes.ExecutorMetricsOrBuilder getPeakExecutorMetricsOrBuilder()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;

Specified by:

getPeakExecutorMetricsOrBuilder in interface StoreTypes.StageDataOrBuilder

hasTaskMetricsDistributions

public boolean hasTaskMetricsDistributions()

optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;

Specified by:

hasTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the taskMetricsDistributions field is set.

getTaskMetricsDistributions

public StoreTypes.TaskMetricDistributions getTaskMetricsDistributions()

optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;

Specified by:

getTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilder

Returns:

The taskMetricsDistributions.

getTaskMetricsDistributionsOrBuilder

public StoreTypes.TaskMetricDistributionsOrBuilder getTaskMetricsDistributionsOrBuilder()

optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;

Specified by:

getTaskMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilder

hasExecutorMetricsDistributions

public boolean hasExecutorMetricsDistributions()

optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;

Specified by:

hasExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilder

Returns:

Whether the executorMetricsDistributions field is set.

getExecutorMetricsDistributions

public StoreTypes.ExecutorMetricsDistributions getExecutorMetricsDistributions()

optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;

Specified by:

getExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilder

Returns:

The executorMetricsDistributions.

getExecutorMetricsDistributionsOrBuilder

public StoreTypes.ExecutorMetricsDistributionsOrBuilder getExecutorMetricsDistributionsOrBuilder()

optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;

Specified by:

getExecutorMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilder

getShuffleCorruptMergedBlockChunks

public long getShuffleCorruptMergedBlockChunks()

int64 shuffle_corrupt_merged_block_chunks = 53;

Specified by:

getShuffleCorruptMergedBlockChunks in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleCorruptMergedBlockChunks.

getShuffleMergedFetchFallbackCount

public long getShuffleMergedFetchFallbackCount()

int64 shuffle_merged_fetch_fallback_count = 54;

Specified by:

getShuffleMergedFetchFallbackCount in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedFetchFallbackCount.

getShuffleMergedRemoteBlocksFetched

public long getShuffleMergedRemoteBlocksFetched()

int64 shuffle_merged_remote_blocks_fetched = 55;

Specified by:

getShuffleMergedRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteBlocksFetched.

getShuffleMergedLocalBlocksFetched

public long getShuffleMergedLocalBlocksFetched()

int64 shuffle_merged_local_blocks_fetched = 56;

Specified by:

getShuffleMergedLocalBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedLocalBlocksFetched.

getShuffleMergedRemoteChunksFetched

public long getShuffleMergedRemoteChunksFetched()

int64 shuffle_merged_remote_chunks_fetched = 57;

Specified by:

getShuffleMergedRemoteChunksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteChunksFetched.

getShuffleMergedLocalChunksFetched

public long getShuffleMergedLocalChunksFetched()

int64 shuffle_merged_local_chunks_fetched = 58;

Specified by:

getShuffleMergedLocalChunksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedLocalChunksFetched.

getShuffleMergedRemoteBytesRead

public long getShuffleMergedRemoteBytesRead()

int64 shuffle_merged_remote_bytes_read = 59;

Specified by:

getShuffleMergedRemoteBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteBytesRead.

getShuffleMergedLocalBytesRead

public long getShuffleMergedLocalBytesRead()

int64 shuffle_merged_local_bytes_read = 60;

Specified by:

getShuffleMergedLocalBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedLocalBytesRead.

getShuffleRemoteReqsDuration

public long getShuffleRemoteReqsDuration()

int64 shuffle_remote_reqs_duration = 61;

Specified by:

getShuffleRemoteReqsDuration in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteReqsDuration.

getShuffleMergedRemoteReqsDuration

public long getShuffleMergedRemoteReqsDuration()

int64 shuffle_merged_remote_reqs_duration = 62;

Specified by:

getShuffleMergedRemoteReqsDuration in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteReqsDuration.

getIsShufflePushEnabled

public boolean getIsShufflePushEnabled()

bool is_shuffle_push_enabled = 63;

Specified by:

getIsShufflePushEnabled in interface StoreTypes.StageDataOrBuilder

Returns:

The isShufflePushEnabled.

getShuffleMergersCount

public int getShuffleMergersCount()

int32 shuffle_mergers_count = 64;

Specified by:

getShuffleMergersCount in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergersCount.

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage

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.GeneratedMessage

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessage

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.StageData parseFrom(ByteBuffer data)
                                      throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.StageData 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.StageData parseFrom(byte[] data)
                                      throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

newBuilderForType

public StoreTypes.StageData.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.StageData.Builder newBuilder()

newBuilder

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

toBuilder

public StoreTypes.StageData.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.StageData getDefaultInstance()

parser

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

getParserForType

public com.google.protobuf.Parser<StoreTypes.StageData> 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.GeneratedMessage

getDefaultInstanceForType

public StoreTypes.StageData getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder