Package org.apache.spark.status.protobuf

Class StoreTypes.StageData.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

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

com.google.protobuf.GeneratedMessage.Builder<StoreTypes.StageData.Builder>

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

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, StoreTypes.StageDataOrBuilder

Enclosing class:

StoreTypes.StageData

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

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

Method Summary

Modifier and Type	Method	Description
StoreTypes.StageData.Builder	addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	addAccumulatorUpdates(StoreTypes.AccumulableInfo value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.AccumulableInfo.Builder	addAccumulatorUpdatesBuilder()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.AccumulableInfo.Builder	addAccumulatorUpdatesBuilder(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	addAllRddIds(Iterable<? extends Long> values)	repeated int64 rdd_ids = 43;
StoreTypes.StageData.Builder	addRddIds(long value)	repeated int64 rdd_ids = 43;
StoreTypes.StageData	build()
StoreTypes.StageData	buildPartial()
StoreTypes.StageData.Builder	clear()
StoreTypes.StageData.Builder	clearAccumulatorUpdates()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	clearAttemptId()	int32 attempt_id = 3;
StoreTypes.StageData.Builder	clearCompletionTime()	optional int64 completion_time = 12;
StoreTypes.StageData.Builder	clearDescription()	optional string description = 40;
StoreTypes.StageData.Builder	clearDetails()	optional string details = 41;
StoreTypes.StageData.Builder	clearDiskBytesSpilled()	int64 disk_bytes_spilled = 22;
StoreTypes.StageData.Builder	clearExecutorCpuTime()	int64 executor_cpu_time = 17;
StoreTypes.StageData.Builder	clearExecutorDeserializeCpuTime()	int64 executor_deserialize_cpu_time = 15;
StoreTypes.StageData.Builder	clearExecutorDeserializeTime()	int64 executor_deserialize_time = 14;
StoreTypes.StageData.Builder	clearExecutorMetricsDistributions()	optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
StoreTypes.StageData.Builder	clearExecutorRunTime()	int64 executor_run_time = 16;
StoreTypes.StageData.Builder	clearExecutorSummary()
StoreTypes.StageData.Builder	clearFailureReason()	optional string failure_reason = 13;
StoreTypes.StageData.Builder	clearFirstTaskLaunchedTime()	optional int64 first_task_launched_time = 11;
StoreTypes.StageData.Builder	clearInputBytes()	int64 input_bytes = 24;
StoreTypes.StageData.Builder	clearInputRecords()	int64 input_records = 25;
StoreTypes.StageData.Builder	clearIsShufflePushEnabled()	bool is_shuffle_push_enabled = 63;
StoreTypes.StageData.Builder	clearJvmGcTime()	int64 jvm_gc_time = 19;
StoreTypes.StageData.Builder	clearKilledTasksSummary()
StoreTypes.StageData.Builder	clearMemoryBytesSpilled()	int64 memory_bytes_spilled = 21;
StoreTypes.StageData.Builder	clearName()	optional string name = 39;
StoreTypes.StageData.Builder	clearNumActiveTasks()	int32 num_active_tasks = 5;
StoreTypes.StageData.Builder	clearNumCompletedIndices()	int32 num_completed_indices = 9;
StoreTypes.StageData.Builder	clearNumCompleteTasks()	int32 num_complete_tasks = 6;
StoreTypes.StageData.Builder	clearNumFailedTasks()	int32 num_failed_tasks = 7;
StoreTypes.StageData.Builder	clearNumKilledTasks()	int32 num_killed_tasks = 8;
StoreTypes.StageData.Builder	clearNumTasks()	int32 num_tasks = 4;
StoreTypes.StageData.Builder	clearOutputBytes()	int64 output_bytes = 26;
StoreTypes.StageData.Builder	clearOutputRecords()	int64 output_records = 27;
StoreTypes.StageData.Builder	clearPeakExecutionMemory()	int64 peak_execution_memory = 23;
StoreTypes.StageData.Builder	clearPeakExecutorMetrics()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
StoreTypes.StageData.Builder	clearRddIds()	repeated int64 rdd_ids = 43;
StoreTypes.StageData.Builder	clearResourceProfileId()	int32 resource_profile_id = 49;
StoreTypes.StageData.Builder	clearResultSerializationTime()	int64 result_serialization_time = 20;
StoreTypes.StageData.Builder	clearResultSize()	int64 result_size = 18;
StoreTypes.StageData.Builder	clearSchedulingPool()	optional string scheduling_pool = 42;
StoreTypes.StageData.Builder	clearShuffleCorruptMergedBlockChunks()	int64 shuffle_corrupt_merged_block_chunks = 53;
StoreTypes.StageData.Builder	clearShuffleFetchWaitTime()	int64 shuffle_fetch_wait_time = 30;
StoreTypes.StageData.Builder	clearShuffleLocalBlocksFetched()	int64 shuffle_local_blocks_fetched = 29;
StoreTypes.StageData.Builder	clearShuffleLocalBytesRead()	int64 shuffle_local_bytes_read = 33;
StoreTypes.StageData.Builder	clearShuffleMergedFetchFallbackCount()	int64 shuffle_merged_fetch_fallback_count = 54;
StoreTypes.StageData.Builder	clearShuffleMergedLocalBlocksFetched()	int64 shuffle_merged_local_blocks_fetched = 56;
StoreTypes.StageData.Builder	clearShuffleMergedLocalBytesRead()	int64 shuffle_merged_local_bytes_read = 60;
StoreTypes.StageData.Builder	clearShuffleMergedLocalChunksFetched()	int64 shuffle_merged_local_chunks_fetched = 58;
StoreTypes.StageData.Builder	clearShuffleMergedRemoteBlocksFetched()	int64 shuffle_merged_remote_blocks_fetched = 55;
StoreTypes.StageData.Builder	clearShuffleMergedRemoteBytesRead()	int64 shuffle_merged_remote_bytes_read = 59;
StoreTypes.StageData.Builder	clearShuffleMergedRemoteChunksFetched()	int64 shuffle_merged_remote_chunks_fetched = 57;
StoreTypes.StageData.Builder	clearShuffleMergedRemoteReqsDuration()	int64 shuffle_merged_remote_reqs_duration = 62;
StoreTypes.StageData.Builder	clearShuffleMergersCount()	int32 shuffle_mergers_count = 64;
StoreTypes.StageData.Builder	clearShuffleReadBytes()	int64 shuffle_read_bytes = 34;
StoreTypes.StageData.Builder	clearShuffleReadRecords()	int64 shuffle_read_records = 35;
StoreTypes.StageData.Builder	clearShuffleRemoteBlocksFetched()	int64 shuffle_remote_blocks_fetched = 28;
StoreTypes.StageData.Builder	clearShuffleRemoteBytesRead()	int64 shuffle_remote_bytes_read = 31;
StoreTypes.StageData.Builder	clearShuffleRemoteBytesReadToDisk()	int64 shuffle_remote_bytes_read_to_disk = 32;
StoreTypes.StageData.Builder	clearShuffleRemoteReqsDuration()	int64 shuffle_remote_reqs_duration = 61;
StoreTypes.StageData.Builder	clearShuffleWriteBytes()	int64 shuffle_write_bytes = 36;
StoreTypes.StageData.Builder	clearShuffleWriteRecords()	int64 shuffle_write_records = 38;
StoreTypes.StageData.Builder	clearShuffleWriteTime()	int64 shuffle_write_time = 37;
StoreTypes.StageData.Builder	clearSpeculationSummary()	optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
StoreTypes.StageData.Builder	clearStageId()	int64 stage_id = 2;
StoreTypes.StageData.Builder	clearStatus()	.org.apache.spark.status.protobuf.StageStatus status = 1;
StoreTypes.StageData.Builder	clearSubmissionTime()	optional int64 submission_time = 10;
StoreTypes.StageData.Builder	clearTaskMetricsDistributions()	optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
StoreTypes.StageData.Builder	clearTasks()
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;
StoreTypes.AccumulableInfo	getAccumulatorUpdates(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.AccumulableInfo.Builder	getAccumulatorUpdatesBuilder(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
List<StoreTypes.AccumulableInfo.Builder>	getAccumulatorUpdatesBuilderList()	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;
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()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
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.ExecutorMetricsDistributions.Builder	getExecutorMetricsDistributionsBuilder()	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;
Map<String,StoreTypes.ExecutorStageSummary>	getMutableExecutorSummary()	Deprecated.
Map<String,Integer>	getMutableKilledTasksSummary()	Deprecated.
Map<Long,StoreTypes.TaskData>	getMutableTasks()	Deprecated.
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;
long	getPeakExecutionMemory()	int64 peak_execution_memory = 23;
StoreTypes.ExecutorMetrics	getPeakExecutorMetrics()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
StoreTypes.ExecutorMetrics.Builder	getPeakExecutorMetricsBuilder()	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;
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.SpeculationStageSummary.Builder	getSpeculationSummaryBuilder()	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.TaskMetricDistributions.Builder	getTaskMetricsDistributionsBuilder()	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;
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()
StoreTypes.StageData.Builder	mergeExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions value)	optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
StoreTypes.StageData.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.StageData.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.StageData.Builder	mergeFrom(StoreTypes.StageData other)
StoreTypes.StageData.Builder	mergePeakExecutorMetrics(StoreTypes.ExecutorMetrics value)	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
StoreTypes.StageData.Builder	mergeSpeculationSummary(StoreTypes.SpeculationStageSummary value)	optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
StoreTypes.StageData.Builder	mergeTaskMetricsDistributions(StoreTypes.TaskMetricDistributions value)	optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
StoreTypes.StageData.Builder	putAllExecutorSummary(Map<String,StoreTypes.ExecutorStageSummary> values)	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
StoreTypes.StageData.Builder	putAllKilledTasksSummary(Map<String,Integer> values)	map<string, int32> killed_tasks_summary = 48;
StoreTypes.StageData.Builder	putAllTasks(Map<Long,StoreTypes.TaskData> values)	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
StoreTypes.StageData.Builder	putExecutorSummary(String key, StoreTypes.ExecutorStageSummary value)	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
StoreTypes.ExecutorStageSummary.Builder	putExecutorSummaryBuilderIfAbsent(String key)	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
StoreTypes.StageData.Builder	putKilledTasksSummary(String key, int value)	map<string, int32> killed_tasks_summary = 48;
StoreTypes.StageData.Builder	putTasks(long key, StoreTypes.TaskData value)	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
StoreTypes.TaskData.Builder	putTasksBuilderIfAbsent(long key)	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
StoreTypes.StageData.Builder	removeAccumulatorUpdates(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	removeExecutorSummary(String key)	map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
StoreTypes.StageData.Builder	removeKilledTasksSummary(String key)	map<string, int32> killed_tasks_summary = 48;
StoreTypes.StageData.Builder	removeTasks(long key)	map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
StoreTypes.StageData.Builder	setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
StoreTypes.StageData.Builder	setAttemptId(int value)	int32 attempt_id = 3;
StoreTypes.StageData.Builder	setCompletionTime(long value)	optional int64 completion_time = 12;
StoreTypes.StageData.Builder	setDescription(String value)	optional string description = 40;
StoreTypes.StageData.Builder	setDescriptionBytes(com.google.protobuf.ByteString value)	optional string description = 40;
StoreTypes.StageData.Builder	setDetails(String value)	optional string details = 41;
StoreTypes.StageData.Builder	setDetailsBytes(com.google.protobuf.ByteString value)	optional string details = 41;
StoreTypes.StageData.Builder	setDiskBytesSpilled(long value)	int64 disk_bytes_spilled = 22;
StoreTypes.StageData.Builder	setExecutorCpuTime(long value)	int64 executor_cpu_time = 17;
StoreTypes.StageData.Builder	setExecutorDeserializeCpuTime(long value)	int64 executor_deserialize_cpu_time = 15;
StoreTypes.StageData.Builder	setExecutorDeserializeTime(long value)	int64 executor_deserialize_time = 14;
StoreTypes.StageData.Builder	setExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions value)	optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
StoreTypes.StageData.Builder	setExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions.Builder builderForValue)	optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
StoreTypes.StageData.Builder	setExecutorRunTime(long value)	int64 executor_run_time = 16;
StoreTypes.StageData.Builder	setFailureReason(String value)	optional string failure_reason = 13;
StoreTypes.StageData.Builder	setFailureReasonBytes(com.google.protobuf.ByteString value)	optional string failure_reason = 13;
StoreTypes.StageData.Builder	setFirstTaskLaunchedTime(long value)	optional int64 first_task_launched_time = 11;
StoreTypes.StageData.Builder	setInputBytes(long value)	int64 input_bytes = 24;
StoreTypes.StageData.Builder	setInputRecords(long value)	int64 input_records = 25;
StoreTypes.StageData.Builder	setIsShufflePushEnabled(boolean value)	bool is_shuffle_push_enabled = 63;
StoreTypes.StageData.Builder	setJvmGcTime(long value)	int64 jvm_gc_time = 19;
StoreTypes.StageData.Builder	setMemoryBytesSpilled(long value)	int64 memory_bytes_spilled = 21;
StoreTypes.StageData.Builder	setName(String value)	optional string name = 39;
StoreTypes.StageData.Builder	setNameBytes(com.google.protobuf.ByteString value)	optional string name = 39;
StoreTypes.StageData.Builder	setNumActiveTasks(int value)	int32 num_active_tasks = 5;
StoreTypes.StageData.Builder	setNumCompletedIndices(int value)	int32 num_completed_indices = 9;
StoreTypes.StageData.Builder	setNumCompleteTasks(int value)	int32 num_complete_tasks = 6;
StoreTypes.StageData.Builder	setNumFailedTasks(int value)	int32 num_failed_tasks = 7;
StoreTypes.StageData.Builder	setNumKilledTasks(int value)	int32 num_killed_tasks = 8;
StoreTypes.StageData.Builder	setNumTasks(int value)	int32 num_tasks = 4;
StoreTypes.StageData.Builder	setOutputBytes(long value)	int64 output_bytes = 26;
StoreTypes.StageData.Builder	setOutputRecords(long value)	int64 output_records = 27;
StoreTypes.StageData.Builder	setPeakExecutionMemory(long value)	int64 peak_execution_memory = 23;
StoreTypes.StageData.Builder	setPeakExecutorMetrics(StoreTypes.ExecutorMetrics value)	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
StoreTypes.StageData.Builder	setPeakExecutorMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue)	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
StoreTypes.StageData.Builder	setRddIds(int index, long value)	repeated int64 rdd_ids = 43;
StoreTypes.StageData.Builder	setResourceProfileId(int value)	int32 resource_profile_id = 49;
StoreTypes.StageData.Builder	setResultSerializationTime(long value)	int64 result_serialization_time = 20;
StoreTypes.StageData.Builder	setResultSize(long value)	int64 result_size = 18;
StoreTypes.StageData.Builder	setSchedulingPool(String value)	optional string scheduling_pool = 42;
StoreTypes.StageData.Builder	setSchedulingPoolBytes(com.google.protobuf.ByteString value)	optional string scheduling_pool = 42;
StoreTypes.StageData.Builder	setShuffleCorruptMergedBlockChunks(long value)	int64 shuffle_corrupt_merged_block_chunks = 53;
StoreTypes.StageData.Builder	setShuffleFetchWaitTime(long value)	int64 shuffle_fetch_wait_time = 30;
StoreTypes.StageData.Builder	setShuffleLocalBlocksFetched(long value)	int64 shuffle_local_blocks_fetched = 29;
StoreTypes.StageData.Builder	setShuffleLocalBytesRead(long value)	int64 shuffle_local_bytes_read = 33;
StoreTypes.StageData.Builder	setShuffleMergedFetchFallbackCount(long value)	int64 shuffle_merged_fetch_fallback_count = 54;
StoreTypes.StageData.Builder	setShuffleMergedLocalBlocksFetched(long value)	int64 shuffle_merged_local_blocks_fetched = 56;
StoreTypes.StageData.Builder	setShuffleMergedLocalBytesRead(long value)	int64 shuffle_merged_local_bytes_read = 60;
StoreTypes.StageData.Builder	setShuffleMergedLocalChunksFetched(long value)	int64 shuffle_merged_local_chunks_fetched = 58;
StoreTypes.StageData.Builder	setShuffleMergedRemoteBlocksFetched(long value)	int64 shuffle_merged_remote_blocks_fetched = 55;
StoreTypes.StageData.Builder	setShuffleMergedRemoteBytesRead(long value)	int64 shuffle_merged_remote_bytes_read = 59;
StoreTypes.StageData.Builder	setShuffleMergedRemoteChunksFetched(long value)	int64 shuffle_merged_remote_chunks_fetched = 57;
StoreTypes.StageData.Builder	setShuffleMergedRemoteReqsDuration(long value)	int64 shuffle_merged_remote_reqs_duration = 62;
StoreTypes.StageData.Builder	setShuffleMergersCount(int value)	int32 shuffle_mergers_count = 64;
StoreTypes.StageData.Builder	setShuffleReadBytes(long value)	int64 shuffle_read_bytes = 34;
StoreTypes.StageData.Builder	setShuffleReadRecords(long value)	int64 shuffle_read_records = 35;
StoreTypes.StageData.Builder	setShuffleRemoteBlocksFetched(long value)	int64 shuffle_remote_blocks_fetched = 28;
StoreTypes.StageData.Builder	setShuffleRemoteBytesRead(long value)	int64 shuffle_remote_bytes_read = 31;
StoreTypes.StageData.Builder	setShuffleRemoteBytesReadToDisk(long value)	int64 shuffle_remote_bytes_read_to_disk = 32;
StoreTypes.StageData.Builder	setShuffleRemoteReqsDuration(long value)	int64 shuffle_remote_reqs_duration = 61;
StoreTypes.StageData.Builder	setShuffleWriteBytes(long value)	int64 shuffle_write_bytes = 36;
StoreTypes.StageData.Builder	setShuffleWriteRecords(long value)	int64 shuffle_write_records = 38;
StoreTypes.StageData.Builder	setShuffleWriteTime(long value)	int64 shuffle_write_time = 37;
StoreTypes.StageData.Builder	setSpeculationSummary(StoreTypes.SpeculationStageSummary value)	optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
StoreTypes.StageData.Builder	setSpeculationSummary(StoreTypes.SpeculationStageSummary.Builder builderForValue)	optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
StoreTypes.StageData.Builder	setStageId(long value)	int64 stage_id = 2;
StoreTypes.StageData.Builder	setStatus(StoreTypes.StageStatus value)	.org.apache.spark.status.protobuf.StageStatus status = 1;
StoreTypes.StageData.Builder	setStatusValue(int value)	.org.apache.spark.status.protobuf.StageStatus status = 1;
StoreTypes.StageData.Builder	setSubmissionTime(long value)	optional int64 submission_time = 10;
StoreTypes.StageData.Builder	setTaskMetricsDistributions(StoreTypes.TaskMetricDistributions value)	optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
StoreTypes.StageData.Builder	setTaskMetricsDistributions(StoreTypes.TaskMetricDistributions.Builder builderForValue)	optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;

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.StageData.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.StageData.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.StageData.Builder>

getDefaultInstanceForType

public StoreTypes.StageData getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.StageData build()

Specified by:

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

Specified by:

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

buildPartial

public StoreTypes.StageData buildPartial()

Specified by:

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

Specified by:

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

mergeFrom

public StoreTypes.StageData.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.StageData.Builder>

mergeFrom

public StoreTypes.StageData.Builder mergeFrom(StoreTypes.StageData 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.StageData.Builder>

mergeFrom

public StoreTypes.StageData.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.StageData.Builder>

Throws:

IOException

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.

setStatusValue

public StoreTypes.StageData.Builder setStatusValue(int value)

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

Parameters:

value - The enum numeric value on the wire for status to set.

Returns:

This builder for chaining.

getStatus

public StoreTypes.StageStatus getStatus()

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

Specified by:

getStatus in interface StoreTypes.StageDataOrBuilder

Returns:

The status.

setStatus

public StoreTypes.StageData.Builder setStatus(StoreTypes.StageStatus value)

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

Parameters:

value - The status to set.

Returns:

This builder for chaining.

clearStatus

public StoreTypes.StageData.Builder clearStatus()

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

Returns:

This builder for chaining.

getStageId

public long getStageId()

int64 stage_id = 2;

Specified by:

getStageId in interface StoreTypes.StageDataOrBuilder

Returns:

The stageId.

setStageId

public StoreTypes.StageData.Builder setStageId(long value)

int64 stage_id = 2;

Parameters:

value - The stageId to set.

Returns:

This builder for chaining.

clearStageId

public StoreTypes.StageData.Builder clearStageId()

int64 stage_id = 2;

Returns:

This builder for chaining.

getAttemptId

public int getAttemptId()

int32 attempt_id = 3;

Specified by:

getAttemptId in interface StoreTypes.StageDataOrBuilder

Returns:

The attemptId.

setAttemptId

public StoreTypes.StageData.Builder setAttemptId(int value)

int32 attempt_id = 3;

Parameters:

value - The attemptId to set.

Returns:

This builder for chaining.

clearAttemptId

public StoreTypes.StageData.Builder clearAttemptId()

int32 attempt_id = 3;

Returns:

This builder for chaining.

getNumTasks

public int getNumTasks()

int32 num_tasks = 4;

Specified by:

getNumTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numTasks.

setNumTasks

public StoreTypes.StageData.Builder setNumTasks(int value)

int32 num_tasks = 4;

Parameters:

value - The numTasks to set.

Returns:

This builder for chaining.

clearNumTasks

public StoreTypes.StageData.Builder clearNumTasks()

int32 num_tasks = 4;

Returns:

This builder for chaining.

getNumActiveTasks

public int getNumActiveTasks()

int32 num_active_tasks = 5;

Specified by:

getNumActiveTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numActiveTasks.

setNumActiveTasks

public StoreTypes.StageData.Builder setNumActiveTasks(int value)

int32 num_active_tasks = 5;

Parameters:

value - The numActiveTasks to set.

Returns:

This builder for chaining.

clearNumActiveTasks

public StoreTypes.StageData.Builder clearNumActiveTasks()

int32 num_active_tasks = 5;

Returns:

This builder for chaining.

getNumCompleteTasks

public int getNumCompleteTasks()

int32 num_complete_tasks = 6;

Specified by:

getNumCompleteTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numCompleteTasks.

setNumCompleteTasks

public StoreTypes.StageData.Builder setNumCompleteTasks(int value)

int32 num_complete_tasks = 6;

Parameters:

value - The numCompleteTasks to set.

Returns:

This builder for chaining.

clearNumCompleteTasks

public StoreTypes.StageData.Builder clearNumCompleteTasks()

int32 num_complete_tasks = 6;

Returns:

This builder for chaining.

getNumFailedTasks

public int getNumFailedTasks()

int32 num_failed_tasks = 7;

Specified by:

getNumFailedTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numFailedTasks.

setNumFailedTasks

public StoreTypes.StageData.Builder setNumFailedTasks(int value)

int32 num_failed_tasks = 7;

Parameters:

value - The numFailedTasks to set.

Returns:

This builder for chaining.

clearNumFailedTasks

public StoreTypes.StageData.Builder clearNumFailedTasks()

int32 num_failed_tasks = 7;

Returns:

This builder for chaining.

getNumKilledTasks

public int getNumKilledTasks()

int32 num_killed_tasks = 8;

Specified by:

getNumKilledTasks in interface StoreTypes.StageDataOrBuilder

Returns:

The numKilledTasks.

setNumKilledTasks

public StoreTypes.StageData.Builder setNumKilledTasks(int value)

int32 num_killed_tasks = 8;

Parameters:

value - The numKilledTasks to set.

Returns:

This builder for chaining.

clearNumKilledTasks

public StoreTypes.StageData.Builder clearNumKilledTasks()

int32 num_killed_tasks = 8;

Returns:

This builder for chaining.

getNumCompletedIndices

public int getNumCompletedIndices()

int32 num_completed_indices = 9;

Specified by:

getNumCompletedIndices in interface StoreTypes.StageDataOrBuilder

Returns:

The numCompletedIndices.

setNumCompletedIndices

public StoreTypes.StageData.Builder setNumCompletedIndices(int value)

int32 num_completed_indices = 9;

Parameters:

value - The numCompletedIndices to set.

Returns:

This builder for chaining.

clearNumCompletedIndices

public StoreTypes.StageData.Builder clearNumCompletedIndices()

int32 num_completed_indices = 9;

Returns:

This builder for chaining.

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.

setSubmissionTime

public StoreTypes.StageData.Builder setSubmissionTime(long value)

optional int64 submission_time = 10;

Parameters:

value - The submissionTime to set.

Returns:

This builder for chaining.

clearSubmissionTime

public StoreTypes.StageData.Builder clearSubmissionTime()

optional int64 submission_time = 10;

Returns:

This builder for chaining.

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.

setFirstTaskLaunchedTime

public StoreTypes.StageData.Builder setFirstTaskLaunchedTime(long value)

optional int64 first_task_launched_time = 11;

Parameters:

value - The firstTaskLaunchedTime to set.

Returns:

This builder for chaining.

clearFirstTaskLaunchedTime

public StoreTypes.StageData.Builder clearFirstTaskLaunchedTime()

optional int64 first_task_launched_time = 11;

Returns:

This builder for chaining.

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.

setCompletionTime

public StoreTypes.StageData.Builder setCompletionTime(long value)

optional int64 completion_time = 12;

Parameters:

value - The completionTime to set.

Returns:

This builder for chaining.

clearCompletionTime

public StoreTypes.StageData.Builder clearCompletionTime()

optional int64 completion_time = 12;

Returns:

This builder for chaining.

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.

setFailureReason

public StoreTypes.StageData.Builder setFailureReason(String value)

optional string failure_reason = 13;

Parameters:

value - The failureReason to set.

Returns:

This builder for chaining.

clearFailureReason

public StoreTypes.StageData.Builder clearFailureReason()

optional string failure_reason = 13;

Returns:

This builder for chaining.

setFailureReasonBytes

public StoreTypes.StageData.Builder setFailureReasonBytes(com.google.protobuf.ByteString value)

optional string failure_reason = 13;

Parameters:

value - The bytes for failureReason to set.

Returns:

This builder for chaining.

getExecutorDeserializeTime

public long getExecutorDeserializeTime()

int64 executor_deserialize_time = 14;

Specified by:

getExecutorDeserializeTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorDeserializeTime.

setExecutorDeserializeTime

public StoreTypes.StageData.Builder setExecutorDeserializeTime(long value)

int64 executor_deserialize_time = 14;

Parameters:

value - The executorDeserializeTime to set.

Returns:

This builder for chaining.

clearExecutorDeserializeTime

public StoreTypes.StageData.Builder clearExecutorDeserializeTime()

int64 executor_deserialize_time = 14;

Returns:

This builder for chaining.

getExecutorDeserializeCpuTime

public long getExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 15;

Specified by:

getExecutorDeserializeCpuTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorDeserializeCpuTime.

setExecutorDeserializeCpuTime

public StoreTypes.StageData.Builder setExecutorDeserializeCpuTime(long value)

int64 executor_deserialize_cpu_time = 15;

Parameters:

value - The executorDeserializeCpuTime to set.

Returns:

This builder for chaining.

clearExecutorDeserializeCpuTime

public StoreTypes.StageData.Builder clearExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 15;

Returns:

This builder for chaining.

getExecutorRunTime

public long getExecutorRunTime()

int64 executor_run_time = 16;

Specified by:

getExecutorRunTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorRunTime.

setExecutorRunTime

public StoreTypes.StageData.Builder setExecutorRunTime(long value)

int64 executor_run_time = 16;

Parameters:

value - The executorRunTime to set.

Returns:

This builder for chaining.

clearExecutorRunTime

public StoreTypes.StageData.Builder clearExecutorRunTime()

int64 executor_run_time = 16;

Returns:

This builder for chaining.

getExecutorCpuTime

public long getExecutorCpuTime()

int64 executor_cpu_time = 17;

Specified by:

getExecutorCpuTime in interface StoreTypes.StageDataOrBuilder

Returns:

The executorCpuTime.

setExecutorCpuTime

public StoreTypes.StageData.Builder setExecutorCpuTime(long value)

int64 executor_cpu_time = 17;

Parameters:

value - The executorCpuTime to set.

Returns:

This builder for chaining.

clearExecutorCpuTime

public StoreTypes.StageData.Builder clearExecutorCpuTime()

int64 executor_cpu_time = 17;

Returns:

This builder for chaining.

getResultSize

public long getResultSize()

int64 result_size = 18;

Specified by:

getResultSize in interface StoreTypes.StageDataOrBuilder

Returns:

The resultSize.

setResultSize

public StoreTypes.StageData.Builder setResultSize(long value)

int64 result_size = 18;

Parameters:

value - The resultSize to set.

Returns:

This builder for chaining.

clearResultSize

public StoreTypes.StageData.Builder clearResultSize()

int64 result_size = 18;

Returns:

This builder for chaining.

getJvmGcTime

public long getJvmGcTime()

int64 jvm_gc_time = 19;

Specified by:

getJvmGcTime in interface StoreTypes.StageDataOrBuilder

Returns:

The jvmGcTime.

setJvmGcTime

public StoreTypes.StageData.Builder setJvmGcTime(long value)

int64 jvm_gc_time = 19;

Parameters:

value - The jvmGcTime to set.

Returns:

This builder for chaining.

clearJvmGcTime

public StoreTypes.StageData.Builder clearJvmGcTime()

int64 jvm_gc_time = 19;

Returns:

This builder for chaining.

getResultSerializationTime

public long getResultSerializationTime()

int64 result_serialization_time = 20;

Specified by:

getResultSerializationTime in interface StoreTypes.StageDataOrBuilder

Returns:

The resultSerializationTime.

setResultSerializationTime

public StoreTypes.StageData.Builder setResultSerializationTime(long value)

int64 result_serialization_time = 20;

Parameters:

value - The resultSerializationTime to set.

Returns:

This builder for chaining.

clearResultSerializationTime

public StoreTypes.StageData.Builder clearResultSerializationTime()

int64 result_serialization_time = 20;

Returns:

This builder for chaining.

getMemoryBytesSpilled

public long getMemoryBytesSpilled()

int64 memory_bytes_spilled = 21;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.StageDataOrBuilder

Returns:

The memoryBytesSpilled.

setMemoryBytesSpilled

public StoreTypes.StageData.Builder setMemoryBytesSpilled(long value)

int64 memory_bytes_spilled = 21;

Parameters:

value - The memoryBytesSpilled to set.

Returns:

This builder for chaining.

clearMemoryBytesSpilled

public StoreTypes.StageData.Builder clearMemoryBytesSpilled()

int64 memory_bytes_spilled = 21;

Returns:

This builder for chaining.

getDiskBytesSpilled

public long getDiskBytesSpilled()

int64 disk_bytes_spilled = 22;

Specified by:

getDiskBytesSpilled in interface StoreTypes.StageDataOrBuilder

Returns:

The diskBytesSpilled.

setDiskBytesSpilled

public StoreTypes.StageData.Builder setDiskBytesSpilled(long value)

int64 disk_bytes_spilled = 22;

Parameters:

value - The diskBytesSpilled to set.

Returns:

This builder for chaining.

clearDiskBytesSpilled

public StoreTypes.StageData.Builder clearDiskBytesSpilled()

int64 disk_bytes_spilled = 22;

Returns:

This builder for chaining.

getPeakExecutionMemory

public long getPeakExecutionMemory()

int64 peak_execution_memory = 23;

Specified by:

getPeakExecutionMemory in interface StoreTypes.StageDataOrBuilder

Returns:

The peakExecutionMemory.

setPeakExecutionMemory

public StoreTypes.StageData.Builder setPeakExecutionMemory(long value)

int64 peak_execution_memory = 23;

Parameters:

value - The peakExecutionMemory to set.

Returns:

This builder for chaining.

clearPeakExecutionMemory

public StoreTypes.StageData.Builder clearPeakExecutionMemory()

int64 peak_execution_memory = 23;

Returns:

This builder for chaining.

getInputBytes

public long getInputBytes()

int64 input_bytes = 24;

Specified by:

getInputBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The inputBytes.

setInputBytes

public StoreTypes.StageData.Builder setInputBytes(long value)

int64 input_bytes = 24;

Parameters:

value - The inputBytes to set.

Returns:

This builder for chaining.

clearInputBytes

public StoreTypes.StageData.Builder clearInputBytes()

int64 input_bytes = 24;

Returns:

This builder for chaining.

getInputRecords

public long getInputRecords()

int64 input_records = 25;

Specified by:

getInputRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The inputRecords.

setInputRecords

public StoreTypes.StageData.Builder setInputRecords(long value)

int64 input_records = 25;

Parameters:

value - The inputRecords to set.

Returns:

This builder for chaining.

clearInputRecords

public StoreTypes.StageData.Builder clearInputRecords()

int64 input_records = 25;

Returns:

This builder for chaining.

getOutputBytes

public long getOutputBytes()

int64 output_bytes = 26;

Specified by:

getOutputBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The outputBytes.

setOutputBytes

public StoreTypes.StageData.Builder setOutputBytes(long value)

int64 output_bytes = 26;

Parameters:

value - The outputBytes to set.

Returns:

This builder for chaining.

clearOutputBytes

public StoreTypes.StageData.Builder clearOutputBytes()

int64 output_bytes = 26;

Returns:

This builder for chaining.

getOutputRecords

public long getOutputRecords()

int64 output_records = 27;

Specified by:

getOutputRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The outputRecords.

setOutputRecords

public StoreTypes.StageData.Builder setOutputRecords(long value)

int64 output_records = 27;

Parameters:

value - The outputRecords to set.

Returns:

This builder for chaining.

clearOutputRecords

public StoreTypes.StageData.Builder clearOutputRecords()

int64 output_records = 27;

Returns:

This builder for chaining.

getShuffleRemoteBlocksFetched

public long getShuffleRemoteBlocksFetched()

int64 shuffle_remote_blocks_fetched = 28;

Specified by:

getShuffleRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteBlocksFetched.

setShuffleRemoteBlocksFetched

public StoreTypes.StageData.Builder setShuffleRemoteBlocksFetched(long value)

int64 shuffle_remote_blocks_fetched = 28;

Parameters:

value - The shuffleRemoteBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleRemoteBlocksFetched

public StoreTypes.StageData.Builder clearShuffleRemoteBlocksFetched()

int64 shuffle_remote_blocks_fetched = 28;

Returns:

This builder for chaining.

getShuffleLocalBlocksFetched

public long getShuffleLocalBlocksFetched()

int64 shuffle_local_blocks_fetched = 29;

Specified by:

getShuffleLocalBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleLocalBlocksFetched.

setShuffleLocalBlocksFetched

public StoreTypes.StageData.Builder setShuffleLocalBlocksFetched(long value)

int64 shuffle_local_blocks_fetched = 29;

Parameters:

value - The shuffleLocalBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleLocalBlocksFetched

public StoreTypes.StageData.Builder clearShuffleLocalBlocksFetched()

int64 shuffle_local_blocks_fetched = 29;

Returns:

This builder for chaining.

getShuffleFetchWaitTime

public long getShuffleFetchWaitTime()

int64 shuffle_fetch_wait_time = 30;

Specified by:

getShuffleFetchWaitTime in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleFetchWaitTime.

setShuffleFetchWaitTime

public StoreTypes.StageData.Builder setShuffleFetchWaitTime(long value)

int64 shuffle_fetch_wait_time = 30;

Parameters:

value - The shuffleFetchWaitTime to set.

Returns:

This builder for chaining.

clearShuffleFetchWaitTime

public StoreTypes.StageData.Builder clearShuffleFetchWaitTime()

int64 shuffle_fetch_wait_time = 30;

Returns:

This builder for chaining.

getShuffleRemoteBytesRead

public long getShuffleRemoteBytesRead()

int64 shuffle_remote_bytes_read = 31;

Specified by:

getShuffleRemoteBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteBytesRead.

setShuffleRemoteBytesRead

public StoreTypes.StageData.Builder setShuffleRemoteBytesRead(long value)

int64 shuffle_remote_bytes_read = 31;

Parameters:

value - The shuffleRemoteBytesRead to set.

Returns:

This builder for chaining.

clearShuffleRemoteBytesRead

public StoreTypes.StageData.Builder clearShuffleRemoteBytesRead()

int64 shuffle_remote_bytes_read = 31;

Returns:

This builder for chaining.

getShuffleRemoteBytesReadToDisk

public long getShuffleRemoteBytesReadToDisk()

int64 shuffle_remote_bytes_read_to_disk = 32;

Specified by:

getShuffleRemoteBytesReadToDisk in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteBytesReadToDisk.

setShuffleRemoteBytesReadToDisk

public StoreTypes.StageData.Builder setShuffleRemoteBytesReadToDisk(long value)

int64 shuffle_remote_bytes_read_to_disk = 32;

Parameters:

value - The shuffleRemoteBytesReadToDisk to set.

Returns:

This builder for chaining.

clearShuffleRemoteBytesReadToDisk

public StoreTypes.StageData.Builder clearShuffleRemoteBytesReadToDisk()

int64 shuffle_remote_bytes_read_to_disk = 32;

Returns:

This builder for chaining.

getShuffleLocalBytesRead

public long getShuffleLocalBytesRead()

int64 shuffle_local_bytes_read = 33;

Specified by:

getShuffleLocalBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleLocalBytesRead.

setShuffleLocalBytesRead

public StoreTypes.StageData.Builder setShuffleLocalBytesRead(long value)

int64 shuffle_local_bytes_read = 33;

Parameters:

value - The shuffleLocalBytesRead to set.

Returns:

This builder for chaining.

clearShuffleLocalBytesRead

public StoreTypes.StageData.Builder clearShuffleLocalBytesRead()

int64 shuffle_local_bytes_read = 33;

Returns:

This builder for chaining.

getShuffleReadBytes

public long getShuffleReadBytes()

int64 shuffle_read_bytes = 34;

Specified by:

getShuffleReadBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleReadBytes.

setShuffleReadBytes

public StoreTypes.StageData.Builder setShuffleReadBytes(long value)

int64 shuffle_read_bytes = 34;

Parameters:

value - The shuffleReadBytes to set.

Returns:

This builder for chaining.

clearShuffleReadBytes

public StoreTypes.StageData.Builder clearShuffleReadBytes()

int64 shuffle_read_bytes = 34;

Returns:

This builder for chaining.

getShuffleReadRecords

public long getShuffleReadRecords()

int64 shuffle_read_records = 35;

Specified by:

getShuffleReadRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleReadRecords.

setShuffleReadRecords

public StoreTypes.StageData.Builder setShuffleReadRecords(long value)

int64 shuffle_read_records = 35;

Parameters:

value - The shuffleReadRecords to set.

Returns:

This builder for chaining.

clearShuffleReadRecords

public StoreTypes.StageData.Builder clearShuffleReadRecords()

int64 shuffle_read_records = 35;

Returns:

This builder for chaining.

getShuffleWriteBytes

public long getShuffleWriteBytes()

int64 shuffle_write_bytes = 36;

Specified by:

getShuffleWriteBytes in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleWriteBytes.

setShuffleWriteBytes

public StoreTypes.StageData.Builder setShuffleWriteBytes(long value)

int64 shuffle_write_bytes = 36;

Parameters:

value - The shuffleWriteBytes to set.

Returns:

This builder for chaining.

clearShuffleWriteBytes

public StoreTypes.StageData.Builder clearShuffleWriteBytes()

int64 shuffle_write_bytes = 36;

Returns:

This builder for chaining.

getShuffleWriteTime

public long getShuffleWriteTime()

int64 shuffle_write_time = 37;

Specified by:

getShuffleWriteTime in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleWriteTime.

setShuffleWriteTime

public StoreTypes.StageData.Builder setShuffleWriteTime(long value)

int64 shuffle_write_time = 37;

Parameters:

value - The shuffleWriteTime to set.

Returns:

This builder for chaining.

clearShuffleWriteTime

public StoreTypes.StageData.Builder clearShuffleWriteTime()

int64 shuffle_write_time = 37;

Returns:

This builder for chaining.

getShuffleWriteRecords

public long getShuffleWriteRecords()

int64 shuffle_write_records = 38;

Specified by:

getShuffleWriteRecords in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleWriteRecords.

setShuffleWriteRecords

public StoreTypes.StageData.Builder setShuffleWriteRecords(long value)

int64 shuffle_write_records = 38;

Parameters:

value - The shuffleWriteRecords to set.

Returns:

This builder for chaining.

clearShuffleWriteRecords

public StoreTypes.StageData.Builder clearShuffleWriteRecords()

int64 shuffle_write_records = 38;

Returns:

This builder for chaining.

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.

setName

public StoreTypes.StageData.Builder setName(String value)

optional string name = 39;

Parameters:

value - The name to set.

Returns:

This builder for chaining.

clearName

public StoreTypes.StageData.Builder clearName()

optional string name = 39;

Returns:

This builder for chaining.

setNameBytes

public StoreTypes.StageData.Builder setNameBytes(com.google.protobuf.ByteString value)

optional string name = 39;

Parameters:

value - The bytes for name to set.

Returns:

This builder for chaining.

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.

setDescription

public StoreTypes.StageData.Builder setDescription(String value)

optional string description = 40;

Parameters:

value - The description to set.

Returns:

This builder for chaining.

clearDescription

public StoreTypes.StageData.Builder clearDescription()

optional string description = 40;

Returns:

This builder for chaining.

setDescriptionBytes

public StoreTypes.StageData.Builder setDescriptionBytes(com.google.protobuf.ByteString value)

optional string description = 40;

Parameters:

value - The bytes for description to set.

Returns:

This builder for chaining.

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.

setDetails

public StoreTypes.StageData.Builder setDetails(String value)

optional string details = 41;

Parameters:

value - The details to set.

Returns:

This builder for chaining.

clearDetails

public StoreTypes.StageData.Builder clearDetails()

optional string details = 41;

Returns:

This builder for chaining.

setDetailsBytes

public StoreTypes.StageData.Builder setDetailsBytes(com.google.protobuf.ByteString value)

optional string details = 41;

Parameters:

value - The bytes for details to set.

Returns:

This builder for chaining.

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.

setSchedulingPool

public StoreTypes.StageData.Builder setSchedulingPool(String value)

optional string scheduling_pool = 42;

Parameters:

value - The schedulingPool to set.

Returns:

This builder for chaining.

clearSchedulingPool

public StoreTypes.StageData.Builder clearSchedulingPool()

optional string scheduling_pool = 42;

Returns:

This builder for chaining.

setSchedulingPoolBytes

public StoreTypes.StageData.Builder setSchedulingPoolBytes(com.google.protobuf.ByteString value)

optional string scheduling_pool = 42;

Parameters:

value - The bytes for schedulingPool to set.

Returns:

This builder for chaining.

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.

setRddIds

public StoreTypes.StageData.Builder setRddIds(int index,
 long value)

repeated int64 rdd_ids = 43;

Parameters:

index - The index to set the value at.

value - The rddIds to set.

Returns:

This builder for chaining.

addRddIds

public StoreTypes.StageData.Builder addRddIds(long value)

repeated int64 rdd_ids = 43;

Parameters:

value - The rddIds to add.

Returns:

This builder for chaining.

addAllRddIds

public StoreTypes.StageData.Builder addAllRddIds(Iterable<? extends Long> values)

repeated int64 rdd_ids = 43;

Parameters:

values - The rddIds to add.

Returns:

This builder for chaining.

clearRddIds

public StoreTypes.StageData.Builder clearRddIds()

repeated int64 rdd_ids = 43;

Returns:

This builder for chaining.

getAccumulatorUpdatesList

public List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()

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

Specified by:

getAccumulatorUpdatesList 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

setAccumulatorUpdates

public StoreTypes.StageData.Builder setAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo value)

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

setAccumulatorUpdates

public StoreTypes.StageData.Builder setAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo.Builder builderForValue)

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

