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, newBuilderForField
findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.StageData.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>
public StoreTypes.StageData getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public StoreTypes.StageData build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.StageData buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.StageData.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
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.Builder
setField
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.Builder
clearField
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.Builder
clearOneof
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.Builder
setRepeatedField
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.Builder
addRepeatedField
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.Builder
mergeFrom
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.MessageLiteOrBuilder
isInitialized
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.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StageData.Builder>
java.io.IOException
public int getStatusValue()
.org.apache.spark.status.protobuf.StageStatus status = 1;
getStatusValue
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public long getSubmissionTime()
optional int64 submission_time = 10;
getSubmissionTime
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public long getFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;
getFirstTaskLaunchedTime
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public long getCompletionTime()
optional int64 completion_time = 12;
getCompletionTime
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public String getFailureReason()
optional string failure_reason = 13;
getFailureReason
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getFailureReasonBytes()
optional string failure_reason = 13;
getFailureReasonBytes
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public String getName()
optional string name = 39;
getName
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getNameBytes()
optional string name = 39;
getNameBytes
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public String getDescription()
optional string description = 40;
getDescription
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getDescriptionBytes()
optional string description = 40;
getDescriptionBytes
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public String getDetails()
optional string details = 41;
getDetails
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getDetailsBytes()
optional string details = 41;
getDetailsBytes
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public String getSchedulingPool()
optional string scheduling_pool = 42;
getSchedulingPool
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getSchedulingPoolBytes()
optional string scheduling_pool = 42;
getSchedulingPoolBytes
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public int getRddIdsCount()
repeated int64 rdd_ids = 43;
getRddIdsCount
in interface StoreTypes.StageDataOrBuilder
public long getRddIds(int index)
repeated int64 rdd_ids = 43;
getRddIds
in interface StoreTypes.StageDataOrBuilder
index
- 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.StageDataOrBuilder
public int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdatesCount
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdates
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdatesOrBuilderList
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksCount
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public java.util.Map<Long,StoreTypes.TaskData> getTasksMap()
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksMap
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.TaskData getTasksOrDefault(long key, StoreTypes.TaskData defaultValue)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksOrDefault
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.TaskData getTasksOrThrow(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksOrThrow
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryCount
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public java.util.Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummaryMap()
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryMap
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorStageSummary getExecutorSummaryOrDefault(String key, StoreTypes.ExecutorStageSummary defaultValue)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryOrDefault
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorStageSummary getExecutorSummaryOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryOrThrow
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public StoreTypes.SpeculationStageSummary getSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
getSpeculationSummary
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public int getKilledTasksSummaryCount()
StoreTypes.StageDataOrBuilder
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryCount
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public java.util.Map<String,Integer> getKilledTasksSummaryMap()
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryMap
in interface StoreTypes.StageDataOrBuilder
public int getKilledTasksSummaryOrDefault(String key, int defaultValue)
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryOrDefault
in interface StoreTypes.StageDataOrBuilder
public int getKilledTasksSummaryOrThrow(String key)
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryOrThrow
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public StoreTypes.ExecutorMetrics getPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
getPeakExecutorMetrics
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public boolean hasTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
hasTaskMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.TaskMetricDistributions getTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
getTaskMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public boolean hasExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
hasExecutorMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorMetricsDistributions getExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
getExecutorMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public long getShuffleCorruptMergedBlockChunks()
int64 shuffle_corrupt_merged_block_chunks = 53;
getShuffleCorruptMergedBlockChunks
in interface StoreTypes.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.StageDataOrBuilder
public 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.Builder
setUnknownFields
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.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StageData.Builder>