public static final class StoreTypes.StageData.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder> implements StoreTypes.StageDataOrBuilder
org.apache.spark.status.protobuf.StageData| Modifier and Type | Method and Description |
|---|---|
StoreTypes.StageData.Builder |
addAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44; |
StoreTypes.StageData.Builder |
addAccumulatorUpdates(int index,
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.StageData.Builder |
addAccumulatorUpdates(StoreTypes.AccumulableInfo value)
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.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
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 |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
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 |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
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() |
StoreTypes.StageData.Builder |
clone() |
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; |
java.util.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; |
java.util.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; |
java.util.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 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; |
java.util.Map<String,StoreTypes.ExecutorStageSummary> |
getExecutorSummary()
Deprecated.
|
int |
getExecutorSummaryCount()
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46; |
java.util.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; |
java.util.Map<String,Integer> |
getKilledTasksSummary()
Deprecated.
|
int |
getKilledTasksSummaryCount()
map<string, int32> killed_tasks_summary = 48; |
java.util.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; |
java.util.Map<String,StoreTypes.ExecutorStageSummary> |
getMutableExecutorSummary()
Deprecated.
|
java.util.Map<String,Integer> |
getMutableKilledTasksSummary()
Deprecated.
|
java.util.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; |
java.util.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; |
java.util.Map<Long,StoreTypes.TaskData> |
getTasks()
Deprecated.
|
int |
getTasksCount()
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45; |
java.util.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; |
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 |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
StoreTypes.StageData.Builder |
putAllExecutorSummary(java.util.Map<String,StoreTypes.ExecutorStageSummary> values)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46; |
StoreTypes.StageData.Builder |
putAllKilledTasksSummary(java.util.Map<String,Integer> values)
map<string, int32> killed_tasks_summary = 48; |
StoreTypes.StageData.Builder |
putAllTasks(java.util.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.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.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.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44; |
StoreTypes.StageData.Builder |
setAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo value)
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.Builder builderForValue)
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52; |
StoreTypes.StageData.Builder |
setExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions value)
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 |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
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.Builder builderForValue)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50; |
StoreTypes.StageData.Builder |
setPeakExecutorMetrics(StoreTypes.ExecutorMetrics value)
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 |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
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.Builder builderForValue)
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47; |
StoreTypes.StageData.Builder |
setSpeculationSummary(StoreTypes.SpeculationStageSummary value)
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.Builder builderForValue)
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51; |
StoreTypes.StageData.Builder |
setTaskMetricsDistributions(StoreTypes.TaskMetricDistributions value)
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51; |
StoreTypes.StageData.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForFieldfindInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toStringpublic static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.StageData.Builder clear()
clear in interface com.google.protobuf.Message.Builderclear in interface com.google.protobuf.MessageLite.Builderclear in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType in interface com.google.protobuf.Message.BuildergetDescriptorForType in interface com.google.protobuf.MessageOrBuildergetDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderpublic StoreTypes.StageData build()
build in interface com.google.protobuf.Message.Builderbuild in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.StageData buildPartial()
buildPartial in interface com.google.protobuf.Message.BuilderbuildPartial in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.StageData.Builder clone()
clone in interface com.google.protobuf.Message.Builderclone in interface com.google.protobuf.MessageLite.Builderclone in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField in interface com.google.protobuf.Message.BuildersetField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField in interface com.google.protobuf.Message.BuilderclearField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof in interface com.google.protobuf.Message.BuilderclearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField in interface com.google.protobuf.Message.BuildersetRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField in interface com.google.protobuf.Message.BuilderaddRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder mergeFrom(StoreTypes.StageData other)
public final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public StoreTypes.StageData.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in interface com.google.protobuf.MessageLite.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StageData.Builder>java.io.IOExceptionpublic int getStatusValue()
.org.apache.spark.status.protobuf.StageStatus status = 1;getStatusValue in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setStatusValue(int value)
.org.apache.spark.status.protobuf.StageStatus status = 1;value - The enum numeric value on the wire for status to set.public StoreTypes.StageStatus getStatus()
.org.apache.spark.status.protobuf.StageStatus status = 1;getStatus in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setStatus(StoreTypes.StageStatus value)
.org.apache.spark.status.protobuf.StageStatus status = 1;value - The status to set.public StoreTypes.StageData.Builder clearStatus()
.org.apache.spark.status.protobuf.StageStatus status = 1;public long getStageId()
int64 stage_id = 2;getStageId in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setStageId(long value)
int64 stage_id = 2;value - The stageId to set.public StoreTypes.StageData.Builder clearStageId()
int64 stage_id = 2;public int getAttemptId()
int32 attempt_id = 3;getAttemptId in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setAttemptId(int value)
int32 attempt_id = 3;value - The attemptId to set.public StoreTypes.StageData.Builder clearAttemptId()
int32 attempt_id = 3;public int getNumTasks()
int32 num_tasks = 4;getNumTasks in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setNumTasks(int value)
int32 num_tasks = 4;value - The numTasks to set.public StoreTypes.StageData.Builder clearNumTasks()
int32 num_tasks = 4;public int getNumActiveTasks()
int32 num_active_tasks = 5;getNumActiveTasks in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setNumActiveTasks(int value)
int32 num_active_tasks = 5;value - The numActiveTasks to set.public StoreTypes.StageData.Builder clearNumActiveTasks()
int32 num_active_tasks = 5;public int getNumCompleteTasks()
int32 num_complete_tasks = 6;getNumCompleteTasks in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setNumCompleteTasks(int value)
int32 num_complete_tasks = 6;value - The numCompleteTasks to set.public StoreTypes.StageData.Builder clearNumCompleteTasks()
int32 num_complete_tasks = 6;public int getNumFailedTasks()
int32 num_failed_tasks = 7;getNumFailedTasks in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setNumFailedTasks(int value)
int32 num_failed_tasks = 7;value - The numFailedTasks to set.public StoreTypes.StageData.Builder clearNumFailedTasks()
int32 num_failed_tasks = 7;public int getNumKilledTasks()
int32 num_killed_tasks = 8;getNumKilledTasks in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setNumKilledTasks(int value)
int32 num_killed_tasks = 8;value - The numKilledTasks to set.public StoreTypes.StageData.Builder clearNumKilledTasks()
int32 num_killed_tasks = 8;public int getNumCompletedIndices()
int32 num_completed_indices = 9;getNumCompletedIndices in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setNumCompletedIndices(int value)
int32 num_completed_indices = 9;value - The numCompletedIndices to set.public StoreTypes.StageData.Builder clearNumCompletedIndices()
int32 num_completed_indices = 9;public boolean hasSubmissionTime()
optional int64 submission_time = 10;hasSubmissionTime in interface StoreTypes.StageDataOrBuilderpublic long getSubmissionTime()
optional int64 submission_time = 10;getSubmissionTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setSubmissionTime(long value)
optional int64 submission_time = 10;value - The submissionTime to set.public StoreTypes.StageData.Builder clearSubmissionTime()
optional int64 submission_time = 10;public boolean hasFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;hasFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilderpublic long getFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;getFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setFirstTaskLaunchedTime(long value)
optional int64 first_task_launched_time = 11;value - The firstTaskLaunchedTime to set.public StoreTypes.StageData.Builder clearFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;public boolean hasCompletionTime()
optional int64 completion_time = 12;hasCompletionTime in interface StoreTypes.StageDataOrBuilderpublic long getCompletionTime()
optional int64 completion_time = 12;getCompletionTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setCompletionTime(long value)
optional int64 completion_time = 12;value - The completionTime to set.public StoreTypes.StageData.Builder clearCompletionTime()
optional int64 completion_time = 12;public boolean hasFailureReason()
optional string failure_reason = 13;hasFailureReason in interface StoreTypes.StageDataOrBuilderpublic String getFailureReason()
optional string failure_reason = 13;getFailureReason in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getFailureReasonBytes()
optional string failure_reason = 13;getFailureReasonBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setFailureReason(String value)
optional string failure_reason = 13;value - The failureReason to set.public StoreTypes.StageData.Builder clearFailureReason()
optional string failure_reason = 13;public StoreTypes.StageData.Builder setFailureReasonBytes(com.google.protobuf.ByteString value)
optional string failure_reason = 13;value - The bytes for failureReason to set.public long getExecutorDeserializeTime()
int64 executor_deserialize_time = 14;getExecutorDeserializeTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setExecutorDeserializeTime(long value)
int64 executor_deserialize_time = 14;value - The executorDeserializeTime to set.public StoreTypes.StageData.Builder clearExecutorDeserializeTime()
int64 executor_deserialize_time = 14;public long getExecutorDeserializeCpuTime()
int64 executor_deserialize_cpu_time = 15;getExecutorDeserializeCpuTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setExecutorDeserializeCpuTime(long value)
int64 executor_deserialize_cpu_time = 15;value - The executorDeserializeCpuTime to set.public StoreTypes.StageData.Builder clearExecutorDeserializeCpuTime()
int64 executor_deserialize_cpu_time = 15;public long getExecutorRunTime()
int64 executor_run_time = 16;getExecutorRunTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setExecutorRunTime(long value)
int64 executor_run_time = 16;value - The executorRunTime to set.public StoreTypes.StageData.Builder clearExecutorRunTime()
int64 executor_run_time = 16;public long getExecutorCpuTime()
int64 executor_cpu_time = 17;getExecutorCpuTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setExecutorCpuTime(long value)
int64 executor_cpu_time = 17;value - The executorCpuTime to set.public StoreTypes.StageData.Builder clearExecutorCpuTime()
int64 executor_cpu_time = 17;public long getResultSize()
int64 result_size = 18;getResultSize in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setResultSize(long value)
int64 result_size = 18;value - The resultSize to set.public StoreTypes.StageData.Builder clearResultSize()
int64 result_size = 18;public long getJvmGcTime()
int64 jvm_gc_time = 19;getJvmGcTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setJvmGcTime(long value)
int64 jvm_gc_time = 19;value - The jvmGcTime to set.public StoreTypes.StageData.Builder clearJvmGcTime()
int64 jvm_gc_time = 19;public long getResultSerializationTime()
int64 result_serialization_time = 20;getResultSerializationTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setResultSerializationTime(long value)
int64 result_serialization_time = 20;value - The resultSerializationTime to set.public StoreTypes.StageData.Builder clearResultSerializationTime()
int64 result_serialization_time = 20;public long getMemoryBytesSpilled()
int64 memory_bytes_spilled = 21;getMemoryBytesSpilled in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setMemoryBytesSpilled(long value)
int64 memory_bytes_spilled = 21;value - The memoryBytesSpilled to set.public StoreTypes.StageData.Builder clearMemoryBytesSpilled()
int64 memory_bytes_spilled = 21;public long getDiskBytesSpilled()
int64 disk_bytes_spilled = 22;getDiskBytesSpilled in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setDiskBytesSpilled(long value)
int64 disk_bytes_spilled = 22;value - The diskBytesSpilled to set.public StoreTypes.StageData.Builder clearDiskBytesSpilled()
int64 disk_bytes_spilled = 22;public long getPeakExecutionMemory()
int64 peak_execution_memory = 23;getPeakExecutionMemory in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setPeakExecutionMemory(long value)
int64 peak_execution_memory = 23;value - The peakExecutionMemory to set.public StoreTypes.StageData.Builder clearPeakExecutionMemory()
int64 peak_execution_memory = 23;public long getInputBytes()
int64 input_bytes = 24;getInputBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setInputBytes(long value)
int64 input_bytes = 24;value - The inputBytes to set.public StoreTypes.StageData.Builder clearInputBytes()
int64 input_bytes = 24;public long getInputRecords()
int64 input_records = 25;getInputRecords in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setInputRecords(long value)
int64 input_records = 25;value - The inputRecords to set.public StoreTypes.StageData.Builder clearInputRecords()
int64 input_records = 25;public long getOutputBytes()
int64 output_bytes = 26;getOutputBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setOutputBytes(long value)
int64 output_bytes = 26;value - The outputBytes to set.public StoreTypes.StageData.Builder clearOutputBytes()
int64 output_bytes = 26;public long getOutputRecords()
int64 output_records = 27;getOutputRecords in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setOutputRecords(long value)
int64 output_records = 27;value - The outputRecords to set.public StoreTypes.StageData.Builder clearOutputRecords()
int64 output_records = 27;public long getShuffleRemoteBlocksFetched()
int64 shuffle_remote_blocks_fetched = 28;getShuffleRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleRemoteBlocksFetched(long value)
int64 shuffle_remote_blocks_fetched = 28;value - The shuffleRemoteBlocksFetched to set.public StoreTypes.StageData.Builder clearShuffleRemoteBlocksFetched()
int64 shuffle_remote_blocks_fetched = 28;public long getShuffleLocalBlocksFetched()
int64 shuffle_local_blocks_fetched = 29;getShuffleLocalBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleLocalBlocksFetched(long value)
int64 shuffle_local_blocks_fetched = 29;value - The shuffleLocalBlocksFetched to set.public StoreTypes.StageData.Builder clearShuffleLocalBlocksFetched()
int64 shuffle_local_blocks_fetched = 29;public long getShuffleFetchWaitTime()
int64 shuffle_fetch_wait_time = 30;getShuffleFetchWaitTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleFetchWaitTime(long value)
int64 shuffle_fetch_wait_time = 30;value - The shuffleFetchWaitTime to set.public StoreTypes.StageData.Builder clearShuffleFetchWaitTime()
int64 shuffle_fetch_wait_time = 30;public long getShuffleRemoteBytesRead()
int64 shuffle_remote_bytes_read = 31;getShuffleRemoteBytesRead in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleRemoteBytesRead(long value)
int64 shuffle_remote_bytes_read = 31;value - The shuffleRemoteBytesRead to set.public StoreTypes.StageData.Builder clearShuffleRemoteBytesRead()
int64 shuffle_remote_bytes_read = 31;public long getShuffleRemoteBytesReadToDisk()
int64 shuffle_remote_bytes_read_to_disk = 32;getShuffleRemoteBytesReadToDisk in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleRemoteBytesReadToDisk(long value)
int64 shuffle_remote_bytes_read_to_disk = 32;value - The shuffleRemoteBytesReadToDisk to set.public StoreTypes.StageData.Builder clearShuffleRemoteBytesReadToDisk()
int64 shuffle_remote_bytes_read_to_disk = 32;public long getShuffleLocalBytesRead()
int64 shuffle_local_bytes_read = 33;getShuffleLocalBytesRead in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleLocalBytesRead(long value)
int64 shuffle_local_bytes_read = 33;value - The shuffleLocalBytesRead to set.public StoreTypes.StageData.Builder clearShuffleLocalBytesRead()
int64 shuffle_local_bytes_read = 33;public long getShuffleReadBytes()
int64 shuffle_read_bytes = 34;getShuffleReadBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleReadBytes(long value)
int64 shuffle_read_bytes = 34;value - The shuffleReadBytes to set.public StoreTypes.StageData.Builder clearShuffleReadBytes()
int64 shuffle_read_bytes = 34;public long getShuffleReadRecords()
int64 shuffle_read_records = 35;getShuffleReadRecords in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleReadRecords(long value)
int64 shuffle_read_records = 35;value - The shuffleReadRecords to set.public StoreTypes.StageData.Builder clearShuffleReadRecords()
int64 shuffle_read_records = 35;public long getShuffleWriteBytes()
int64 shuffle_write_bytes = 36;getShuffleWriteBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleWriteBytes(long value)
int64 shuffle_write_bytes = 36;value - The shuffleWriteBytes to set.public StoreTypes.StageData.Builder clearShuffleWriteBytes()
int64 shuffle_write_bytes = 36;public long getShuffleWriteTime()
int64 shuffle_write_time = 37;getShuffleWriteTime in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleWriteTime(long value)
int64 shuffle_write_time = 37;value - The shuffleWriteTime to set.public StoreTypes.StageData.Builder clearShuffleWriteTime()
int64 shuffle_write_time = 37;public long getShuffleWriteRecords()
int64 shuffle_write_records = 38;getShuffleWriteRecords in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleWriteRecords(long value)
int64 shuffle_write_records = 38;value - The shuffleWriteRecords to set.public StoreTypes.StageData.Builder clearShuffleWriteRecords()
int64 shuffle_write_records = 38;public boolean hasName()
optional string name = 39;hasName in interface StoreTypes.StageDataOrBuilderpublic String getName()
optional string name = 39;getName in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getNameBytes()
optional string name = 39;getNameBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setName(String value)
optional string name = 39;value - The name to set.public StoreTypes.StageData.Builder clearName()
optional string name = 39;public StoreTypes.StageData.Builder setNameBytes(com.google.protobuf.ByteString value)
optional string name = 39;value - The bytes for name to set.public boolean hasDescription()
optional string description = 40;hasDescription in interface StoreTypes.StageDataOrBuilderpublic String getDescription()
optional string description = 40;getDescription in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getDescriptionBytes()
optional string description = 40;getDescriptionBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setDescription(String value)
optional string description = 40;value - The description to set.public StoreTypes.StageData.Builder clearDescription()
optional string description = 40;public StoreTypes.StageData.Builder setDescriptionBytes(com.google.protobuf.ByteString value)
optional string description = 40;value - The bytes for description to set.public boolean hasDetails()
optional string details = 41;hasDetails in interface StoreTypes.StageDataOrBuilderpublic String getDetails()
optional string details = 41;getDetails in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getDetailsBytes()
optional string details = 41;getDetailsBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setDetails(String value)
optional string details = 41;value - The details to set.public StoreTypes.StageData.Builder clearDetails()
optional string details = 41;public StoreTypes.StageData.Builder setDetailsBytes(com.google.protobuf.ByteString value)
optional string details = 41;value - The bytes for details to set.public boolean hasSchedulingPool()
optional string scheduling_pool = 42;hasSchedulingPool in interface StoreTypes.StageDataOrBuilderpublic String getSchedulingPool()
optional string scheduling_pool = 42;getSchedulingPool in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getSchedulingPoolBytes()
optional string scheduling_pool = 42;getSchedulingPoolBytes in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setSchedulingPool(String value)
optional string scheduling_pool = 42;value - The schedulingPool to set.public StoreTypes.StageData.Builder clearSchedulingPool()
optional string scheduling_pool = 42;public StoreTypes.StageData.Builder setSchedulingPoolBytes(com.google.protobuf.ByteString value)
optional string scheduling_pool = 42;value - The bytes for schedulingPool to set.public java.util.List<Long> getRddIdsList()
repeated int64 rdd_ids = 43;getRddIdsList in interface StoreTypes.StageDataOrBuilderpublic int getRddIdsCount()
repeated int64 rdd_ids = 43;getRddIdsCount in interface StoreTypes.StageDataOrBuilderpublic long getRddIds(int index)
repeated int64 rdd_ids = 43;getRddIds in interface StoreTypes.StageDataOrBuilderindex - The index of the element to return.public StoreTypes.StageData.Builder setRddIds(int index, long value)
repeated int64 rdd_ids = 43;index - The index to set the value at.value - The rddIds to set.public StoreTypes.StageData.Builder addRddIds(long value)
repeated int64 rdd_ids = 43;value - The rddIds to add.public StoreTypes.StageData.Builder addAllRddIds(Iterable<? extends Long> values)
repeated int64 rdd_ids = 43;values - The rddIds to add.public StoreTypes.StageData.Builder clearRddIds()
repeated int64 rdd_ids = 43;public java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesList in interface StoreTypes.StageDataOrBuilderpublic int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesCount in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdates in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder clearAccumulatorUpdates()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.StageData.Builder removeAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.AccumulableInfo.Builder getAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesOrBuilder in interface StoreTypes.StageDataOrBuilderpublic java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesOrBuilderList in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public java.util.List<StoreTypes.AccumulableInfo.Builder> getAccumulatorUpdatesBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;public int getTasksCount()
StoreTypes.StageDataOrBuildermap<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksCount in interface StoreTypes.StageDataOrBuilderpublic boolean containsTasks(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;containsTasks in interface StoreTypes.StageDataOrBuilder@Deprecated public java.util.Map<Long,StoreTypes.TaskData> getTasks()
getTasksMap() instead.getTasks in interface StoreTypes.StageDataOrBuilderpublic java.util.Map<Long,StoreTypes.TaskData> getTasksMap()
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksMap in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.TaskData getTasksOrDefault(long key, StoreTypes.TaskData defaultValue)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksOrDefault in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.TaskData getTasksOrThrow(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksOrThrow in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder clearTasks()
public StoreTypes.StageData.Builder removeTasks(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;@Deprecated public java.util.Map<Long,StoreTypes.TaskData> getMutableTasks()
public StoreTypes.StageData.Builder putTasks(long key, StoreTypes.TaskData value)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;public StoreTypes.StageData.Builder putAllTasks(java.util.Map<Long,StoreTypes.TaskData> values)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;public int getExecutorSummaryCount()
StoreTypes.StageDataOrBuildermap<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryCount in interface StoreTypes.StageDataOrBuilderpublic boolean containsExecutorSummary(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;containsExecutorSummary in interface StoreTypes.StageDataOrBuilder@Deprecated public java.util.Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummary()
getExecutorSummaryMap() instead.getExecutorSummary in interface StoreTypes.StageDataOrBuilderpublic java.util.Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummaryMap()
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryMap in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorStageSummary getExecutorSummaryOrDefault(String key, StoreTypes.ExecutorStageSummary defaultValue)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryOrDefault in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorStageSummary getExecutorSummaryOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryOrThrow in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder clearExecutorSummary()
public StoreTypes.StageData.Builder removeExecutorSummary(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;@Deprecated public java.util.Map<String,StoreTypes.ExecutorStageSummary> getMutableExecutorSummary()
public StoreTypes.StageData.Builder putExecutorSummary(String key, StoreTypes.ExecutorStageSummary value)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;public StoreTypes.StageData.Builder putAllExecutorSummary(java.util.Map<String,StoreTypes.ExecutorStageSummary> values)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;public boolean hasSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;hasSpeculationSummary in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.SpeculationStageSummary getSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;getSpeculationSummary in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setSpeculationSummary(StoreTypes.SpeculationStageSummary value)
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;public StoreTypes.StageData.Builder setSpeculationSummary(StoreTypes.SpeculationStageSummary.Builder builderForValue)
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;public StoreTypes.StageData.Builder mergeSpeculationSummary(StoreTypes.SpeculationStageSummary value)
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;public StoreTypes.StageData.Builder clearSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;public StoreTypes.SpeculationStageSummary.Builder getSpeculationSummaryBuilder()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;public StoreTypes.SpeculationStageSummaryOrBuilder getSpeculationSummaryOrBuilder()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;getSpeculationSummaryOrBuilder in interface StoreTypes.StageDataOrBuilderpublic int getKilledTasksSummaryCount()
StoreTypes.StageDataOrBuildermap<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryCount in interface StoreTypes.StageDataOrBuilderpublic boolean containsKilledTasksSummary(String key)
map<string, int32> killed_tasks_summary = 48;containsKilledTasksSummary in interface StoreTypes.StageDataOrBuilder@Deprecated public java.util.Map<String,Integer> getKilledTasksSummary()
getKilledTasksSummaryMap() instead.getKilledTasksSummary in interface StoreTypes.StageDataOrBuilderpublic java.util.Map<String,Integer> getKilledTasksSummaryMap()
map<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryMap in interface StoreTypes.StageDataOrBuilderpublic int getKilledTasksSummaryOrDefault(String key,
int defaultValue)
map<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryOrDefault in interface StoreTypes.StageDataOrBuilderpublic int getKilledTasksSummaryOrThrow(String key)
map<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryOrThrow in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder clearKilledTasksSummary()
public StoreTypes.StageData.Builder removeKilledTasksSummary(String key)
map<string, int32> killed_tasks_summary = 48;@Deprecated public java.util.Map<String,Integer> getMutableKilledTasksSummary()
public StoreTypes.StageData.Builder putKilledTasksSummary(String key, int value)
map<string, int32> killed_tasks_summary = 48;public StoreTypes.StageData.Builder putAllKilledTasksSummary(java.util.Map<String,Integer> values)
map<string, int32> killed_tasks_summary = 48;public int getResourceProfileId()
int32 resource_profile_id = 49;getResourceProfileId in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setResourceProfileId(int value)
int32 resource_profile_id = 49;value - The resourceProfileId to set.public StoreTypes.StageData.Builder clearResourceProfileId()
int32 resource_profile_id = 49;public boolean hasPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;hasPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorMetrics getPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;getPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setPeakExecutorMetrics(StoreTypes.ExecutorMetrics value)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;public StoreTypes.StageData.Builder setPeakExecutorMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;public StoreTypes.StageData.Builder mergePeakExecutorMetrics(StoreTypes.ExecutorMetrics value)
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;public StoreTypes.StageData.Builder clearPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;public StoreTypes.ExecutorMetrics.Builder getPeakExecutorMetricsBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;public StoreTypes.ExecutorMetricsOrBuilder getPeakExecutorMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;getPeakExecutorMetricsOrBuilder in interface StoreTypes.StageDataOrBuilderpublic boolean hasTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;hasTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.TaskMetricDistributions getTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;getTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setTaskMetricsDistributions(StoreTypes.TaskMetricDistributions value)
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;public StoreTypes.StageData.Builder setTaskMetricsDistributions(StoreTypes.TaskMetricDistributions.Builder builderForValue)
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;public StoreTypes.StageData.Builder mergeTaskMetricsDistributions(StoreTypes.TaskMetricDistributions value)
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;public StoreTypes.StageData.Builder clearTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;public StoreTypes.TaskMetricDistributions.Builder getTaskMetricsDistributionsBuilder()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;public StoreTypes.TaskMetricDistributionsOrBuilder getTaskMetricsDistributionsOrBuilder()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;getTaskMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilderpublic boolean hasExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;hasExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorMetricsDistributions getExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;getExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions value)
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;public StoreTypes.StageData.Builder setExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions.Builder builderForValue)
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;public StoreTypes.StageData.Builder mergeExecutorMetricsDistributions(StoreTypes.ExecutorMetricsDistributions value)
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;public StoreTypes.StageData.Builder clearExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;public StoreTypes.ExecutorMetricsDistributions.Builder getExecutorMetricsDistributionsBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;public StoreTypes.ExecutorMetricsDistributionsOrBuilder getExecutorMetricsDistributionsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;getExecutorMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilderpublic long getShuffleCorruptMergedBlockChunks()
int64 shuffle_corrupt_merged_block_chunks = 53;getShuffleCorruptMergedBlockChunks in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleCorruptMergedBlockChunks(long value)
int64 shuffle_corrupt_merged_block_chunks = 53;value - The shuffleCorruptMergedBlockChunks to set.public StoreTypes.StageData.Builder clearShuffleCorruptMergedBlockChunks()
int64 shuffle_corrupt_merged_block_chunks = 53;public long getShuffleMergedFetchFallbackCount()
int64 shuffle_merged_fetch_fallback_count = 54;getShuffleMergedFetchFallbackCount in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedFetchFallbackCount(long value)
int64 shuffle_merged_fetch_fallback_count = 54;value - The shuffleMergedFetchFallbackCount to set.public StoreTypes.StageData.Builder clearShuffleMergedFetchFallbackCount()
int64 shuffle_merged_fetch_fallback_count = 54;public long getShuffleMergedRemoteBlocksFetched()
int64 shuffle_merged_remote_blocks_fetched = 55;getShuffleMergedRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedRemoteBlocksFetched(long value)
int64 shuffle_merged_remote_blocks_fetched = 55;value - The shuffleMergedRemoteBlocksFetched to set.public StoreTypes.StageData.Builder clearShuffleMergedRemoteBlocksFetched()
int64 shuffle_merged_remote_blocks_fetched = 55;public long getShuffleMergedLocalBlocksFetched()
int64 shuffle_merged_local_blocks_fetched = 56;getShuffleMergedLocalBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedLocalBlocksFetched(long value)
int64 shuffle_merged_local_blocks_fetched = 56;value - The shuffleMergedLocalBlocksFetched to set.public StoreTypes.StageData.Builder clearShuffleMergedLocalBlocksFetched()
int64 shuffle_merged_local_blocks_fetched = 56;public long getShuffleMergedRemoteChunksFetched()
int64 shuffle_merged_remote_chunks_fetched = 57;getShuffleMergedRemoteChunksFetched in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedRemoteChunksFetched(long value)
int64 shuffle_merged_remote_chunks_fetched = 57;value - The shuffleMergedRemoteChunksFetched to set.public StoreTypes.StageData.Builder clearShuffleMergedRemoteChunksFetched()
int64 shuffle_merged_remote_chunks_fetched = 57;public long getShuffleMergedLocalChunksFetched()
int64 shuffle_merged_local_chunks_fetched = 58;getShuffleMergedLocalChunksFetched in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedLocalChunksFetched(long value)
int64 shuffle_merged_local_chunks_fetched = 58;value - The shuffleMergedLocalChunksFetched to set.public StoreTypes.StageData.Builder clearShuffleMergedLocalChunksFetched()
int64 shuffle_merged_local_chunks_fetched = 58;public long getShuffleMergedRemoteBytesRead()
int64 shuffle_merged_remote_bytes_read = 59;getShuffleMergedRemoteBytesRead in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedRemoteBytesRead(long value)
int64 shuffle_merged_remote_bytes_read = 59;value - The shuffleMergedRemoteBytesRead to set.public StoreTypes.StageData.Builder clearShuffleMergedRemoteBytesRead()
int64 shuffle_merged_remote_bytes_read = 59;public long getShuffleMergedLocalBytesRead()
int64 shuffle_merged_local_bytes_read = 60;getShuffleMergedLocalBytesRead in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedLocalBytesRead(long value)
int64 shuffle_merged_local_bytes_read = 60;value - The shuffleMergedLocalBytesRead to set.public StoreTypes.StageData.Builder clearShuffleMergedLocalBytesRead()
int64 shuffle_merged_local_bytes_read = 60;public long getShuffleRemoteReqsDuration()
int64 shuffle_remote_reqs_duration = 61;getShuffleRemoteReqsDuration in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleRemoteReqsDuration(long value)
int64 shuffle_remote_reqs_duration = 61;value - The shuffleRemoteReqsDuration to set.public StoreTypes.StageData.Builder clearShuffleRemoteReqsDuration()
int64 shuffle_remote_reqs_duration = 61;public long getShuffleMergedRemoteReqsDuration()
int64 shuffle_merged_remote_reqs_duration = 62;getShuffleMergedRemoteReqsDuration in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergedRemoteReqsDuration(long value)
int64 shuffle_merged_remote_reqs_duration = 62;value - The shuffleMergedRemoteReqsDuration to set.public StoreTypes.StageData.Builder clearShuffleMergedRemoteReqsDuration()
int64 shuffle_merged_remote_reqs_duration = 62;public boolean getIsShufflePushEnabled()
bool is_shuffle_push_enabled = 63;getIsShufflePushEnabled in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setIsShufflePushEnabled(boolean value)
bool is_shuffle_push_enabled = 63;value - The isShufflePushEnabled to set.public StoreTypes.StageData.Builder clearIsShufflePushEnabled()
bool is_shuffle_push_enabled = 63;public int getShuffleMergersCount()
int32 shuffle_mergers_count = 64;getShuffleMergersCount in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageData.Builder setShuffleMergersCount(int value)
int32 shuffle_mergers_count = 64;value - The shuffleMergersCount to set.public StoreTypes.StageData.Builder clearShuffleMergersCount()
int32 shuffle_mergers_count = 64;public final StoreTypes.StageData.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields in interface com.google.protobuf.Message.BuildersetUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>public final StoreTypes.StageData.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields in interface com.google.protobuf.Message.BuildermergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>