addAccumulatorUpdates

public StoreTypes.StageData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo value)

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

addAccumulatorUpdates

public StoreTypes.StageData.Builder addAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo value)

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

addAccumulatorUpdates

public StoreTypes.StageData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)

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

addAccumulatorUpdates

public StoreTypes.StageData.Builder addAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo.Builder builderForValue)

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

addAllAccumulatorUpdates

public StoreTypes.StageData.Builder addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)

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

clearAccumulatorUpdates

public StoreTypes.StageData.Builder clearAccumulatorUpdates()

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

removeAccumulatorUpdates

public StoreTypes.StageData.Builder removeAccumulatorUpdates(int index)

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

getAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder getAccumulatorUpdatesBuilder(int index)

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

getAccumulatorUpdatesOrBuilder

public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)

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

Specified by:

getAccumulatorUpdatesOrBuilder 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

addAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder()

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

addAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder(int index)

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

getAccumulatorUpdatesBuilderList

public List<StoreTypes.AccumulableInfo.Builder> getAccumulatorUpdatesBuilderList()

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

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

clearTasks

public StoreTypes.StageData.Builder clearTasks()

removeTasks

public StoreTypes.StageData.Builder removeTasks(long key)

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

getMutableTasks

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

Deprecated.

Use alternate mutation accessors instead.

putTasks

public StoreTypes.StageData.Builder putTasks(long key,
 StoreTypes.TaskData value)

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

putAllTasks

public StoreTypes.StageData.Builder putAllTasks(Map<Long,StoreTypes.TaskData> values)

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

putTasksBuilderIfAbsent

public StoreTypes.TaskData.Builder putTasksBuilderIfAbsent(long key)

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

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

clearExecutorSummary

public StoreTypes.StageData.Builder clearExecutorSummary()

removeExecutorSummary

public StoreTypes.StageData.Builder removeExecutorSummary(String key)

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

getMutableExecutorSummary

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

Deprecated.

Use alternate mutation accessors instead.

putExecutorSummary

public StoreTypes.StageData.Builder putExecutorSummary(String key,
 StoreTypes.ExecutorStageSummary value)

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

putAllExecutorSummary

public StoreTypes.StageData.Builder putAllExecutorSummary(Map<String,StoreTypes.ExecutorStageSummary> values)

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

putExecutorSummaryBuilderIfAbsent

public StoreTypes.ExecutorStageSummary.Builder putExecutorSummaryBuilderIfAbsent(String key)

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

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.

setSpeculationSummary

public StoreTypes.StageData.Builder setSpeculationSummary(StoreTypes.SpeculationStageSummary value)

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

setSpeculationSummary

public StoreTypes.StageData.Builder setSpeculationSummary(StoreTypes.SpeculationStageSummary.Builder builderForValue)

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

mergeSpeculationSummary

public StoreTypes.StageData.Builder mergeSpeculationSummary(StoreTypes.SpeculationStageSummary value)

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

clearSpeculationSummary

public StoreTypes.StageData.Builder clearSpeculationSummary()

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

getSpeculationSummaryBuilder

public StoreTypes.SpeculationStageSummary.Builder getSpeculationSummaryBuilder()

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

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

clearKilledTasksSummary

public StoreTypes.StageData.Builder clearKilledTasksSummary()

removeKilledTasksSummary

public StoreTypes.StageData.Builder removeKilledTasksSummary(String key)

map<string, int32> killed_tasks_summary = 48;

getMutableKilledTasksSummary

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

Deprecated.

Use alternate mutation accessors instead.

putKilledTasksSummary

public StoreTypes.StageData.Builder putKilledTasksSummary(String key,
 int value)

map<string, int32> killed_tasks_summary = 48;

putAllKilledTasksSummary

public StoreTypes.StageData.Builder putAllKilledTasksSummary(Map<String,Integer> values)

map<string, int32> killed_tasks_summary = 48;

getResourceProfileId

public int getResourceProfileId()

int32 resource_profile_id = 49;

Specified by:

getResourceProfileId in interface StoreTypes.StageDataOrBuilder

Returns:

The resourceProfileId.

setResourceProfileId

public StoreTypes.StageData.Builder setResourceProfileId(int value)

int32 resource_profile_id = 49;

Parameters:

value - The resourceProfileId to set.

Returns:

This builder for chaining.

clearResourceProfileId

public StoreTypes.StageData.Builder clearResourceProfileId()

int32 resource_profile_id = 49;

Returns:

This builder for chaining.

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.

setPeakExecutorMetrics

public StoreTypes.StageData.Builder setPeakExecutorMetrics(StoreTypes.ExecutorMetrics value)

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

setPeakExecutorMetrics

public StoreTypes.StageData.Builder setPeakExecutorMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue)

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

mergePeakExecutorMetrics

public StoreTypes.StageData.Builder mergePeakExecutorMetrics(StoreTypes.ExecutorMetrics value)

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

clearPeakExecutorMetrics

public StoreTypes.StageData.Builder clearPeakExecutorMetrics()

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

getPeakExecutorMetricsBuilder

public StoreTypes.ExecutorMetrics.Builder getPeakExecutorMetricsBuilder()

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

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.

setTaskMetricsDistributions

public StoreTypes.StageData.Builder setTaskMetricsDistributions(StoreTypes.TaskMetricDistributions value)

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

setTaskMetricsDistributions

public StoreTypes.StageData.Builder setTaskMetricsDistributions(StoreTypes.TaskMetricDistributions.Builder builderForValue)

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

mergeTaskMetricsDistributions

public StoreTypes.StageData.Builder mergeTaskMetricsDistributions(StoreTypes.TaskMetricDistributions value)

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

clearTaskMetricsDistributions

public StoreTypes.StageData.Builder clearTaskMetricsDistributions()

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

getTaskMetricsDistributionsBuilder

public StoreTypes.TaskMetricDistributions.Builder getTaskMetricsDistributionsBuilder()

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

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.

setExecutorMetricsDistributions

public StoreTypes.StageData.Builder setExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions value)

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

setExecutorMetricsDistributions

public StoreTypes.StageData.Builder setExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions.Builder builderForValue)

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

mergeExecutorMetricsDistributions

public StoreTypes.StageData.Builder mergeExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions value)

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

clearExecutorMetricsDistributions

public StoreTypes.StageData.Builder clearExecutorMetricsDistributions()

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

getExecutorMetricsDistributionsBuilder

public StoreTypes.ExecutorMetricsDistributions.Builder getExecutorMetricsDistributionsBuilder()

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

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.

setShuffleCorruptMergedBlockChunks

public StoreTypes.StageData.Builder setShuffleCorruptMergedBlockChunks(long value)

int64 shuffle_corrupt_merged_block_chunks = 53;

Parameters:

value - The shuffleCorruptMergedBlockChunks to set.

Returns:

This builder for chaining.

clearShuffleCorruptMergedBlockChunks

public StoreTypes.StageData.Builder clearShuffleCorruptMergedBlockChunks()

int64 shuffle_corrupt_merged_block_chunks = 53;

Returns:

This builder for chaining.

getShuffleMergedFetchFallbackCount

public long getShuffleMergedFetchFallbackCount()

int64 shuffle_merged_fetch_fallback_count = 54;

Specified by:

getShuffleMergedFetchFallbackCount in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedFetchFallbackCount.

setShuffleMergedFetchFallbackCount

public StoreTypes.StageData.Builder setShuffleMergedFetchFallbackCount(long value)

int64 shuffle_merged_fetch_fallback_count = 54;

Parameters:

value - The shuffleMergedFetchFallbackCount to set.

Returns:

This builder for chaining.

clearShuffleMergedFetchFallbackCount

public StoreTypes.StageData.Builder clearShuffleMergedFetchFallbackCount()

int64 shuffle_merged_fetch_fallback_count = 54;

Returns:

This builder for chaining.

getShuffleMergedRemoteBlocksFetched

public long getShuffleMergedRemoteBlocksFetched()

int64 shuffle_merged_remote_blocks_fetched = 55;

Specified by:

getShuffleMergedRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteBlocksFetched.

setShuffleMergedRemoteBlocksFetched

public StoreTypes.StageData.Builder setShuffleMergedRemoteBlocksFetched(long value)

int64 shuffle_merged_remote_blocks_fetched = 55;

Parameters:

value - The shuffleMergedRemoteBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteBlocksFetched

public StoreTypes.StageData.Builder clearShuffleMergedRemoteBlocksFetched()

int64 shuffle_merged_remote_blocks_fetched = 55;

Returns:

This builder for chaining.

getShuffleMergedLocalBlocksFetched

public long getShuffleMergedLocalBlocksFetched()

int64 shuffle_merged_local_blocks_fetched = 56;

Specified by:

getShuffleMergedLocalBlocksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedLocalBlocksFetched.

setShuffleMergedLocalBlocksFetched

public StoreTypes.StageData.Builder setShuffleMergedLocalBlocksFetched(long value)

int64 shuffle_merged_local_blocks_fetched = 56;

Parameters:

value - The shuffleMergedLocalBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedLocalBlocksFetched

public StoreTypes.StageData.Builder clearShuffleMergedLocalBlocksFetched()

int64 shuffle_merged_local_blocks_fetched = 56;

Returns:

This builder for chaining.

getShuffleMergedRemoteChunksFetched

public long getShuffleMergedRemoteChunksFetched()

int64 shuffle_merged_remote_chunks_fetched = 57;

Specified by:

getShuffleMergedRemoteChunksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteChunksFetched.

setShuffleMergedRemoteChunksFetched

public StoreTypes.StageData.Builder setShuffleMergedRemoteChunksFetched(long value)

int64 shuffle_merged_remote_chunks_fetched = 57;

Parameters:

value - The shuffleMergedRemoteChunksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteChunksFetched

public StoreTypes.StageData.Builder clearShuffleMergedRemoteChunksFetched()

int64 shuffle_merged_remote_chunks_fetched = 57;

Returns:

This builder for chaining.

getShuffleMergedLocalChunksFetched

public long getShuffleMergedLocalChunksFetched()

int64 shuffle_merged_local_chunks_fetched = 58;

Specified by:

getShuffleMergedLocalChunksFetched in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedLocalChunksFetched.

setShuffleMergedLocalChunksFetched

public StoreTypes.StageData.Builder setShuffleMergedLocalChunksFetched(long value)

int64 shuffle_merged_local_chunks_fetched = 58;

Parameters:

value - The shuffleMergedLocalChunksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedLocalChunksFetched

public StoreTypes.StageData.Builder clearShuffleMergedLocalChunksFetched()

int64 shuffle_merged_local_chunks_fetched = 58;

Returns:

This builder for chaining.

getShuffleMergedRemoteBytesRead

public long getShuffleMergedRemoteBytesRead()

int64 shuffle_merged_remote_bytes_read = 59;

Specified by:

getShuffleMergedRemoteBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteBytesRead.

setShuffleMergedRemoteBytesRead

public StoreTypes.StageData.Builder setShuffleMergedRemoteBytesRead(long value)

int64 shuffle_merged_remote_bytes_read = 59;

Parameters:

value - The shuffleMergedRemoteBytesRead to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteBytesRead

public StoreTypes.StageData.Builder clearShuffleMergedRemoteBytesRead()

int64 shuffle_merged_remote_bytes_read = 59;

Returns:

This builder for chaining.

getShuffleMergedLocalBytesRead

public long getShuffleMergedLocalBytesRead()

int64 shuffle_merged_local_bytes_read = 60;

Specified by:

getShuffleMergedLocalBytesRead in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedLocalBytesRead.

setShuffleMergedLocalBytesRead

public StoreTypes.StageData.Builder setShuffleMergedLocalBytesRead(long value)

int64 shuffle_merged_local_bytes_read = 60;

Parameters:

value - The shuffleMergedLocalBytesRead to set.

Returns:

This builder for chaining.

clearShuffleMergedLocalBytesRead

public StoreTypes.StageData.Builder clearShuffleMergedLocalBytesRead()

int64 shuffle_merged_local_bytes_read = 60;

Returns:

This builder for chaining.

getShuffleRemoteReqsDuration

public long getShuffleRemoteReqsDuration()

int64 shuffle_remote_reqs_duration = 61;

Specified by:

getShuffleRemoteReqsDuration in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleRemoteReqsDuration.

setShuffleRemoteReqsDuration

public StoreTypes.StageData.Builder setShuffleRemoteReqsDuration(long value)

int64 shuffle_remote_reqs_duration = 61;

Parameters:

value - The shuffleRemoteReqsDuration to set.

Returns:

This builder for chaining.

clearShuffleRemoteReqsDuration

public StoreTypes.StageData.Builder clearShuffleRemoteReqsDuration()

int64 shuffle_remote_reqs_duration = 61;

Returns:

This builder for chaining.

getShuffleMergedRemoteReqsDuration

public long getShuffleMergedRemoteReqsDuration()

int64 shuffle_merged_remote_reqs_duration = 62;

Specified by:

getShuffleMergedRemoteReqsDuration in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergedRemoteReqsDuration.

setShuffleMergedRemoteReqsDuration

public StoreTypes.StageData.Builder setShuffleMergedRemoteReqsDuration(long value)

int64 shuffle_merged_remote_reqs_duration = 62;

Parameters:

value - The shuffleMergedRemoteReqsDuration to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteReqsDuration

public StoreTypes.StageData.Builder clearShuffleMergedRemoteReqsDuration()

int64 shuffle_merged_remote_reqs_duration = 62;

Returns:

This builder for chaining.

getIsShufflePushEnabled

public boolean getIsShufflePushEnabled()

bool is_shuffle_push_enabled = 63;

Specified by:

getIsShufflePushEnabled in interface StoreTypes.StageDataOrBuilder

Returns:

The isShufflePushEnabled.

setIsShufflePushEnabled

public StoreTypes.StageData.Builder setIsShufflePushEnabled(boolean value)

bool is_shuffle_push_enabled = 63;

Parameters:

value - The isShufflePushEnabled to set.

Returns:

This builder for chaining.

clearIsShufflePushEnabled

public StoreTypes.StageData.Builder clearIsShufflePushEnabled()

bool is_shuffle_push_enabled = 63;

Returns:

This builder for chaining.

getShuffleMergersCount

public int getShuffleMergersCount()

int32 shuffle_mergers_count = 64;

Specified by:

getShuffleMergersCount in interface StoreTypes.StageDataOrBuilder

Returns:

The shuffleMergersCount.

setShuffleMergersCount

public StoreTypes.StageData.Builder setShuffleMergersCount(int value)

int32 shuffle_mergers_count = 64;

Parameters:

value - The shuffleMergersCount to set.

Returns:

This builder for chaining.

clearShuffleMergersCount

public StoreTypes.StageData.Builder clearShuffleMergersCount()

int32 shuffle_mergers_count = 64;

Returns:

This builder for chaining.