com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessageV3

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

All Implemented Interfaces:: com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable, StoreTypes.StageDataOrBuilder

Enclosing class:: StoreTypes

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

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

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static final class

StoreTypes.StageData.Builder

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

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
Field Summary

Fields

Modifier and Type

Field

Description

static final int

ACCUMULATOR_UPDATES_FIELD_NUMBER

static final int

ATTEMPT_ID_FIELD_NUMBER

static final int

COMPLETION_TIME_FIELD_NUMBER

static final int

DESCRIPTION_FIELD_NUMBER

static final int

DETAILS_FIELD_NUMBER

static final int

DISK_BYTES_SPILLED_FIELD_NUMBER

static final int

EXECUTOR_CPU_TIME_FIELD_NUMBER

static final int

EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

static final int

EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

static final int

EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER

static final int

EXECUTOR_RUN_TIME_FIELD_NUMBER

static final int

EXECUTOR_SUMMARY_FIELD_NUMBER

static final int

FAILURE_REASON_FIELD_NUMBER

static final int

FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER

static final int

INPUT_BYTES_FIELD_NUMBER

static final int

INPUT_RECORDS_FIELD_NUMBER

static final int

IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER

static final int

JVM_GC_TIME_FIELD_NUMBER

static final int

KILLED_TASKS_SUMMARY_FIELD_NUMBER

static final int

MEMORY_BYTES_SPILLED_FIELD_NUMBER

static final int

NAME_FIELD_NUMBER

static final int

NUM_ACTIVE_TASKS_FIELD_NUMBER

static final int

NUM_COMPLETE_TASKS_FIELD_NUMBER

static final int

NUM_COMPLETED_INDICES_FIELD_NUMBER

static final int

NUM_FAILED_TASKS_FIELD_NUMBER

static final int

NUM_KILLED_TASKS_FIELD_NUMBER

static final int

NUM_TASKS_FIELD_NUMBER

static final int

OUTPUT_BYTES_FIELD_NUMBER

static final int

OUTPUT_RECORDS_FIELD_NUMBER

static final int

PEAK_EXECUTION_MEMORY_FIELD_NUMBER

static final int

PEAK_EXECUTOR_METRICS_FIELD_NUMBER

static final int

RDD_IDS_FIELD_NUMBER

static final int

RESOURCE_PROFILE_ID_FIELD_NUMBER

static final int

RESULT_SERIALIZATION_TIME_FIELD_NUMBER

static final int

RESULT_SIZE_FIELD_NUMBER

static final int

SCHEDULING_POOL_FIELD_NUMBER

static final int

SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

static final int

SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

static final int

SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

static final int

SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER

static final int

SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

static final int

SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

static final int

SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

static final int

SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

static final int

SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

static final int

SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

static final int

SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

static final int

SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER

static final int

SHUFFLE_MERGERS_COUNT_FIELD_NUMBER

static final int

SHUFFLE_READ_BYTES_FIELD_NUMBER

static final int

SHUFFLE_READ_RECORDS_FIELD_NUMBER

static final int

SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

static final int

SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

static final int

SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

static final int

SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

static final int

SHUFFLE_WRITE_BYTES_FIELD_NUMBER

static final int

SHUFFLE_WRITE_RECORDS_FIELD_NUMBER

static final int

SHUFFLE_WRITE_TIME_FIELD_NUMBER

static final int

SPECULATION_SUMMARY_FIELD_NUMBER

static final int

STAGE_ID_FIELD_NUMBER

static final int

STATUS_FIELD_NUMBER

static final int

SUBMISSION_TIME_FIELD_NUMBER

static final int

TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER

static final int

TASKS_FIELD_NUMBER
Method Summary

Modifier and Type

Method

Description

boolean

containsExecutorSummary(String key)

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

boolean

containsKilledTasksSummary(String key)

map<string, int32> killed_tasks_summary = 48;

boolean

containsTasks(long key)

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

boolean

equals(Object obj)

StoreTypes.AccumulableInfo

getAccumulatorUpdates(int index)

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

int

getAccumulatorUpdatesCount()

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

List<StoreTypes.AccumulableInfo>

getAccumulatorUpdatesList()

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

StoreTypes.AccumulableInfoOrBuilder

getAccumulatorUpdatesOrBuilder(int index)

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

List<? extends StoreTypes.AccumulableInfoOrBuilder>

getAccumulatorUpdatesOrBuilderList()

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

int

getAttemptId()

int32 attempt_id = 3;

long

getCompletionTime()

optional int64 completion_time = 12;

static StoreTypes.StageData

getDefaultInstance()

StoreTypes.StageData

getDefaultInstanceForType()

String

getDescription()

optional string description = 40;

com.google.protobuf.ByteString

getDescriptionBytes()

optional string description = 40;

static final com.google.protobuf.Descriptors.Descriptor

getDescriptor()

String

getDetails()

optional string details = 41;

com.google.protobuf.ByteString

getDetailsBytes()

optional string details = 41;

long

getDiskBytesSpilled()

int64 disk_bytes_spilled = 22;

long

getExecutorCpuTime()

int64 executor_cpu_time = 17;

long

getExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 15;

long

getExecutorDeserializeTime()

int64 executor_deserialize_time = 14;

StoreTypes.ExecutorMetricsDistributions

getExecutorMetricsDistributions()

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

StoreTypes.ExecutorMetricsDistributionsOrBuilder

getExecutorMetricsDistributionsOrBuilder()

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

long

getExecutorRunTime()

int64 executor_run_time = 16;

Map<String,StoreTypes.ExecutorStageSummary>

getExecutorSummary()

Deprecated.

int

getExecutorSummaryCount()

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

Map<String,StoreTypes.ExecutorStageSummary>

getExecutorSummaryMap()

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

StoreTypes.ExecutorStageSummary

getExecutorSummaryOrDefault(String key, StoreTypes.ExecutorStageSummary defaultValue)

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

StoreTypes.ExecutorStageSummary

getExecutorSummaryOrThrow(String key)

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

String

getFailureReason()

optional string failure_reason = 13;

com.google.protobuf.ByteString

getFailureReasonBytes()

optional string failure_reason = 13;

long

getFirstTaskLaunchedTime()

optional int64 first_task_launched_time = 11;

long

getInputBytes()

int64 input_bytes = 24;

long

getInputRecords()

int64 input_records = 25;

boolean

getIsShufflePushEnabled()

bool is_shuffle_push_enabled = 63;

long

getJvmGcTime()

int64 jvm_gc_time = 19;

Map<String,Integer>

getKilledTasksSummary()

Deprecated.

int

getKilledTasksSummaryCount()

map<string, int32> killed_tasks_summary = 48;

Map<String,Integer>

getKilledTasksSummaryMap()

map<string, int32> killed_tasks_summary = 48;

int

getKilledTasksSummaryOrDefault(String key, int defaultValue)

map<string, int32> killed_tasks_summary = 48;

int

getKilledTasksSummaryOrThrow(String key)

map<string, int32> killed_tasks_summary = 48;

long

getMemoryBytesSpilled()

int64 memory_bytes_spilled = 21;

String

getName()

optional string name = 39;

com.google.protobuf.ByteString

getNameBytes()

optional string name = 39;

int

getNumActiveTasks()

int32 num_active_tasks = 5;

int

getNumCompletedIndices()

int32 num_completed_indices = 9;

int

getNumCompleteTasks()

int32 num_complete_tasks = 6;

int

getNumFailedTasks()

int32 num_failed_tasks = 7;

int

getNumKilledTasks()

int32 num_killed_tasks = 8;

int

getNumTasks()

int32 num_tasks = 4;

long

getOutputBytes()

int64 output_bytes = 26;

long

getOutputRecords()

int64 output_records = 27;

com.google.protobuf.Parser<StoreTypes.StageData>

getParserForType()

long

getPeakExecutionMemory()

int64 peak_execution_memory = 23;

StoreTypes.ExecutorMetrics

getPeakExecutorMetrics()

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

StoreTypes.ExecutorMetricsOrBuilder

getPeakExecutorMetricsOrBuilder()

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

long

getRddIds(int index)

repeated int64 rdd_ids = 43;

int

getRddIdsCount()

repeated int64 rdd_ids = 43;

List<Long>

getRddIdsList()

repeated int64 rdd_ids = 43;

int

getResourceProfileId()

int32 resource_profile_id = 49;

long

getResultSerializationTime()

int64 result_serialization_time = 20;

long

getResultSize()

int64 result_size = 18;

String

getSchedulingPool()

optional string scheduling_pool = 42;

com.google.protobuf.ByteString

getSchedulingPoolBytes()

optional string scheduling_pool = 42;

int

getSerializedSize()

long

getShuffleCorruptMergedBlockChunks()

int64 shuffle_corrupt_merged_block_chunks = 53;

long

getShuffleFetchWaitTime()

int64 shuffle_fetch_wait_time = 30;

long

getShuffleLocalBlocksFetched()

int64 shuffle_local_blocks_fetched = 29;

long

getShuffleLocalBytesRead()

int64 shuffle_local_bytes_read = 33;

long

getShuffleMergedFetchFallbackCount()

int64 shuffle_merged_fetch_fallback_count = 54;

long

getShuffleMergedLocalBlocksFetched()

int64 shuffle_merged_local_blocks_fetched = 56;

long

getShuffleMergedLocalBytesRead()

int64 shuffle_merged_local_bytes_read = 60;

long

getShuffleMergedLocalChunksFetched()

int64 shuffle_merged_local_chunks_fetched = 58;

long

getShuffleMergedRemoteBlocksFetched()

int64 shuffle_merged_remote_blocks_fetched = 55;

long

getShuffleMergedRemoteBytesRead()

int64 shuffle_merged_remote_bytes_read = 59;

long

getShuffleMergedRemoteChunksFetched()

int64 shuffle_merged_remote_chunks_fetched = 57;

long

getShuffleMergedRemoteReqsDuration()

int64 shuffle_merged_remote_reqs_duration = 62;

int

getShuffleMergersCount()

int32 shuffle_mergers_count = 64;

long

getShuffleReadBytes()

int64 shuffle_read_bytes = 34;

long

getShuffleReadRecords()

int64 shuffle_read_records = 35;

long

getShuffleRemoteBlocksFetched()

int64 shuffle_remote_blocks_fetched = 28;

long

getShuffleRemoteBytesRead()

int64 shuffle_remote_bytes_read = 31;

long

getShuffleRemoteBytesReadToDisk()

int64 shuffle_remote_bytes_read_to_disk = 32;

long

getShuffleRemoteReqsDuration()

int64 shuffle_remote_reqs_duration = 61;

long

getShuffleWriteBytes()

int64 shuffle_write_bytes = 36;

long

getShuffleWriteRecords()

int64 shuffle_write_records = 38;

long

getShuffleWriteTime()

int64 shuffle_write_time = 37;

StoreTypes.SpeculationStageSummary

getSpeculationSummary()

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

StoreTypes.SpeculationStageSummaryOrBuilder

getSpeculationSummaryOrBuilder()

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

long

getStageId()

int64 stage_id = 2;

StoreTypes.StageStatus

getStatus()

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

int

getStatusValue()

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

long

getSubmissionTime()

optional int64 submission_time = 10;

StoreTypes.TaskMetricDistributions

getTaskMetricsDistributions()

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

StoreTypes.TaskMetricDistributionsOrBuilder

getTaskMetricsDistributionsOrBuilder()

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

Map<Long,StoreTypes.TaskData>

getTasks()

Deprecated.

int

getTasksCount()

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

Map<Long,StoreTypes.TaskData>

getTasksMap()

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

StoreTypes.TaskData

getTasksOrDefault(long key, StoreTypes.TaskData defaultValue)

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

StoreTypes.TaskData

getTasksOrThrow(long key)

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

boolean

hasCompletionTime()

optional int64 completion_time = 12;

boolean

hasDescription()

optional string description = 40;

boolean

hasDetails()

optional string details = 41;

boolean

hasExecutorMetricsDistributions()

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

boolean

hasFailureReason()

optional string failure_reason = 13;

boolean

hasFirstTaskLaunchedTime()

optional int64 first_task_launched_time = 11;

int

hashCode()

boolean

hasName()

optional string name = 39;

boolean

hasPeakExecutorMetrics()

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

boolean

hasSchedulingPool()

optional string scheduling_pool = 42;

boolean

hasSpeculationSummary()

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

boolean

hasSubmissionTime()

optional int64 submission_time = 10;

boolean

hasTaskMetricsDistributions()

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

final boolean

isInitialized()

static StoreTypes.StageData.Builder

newBuilder()

static StoreTypes.StageData.Builder

newBuilder(StoreTypes.StageData prototype)

StoreTypes.StageData.Builder

newBuilderForType()

static StoreTypes.StageData

parseDelimitedFrom(InputStream input)

static StoreTypes.StageData

parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

static StoreTypes.StageData

parseFrom(byte[] data)

static StoreTypes.StageData

parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

static StoreTypes.StageData

parseFrom(com.google.protobuf.ByteString data)

static StoreTypes.StageData

parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

static StoreTypes.StageData

parseFrom(com.google.protobuf.CodedInputStream input)

static StoreTypes.StageData

parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

static StoreTypes.StageData

parseFrom(InputStream input)

static StoreTypes.StageData

parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

static StoreTypes.StageData

parseFrom(ByteBuffer data)

static StoreTypes.StageData

parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

static com.google.protobuf.Parser<StoreTypes.StageData>

parser()

StoreTypes.StageData.Builder

toBuilder()

void

writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessageV3
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Field Details
- STATUS_FIELD_NUMBER
  
  public static final int STATUS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- STAGE_ID_FIELD_NUMBER
  
  public static final int STAGE_ID_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- ATTEMPT_ID_FIELD_NUMBER
  
  public static final int ATTEMPT_ID_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- NUM_TASKS_FIELD_NUMBER
  
  public static final int NUM_TASKS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- NUM_ACTIVE_TASKS_FIELD_NUMBER
  
  public static final int NUM_ACTIVE_TASKS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- NUM_COMPLETE_TASKS_FIELD_NUMBER
  
  public static final int NUM_COMPLETE_TASKS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- NUM_FAILED_TASKS_FIELD_NUMBER
  
  public static final int NUM_FAILED_TASKS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- NUM_KILLED_TASKS_FIELD_NUMBER
  
  public static final int NUM_KILLED_TASKS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- NUM_COMPLETED_INDICES_FIELD_NUMBER
  
  public static final int NUM_COMPLETED_INDICES_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SUBMISSION_TIME_FIELD_NUMBER
  
  public static final int SUBMISSION_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER
  
  public static final int FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- COMPLETION_TIME_FIELD_NUMBER
  
  public static final int COMPLETION_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- FAILURE_REASON_FIELD_NUMBER
  
  public static final int FAILURE_REASON_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER
  
  public static final int EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER
  
  public static final int EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- EXECUTOR_RUN_TIME_FIELD_NUMBER
  
  public static final int EXECUTOR_RUN_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- EXECUTOR_CPU_TIME_FIELD_NUMBER
  
  public static final int EXECUTOR_CPU_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- RESULT_SIZE_FIELD_NUMBER
  
  public static final int RESULT_SIZE_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- JVM_GC_TIME_FIELD_NUMBER
  
  public static final int JVM_GC_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- RESULT_SERIALIZATION_TIME_FIELD_NUMBER
  
  public static final int RESULT_SERIALIZATION_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- MEMORY_BYTES_SPILLED_FIELD_NUMBER
  
  public static final int MEMORY_BYTES_SPILLED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- DISK_BYTES_SPILLED_FIELD_NUMBER
  
  public static final int DISK_BYTES_SPILLED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- PEAK_EXECUTION_MEMORY_FIELD_NUMBER
  
  public static final int PEAK_EXECUTION_MEMORY_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- INPUT_BYTES_FIELD_NUMBER
  
  public static final int INPUT_BYTES_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- INPUT_RECORDS_FIELD_NUMBER
  
  public static final int INPUT_RECORDS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- OUTPUT_BYTES_FIELD_NUMBER
  
  public static final int OUTPUT_BYTES_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- OUTPUT_RECORDS_FIELD_NUMBER
  
  public static final int OUTPUT_RECORDS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
  
  public static final int SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
  
  public static final int SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER
  
  public static final int SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER
  
  public static final int SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
  
  public static final int SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER
  
  public static final int SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_READ_BYTES_FIELD_NUMBER
  
  public static final int SHUFFLE_READ_BYTES_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_READ_RECORDS_FIELD_NUMBER
  
  public static final int SHUFFLE_READ_RECORDS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_WRITE_BYTES_FIELD_NUMBER
  
  public static final int SHUFFLE_WRITE_BYTES_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_WRITE_TIME_FIELD_NUMBER
  
  public static final int SHUFFLE_WRITE_TIME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_WRITE_RECORDS_FIELD_NUMBER
  
  public static final int SHUFFLE_WRITE_RECORDS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- NAME_FIELD_NUMBER
  
  public static final int NAME_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- DESCRIPTION_FIELD_NUMBER
  
  public static final int DESCRIPTION_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- DETAILS_FIELD_NUMBER
  
  public static final int DETAILS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SCHEDULING_POOL_FIELD_NUMBER
  
  public static final int SCHEDULING_POOL_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- RDD_IDS_FIELD_NUMBER
  
  public static final int RDD_IDS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- ACCUMULATOR_UPDATES_FIELD_NUMBER
  
  public static final int ACCUMULATOR_UPDATES_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- TASKS_FIELD_NUMBER
  
  public static final int TASKS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- EXECUTOR_SUMMARY_FIELD_NUMBER
  
  public static final int EXECUTOR_SUMMARY_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SPECULATION_SUMMARY_FIELD_NUMBER
  
  public static final int SPECULATION_SUMMARY_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- KILLED_TASKS_SUMMARY_FIELD_NUMBER
  
  public static final int KILLED_TASKS_SUMMARY_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- RESOURCE_PROFILE_ID_FIELD_NUMBER
  
  public static final int RESOURCE_PROFILE_ID_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- PEAK_EXECUTOR_METRICS_FIELD_NUMBER
  
  public static final int PEAK_EXECUTOR_METRICS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER
  
  public static final int TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER
  
  public static final int EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER
  
  public static final int SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER
  
  public static final int SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER
  
  public static final int IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER
  See Also:
  
  Constant Field Values
- SHUFFLE_MERGERS_COUNT_FIELD_NUMBER
  
  public static final int SHUFFLE_MERGERS_COUNT_FIELD_NUMBER
  See Also:
  
  Constant Field Values
Method Details
- getDescriptor
  
  public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
- getStatusValue
  
  public int getStatusValue()
  
  .org.apache.spark.status.protobuf.StageStatus status = 1;
  
  Specified by:
  
  getStatusValue in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The enum numeric value on the wire for status.
- getStatus
  
  public StoreTypes.StageStatus getStatus()
  
  .org.apache.spark.status.protobuf.StageStatus status = 1;
  
  Specified by:
  
  getStatus in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The status.
- getStageId
  
  public long getStageId()
  
  int64 stage_id = 2;
  
  Specified by:
  
  getStageId in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The stageId.
- getAttemptId
  
  public int getAttemptId()
  
  int32 attempt_id = 3;
  
  Specified by:
  
  getAttemptId in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The attemptId.
- getNumTasks
  
  public int getNumTasks()
  
  int32 num_tasks = 4;
  
  Specified by:
  
  getNumTasks in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The numTasks.
- getNumActiveTasks
  
  public int getNumActiveTasks()
  
  int32 num_active_tasks = 5;
  
  Specified by:
  
  getNumActiveTasks in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The numActiveTasks.
- getNumCompleteTasks
  
  public int getNumCompleteTasks()
  
  int32 num_complete_tasks = 6;
  
  Specified by:
  
  getNumCompleteTasks in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The numCompleteTasks.
- getNumFailedTasks
  
  public int getNumFailedTasks()
  
  int32 num_failed_tasks = 7;
  
  Specified by:
  
  getNumFailedTasks in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The numFailedTasks.
- getNumKilledTasks
  
  public int getNumKilledTasks()
  
  int32 num_killed_tasks = 8;
  
  Specified by:
  
  getNumKilledTasks in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The numKilledTasks.
- getNumCompletedIndices
  
  public int getNumCompletedIndices()
  
  int32 num_completed_indices = 9;
  
  Specified by:
  
  getNumCompletedIndices in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The numCompletedIndices.
- hasSubmissionTime
  
  public boolean hasSubmissionTime()
  
  optional int64 submission_time = 10;
  
  Specified by:
  
  hasSubmissionTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the submissionTime field is set.
- getSubmissionTime
  
  public long getSubmissionTime()
  
  optional int64 submission_time = 10;
  
  Specified by:
  
  getSubmissionTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The submissionTime.
- hasFirstTaskLaunchedTime
  
  public boolean hasFirstTaskLaunchedTime()
  
  optional int64 first_task_launched_time = 11;
  
  Specified by:
  
  hasFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the firstTaskLaunchedTime field is set.
- getFirstTaskLaunchedTime
  
  public long getFirstTaskLaunchedTime()
  
  optional int64 first_task_launched_time = 11;
  
  Specified by:
  
  getFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The firstTaskLaunchedTime.
- hasCompletionTime
  
  public boolean hasCompletionTime()
  
  optional int64 completion_time = 12;
  
  Specified by:
  
  hasCompletionTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the completionTime field is set.
- getCompletionTime
  
  public long getCompletionTime()
  
  optional int64 completion_time = 12;
  
  Specified by:
  
  getCompletionTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The completionTime.
- hasFailureReason
  
  public boolean hasFailureReason()
  
  optional string failure_reason = 13;
  
  Specified by:
  
  hasFailureReason in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the failureReason field is set.
- getFailureReason
  
  public String getFailureReason()
  
  optional string failure_reason = 13;
  
  Specified by:
  
  getFailureReason in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The failureReason.
- getFailureReasonBytes
  
  public com.google.protobuf.ByteString getFailureReasonBytes()
  
  optional string failure_reason = 13;
  
  Specified by:
  
  getFailureReasonBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The bytes for failureReason.
- getExecutorDeserializeTime
  
  public long getExecutorDeserializeTime()
  
  int64 executor_deserialize_time = 14;
  
  Specified by:
  
  getExecutorDeserializeTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The executorDeserializeTime.
- getExecutorDeserializeCpuTime
  
  public long getExecutorDeserializeCpuTime()
  
  int64 executor_deserialize_cpu_time = 15;
  
  Specified by:
  
  getExecutorDeserializeCpuTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The executorDeserializeCpuTime.
- getExecutorRunTime
  
  public long getExecutorRunTime()
  
  int64 executor_run_time = 16;
  
  Specified by:
  
  getExecutorRunTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The executorRunTime.
- getExecutorCpuTime
  
  public long getExecutorCpuTime()
  
  int64 executor_cpu_time = 17;
  
  Specified by:
  
  getExecutorCpuTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The executorCpuTime.
- getResultSize
  
  public long getResultSize()
  
  int64 result_size = 18;
  
  Specified by:
  
  getResultSize in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The resultSize.
- getJvmGcTime
  
  public long getJvmGcTime()
  
  int64 jvm_gc_time = 19;
  
  Specified by:
  
  getJvmGcTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The jvmGcTime.
- getResultSerializationTime
  
  public long getResultSerializationTime()
  
  int64 result_serialization_time = 20;
  
  Specified by:
  
  getResultSerializationTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The resultSerializationTime.
- getMemoryBytesSpilled
  
  public long getMemoryBytesSpilled()
  
  int64 memory_bytes_spilled = 21;
  
  Specified by:
  
  getMemoryBytesSpilled in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The memoryBytesSpilled.
- getDiskBytesSpilled
  
  public long getDiskBytesSpilled()
  
  int64 disk_bytes_spilled = 22;
  
  Specified by:
  
  getDiskBytesSpilled in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The diskBytesSpilled.
- getPeakExecutionMemory
  
  public long getPeakExecutionMemory()
  
  int64 peak_execution_memory = 23;
  
  Specified by:
  
  getPeakExecutionMemory in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The peakExecutionMemory.
- getInputBytes
  
  public long getInputBytes()
  
  int64 input_bytes = 24;
  
  Specified by:
  
  getInputBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The inputBytes.
- getInputRecords
  
  public long getInputRecords()
  
  int64 input_records = 25;
  
  Specified by:
  
  getInputRecords in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The inputRecords.
- getOutputBytes
  
  public long getOutputBytes()
  
  int64 output_bytes = 26;
  
  Specified by:
  
  getOutputBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The outputBytes.
- getOutputRecords
  
  public long getOutputRecords()
  
  int64 output_records = 27;
  
  Specified by:
  
  getOutputRecords in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The outputRecords.
- getShuffleRemoteBlocksFetched
  
  public long getShuffleRemoteBlocksFetched()
  
  int64 shuffle_remote_blocks_fetched = 28;
  
  Specified by:
  
  getShuffleRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleRemoteBlocksFetched.
- getShuffleLocalBlocksFetched
  
  public long getShuffleLocalBlocksFetched()
  
  int64 shuffle_local_blocks_fetched = 29;
  
  Specified by:
  
  getShuffleLocalBlocksFetched in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleLocalBlocksFetched.
- getShuffleFetchWaitTime
  
  public long getShuffleFetchWaitTime()
  
  int64 shuffle_fetch_wait_time = 30;
  
  Specified by:
  
  getShuffleFetchWaitTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleFetchWaitTime.
- getShuffleRemoteBytesRead
  
  public long getShuffleRemoteBytesRead()
  
  int64 shuffle_remote_bytes_read = 31;
  
  Specified by:
  
  getShuffleRemoteBytesRead in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleRemoteBytesRead.
- getShuffleRemoteBytesReadToDisk
  
  public long getShuffleRemoteBytesReadToDisk()
  
  int64 shuffle_remote_bytes_read_to_disk = 32;
  
  Specified by:
  
  getShuffleRemoteBytesReadToDisk in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleRemoteBytesReadToDisk.
- getShuffleLocalBytesRead
  
  public long getShuffleLocalBytesRead()
  
  int64 shuffle_local_bytes_read = 33;
  
  Specified by:
  
  getShuffleLocalBytesRead in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleLocalBytesRead.
- getShuffleReadBytes
  
  public long getShuffleReadBytes()
  
  int64 shuffle_read_bytes = 34;
  
  Specified by:
  
  getShuffleReadBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleReadBytes.
- getShuffleReadRecords
  
  public long getShuffleReadRecords()
  
  int64 shuffle_read_records = 35;
  
  Specified by:
  
  getShuffleReadRecords in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleReadRecords.
- getShuffleWriteBytes
  
  public long getShuffleWriteBytes()
  
  int64 shuffle_write_bytes = 36;
  
  Specified by:
  
  getShuffleWriteBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleWriteBytes.
- getShuffleWriteTime
  
  public long getShuffleWriteTime()
  
  int64 shuffle_write_time = 37;
  
  Specified by:
  
  getShuffleWriteTime in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleWriteTime.
- getShuffleWriteRecords
  
  public long getShuffleWriteRecords()
  
  int64 shuffle_write_records = 38;
  
  Specified by:
  
  getShuffleWriteRecords in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleWriteRecords.
- hasName
  
  public boolean hasName()
  
  optional string name = 39;
  
  Specified by:
  
  hasName in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the name field is set.
- getName
  
  public String getName()
  
  optional string name = 39;
  
  Specified by:
  
  getName in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The name.
- getNameBytes
  
  public com.google.protobuf.ByteString getNameBytes()
  
  optional string name = 39;
  
  Specified by:
  
  getNameBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The bytes for name.
- hasDescription
  
  public boolean hasDescription()
  
  optional string description = 40;
  
  Specified by:
  
  hasDescription in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the description field is set.
- getDescription
  
  public String getDescription()
  
  optional string description = 40;
  
  Specified by:
  
  getDescription in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The description.
- getDescriptionBytes
  
  public com.google.protobuf.ByteString getDescriptionBytes()
  
  optional string description = 40;
  
  Specified by:
  
  getDescriptionBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The bytes for description.
- hasDetails
  
  public boolean hasDetails()
  
  optional string details = 41;
  
  Specified by:
  
  hasDetails in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the details field is set.
- getDetails
  
  public String getDetails()
  
  optional string details = 41;
  
  Specified by:
  
  getDetails in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The details.
- getDetailsBytes
  
  public com.google.protobuf.ByteString getDetailsBytes()
  
  optional string details = 41;
  
  Specified by:
  
  getDetailsBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The bytes for details.
- hasSchedulingPool
  
  public boolean hasSchedulingPool()
  
  optional string scheduling_pool = 42;
  
  Specified by:
  
  hasSchedulingPool in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the schedulingPool field is set.
- getSchedulingPool
  
  public String getSchedulingPool()
  
  optional string scheduling_pool = 42;
  
  Specified by:
  
  getSchedulingPool in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The schedulingPool.
- getSchedulingPoolBytes
  
  public com.google.protobuf.ByteString getSchedulingPoolBytes()
  
  optional string scheduling_pool = 42;
  
  Specified by:
  
  getSchedulingPoolBytes in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The bytes for schedulingPool.
- getRddIdsList
  
  public List<Long> getRddIdsList()
  
  repeated int64 rdd_ids = 43;
  
  Specified by:
  
  getRddIdsList in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  A list containing the rddIds.
- getRddIdsCount
  
  public int getRddIdsCount()
  
  repeated int64 rdd_ids = 43;
  
  Specified by:
  
  getRddIdsCount in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The count of rddIds.
- getRddIds
  
  public long getRddIds(int index)
  
  repeated int64 rdd_ids = 43;
  
  Specified by:
  
  getRddIds in interface StoreTypes.StageDataOrBuilder
  
  Parameters:
  
  index - The index of the element to return.
  
  Returns:
  
  The rddIds at the given index.
- getAccumulatorUpdatesList
  
  public List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
  
  repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
  
  Specified by:
  
  getAccumulatorUpdatesList in interface StoreTypes.StageDataOrBuilder
- getAccumulatorUpdatesOrBuilderList
  
  public List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
  
  repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
  
  Specified by:
  
  getAccumulatorUpdatesOrBuilderList in interface StoreTypes.StageDataOrBuilder
- getAccumulatorUpdatesCount
  
  public int getAccumulatorUpdatesCount()
  
  repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
  
  Specified by:
  
  getAccumulatorUpdatesCount in interface StoreTypes.StageDataOrBuilder
- getAccumulatorUpdates
  
  public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
  
  repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
  
  Specified by:
  
  getAccumulatorUpdates in interface StoreTypes.StageDataOrBuilder
- getAccumulatorUpdatesOrBuilder
  
  public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
  
  repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
  
  Specified by:
  
  getAccumulatorUpdatesOrBuilder in interface StoreTypes.StageDataOrBuilder
- getTasksCount
  
  public int getTasksCount()
  
  Description copied from interface: StoreTypes.StageDataOrBuilder
  
  map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
  
  Specified by:
  
  getTasksCount in interface StoreTypes.StageDataOrBuilder
- containsTasks
  
  public boolean containsTasks(long key)
  
  map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
  
  Specified by:
  
  containsTasks in interface StoreTypes.StageDataOrBuilder
- getTasks
  
  @Deprecated public Map<Long,StoreTypes.TaskData> getTasks()
  
  Deprecated.
  
  Use getTasksMap() instead.
  
  Specified by:
  
  getTasks in interface StoreTypes.StageDataOrBuilder
- getTasksMap
  
  public Map<Long,StoreTypes.TaskData> getTasksMap()
  
  map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
  
  Specified by:
  
  getTasksMap in interface StoreTypes.StageDataOrBuilder
- getTasksOrDefault
  
  public StoreTypes.TaskData getTasksOrDefault(long key, StoreTypes.TaskData defaultValue)
  
  map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
  
  Specified by:
  
  getTasksOrDefault in interface StoreTypes.StageDataOrBuilder
- getTasksOrThrow
  
  public StoreTypes.TaskData getTasksOrThrow(long key)
  
  map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
  
  Specified by:
  
  getTasksOrThrow in interface StoreTypes.StageDataOrBuilder
- getExecutorSummaryCount
  
  public int getExecutorSummaryCount()
  
  Description copied from interface: StoreTypes.StageDataOrBuilder
  
  map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
  
  Specified by:
  
  getExecutorSummaryCount in interface StoreTypes.StageDataOrBuilder
- containsExecutorSummary
  
  public boolean containsExecutorSummary(String key)
  
  map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
  
  Specified by:
  
  containsExecutorSummary in interface StoreTypes.StageDataOrBuilder
- getExecutorSummary
  
  @Deprecated public Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummary()
  
  Deprecated.
  
  Use getExecutorSummaryMap() instead.
  
  Specified by:
  
  getExecutorSummary in interface StoreTypes.StageDataOrBuilder
- getExecutorSummaryMap
  
  public Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummaryMap()
  
  map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
  
  Specified by:
  
  getExecutorSummaryMap in interface StoreTypes.StageDataOrBuilder
- getExecutorSummaryOrDefault
  
  public StoreTypes.ExecutorStageSummary getExecutorSummaryOrDefault(String key, StoreTypes.ExecutorStageSummary defaultValue)
  
  map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
  
  Specified by:
  
  getExecutorSummaryOrDefault in interface StoreTypes.StageDataOrBuilder
- getExecutorSummaryOrThrow
  
  public StoreTypes.ExecutorStageSummary getExecutorSummaryOrThrow(String key)
  
  map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
  
  Specified by:
  
  getExecutorSummaryOrThrow in interface StoreTypes.StageDataOrBuilder
- hasSpeculationSummary
  
  public boolean hasSpeculationSummary()
  
  optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
  
  Specified by:
  
  hasSpeculationSummary in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the speculationSummary field is set.
- getSpeculationSummary
  
  public StoreTypes.SpeculationStageSummary getSpeculationSummary()
  
  optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
  
  Specified by:
  
  getSpeculationSummary in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The speculationSummary.
- getSpeculationSummaryOrBuilder
  
  public StoreTypes.SpeculationStageSummaryOrBuilder getSpeculationSummaryOrBuilder()
  
  optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
  
  Specified by:
  
  getSpeculationSummaryOrBuilder in interface StoreTypes.StageDataOrBuilder
- getKilledTasksSummaryCount
  
  public int getKilledTasksSummaryCount()
  
  Description copied from interface: StoreTypes.StageDataOrBuilder
  
  map<string, int32> killed_tasks_summary = 48;
  
  Specified by:
  
  getKilledTasksSummaryCount in interface StoreTypes.StageDataOrBuilder
- containsKilledTasksSummary
  
  public boolean containsKilledTasksSummary(String key)
  
  map<string, int32> killed_tasks_summary = 48;
  
  Specified by:
  
  containsKilledTasksSummary in interface StoreTypes.StageDataOrBuilder
- getKilledTasksSummary
  
  @Deprecated public Map<String,Integer> getKilledTasksSummary()
  
  Deprecated.
  
  Use getKilledTasksSummaryMap() instead.
  
  Specified by:
  
  getKilledTasksSummary in interface StoreTypes.StageDataOrBuilder
- getKilledTasksSummaryMap
  
  public Map<String,Integer> getKilledTasksSummaryMap()
  
  map<string, int32> killed_tasks_summary = 48;
  
  Specified by:
  
  getKilledTasksSummaryMap in interface StoreTypes.StageDataOrBuilder
- getKilledTasksSummaryOrDefault
  
  public int getKilledTasksSummaryOrDefault(String key, int defaultValue)
  
  map<string, int32> killed_tasks_summary = 48;
  
  Specified by:
  
  getKilledTasksSummaryOrDefault in interface StoreTypes.StageDataOrBuilder
- getKilledTasksSummaryOrThrow
  
  public int getKilledTasksSummaryOrThrow(String key)
  
  map<string, int32> killed_tasks_summary = 48;
  
  Specified by:
  
  getKilledTasksSummaryOrThrow in interface StoreTypes.StageDataOrBuilder
- getResourceProfileId
  
  public int getResourceProfileId()
  
  int32 resource_profile_id = 49;
  
  Specified by:
  
  getResourceProfileId in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The resourceProfileId.
- hasPeakExecutorMetrics
  
  public boolean hasPeakExecutorMetrics()
  
  optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
  
  Specified by:
  
  hasPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the peakExecutorMetrics field is set.
- getPeakExecutorMetrics
  
  public StoreTypes.ExecutorMetrics getPeakExecutorMetrics()
  
  optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
  
  Specified by:
  
  getPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The peakExecutorMetrics.
- getPeakExecutorMetricsOrBuilder
  
  public StoreTypes.ExecutorMetricsOrBuilder getPeakExecutorMetricsOrBuilder()
  
  optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
  
  Specified by:
  
  getPeakExecutorMetricsOrBuilder in interface StoreTypes.StageDataOrBuilder
- hasTaskMetricsDistributions
  
  public boolean hasTaskMetricsDistributions()
  
  optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
  
  Specified by:
  
  hasTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the taskMetricsDistributions field is set.
- getTaskMetricsDistributions
  
  public StoreTypes.TaskMetricDistributions getTaskMetricsDistributions()
  
  optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
  
  Specified by:
  
  getTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The taskMetricsDistributions.
- getTaskMetricsDistributionsOrBuilder
  
  public StoreTypes.TaskMetricDistributionsOrBuilder getTaskMetricsDistributionsOrBuilder()
  
  optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
  
  Specified by:
  
  getTaskMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilder
- hasExecutorMetricsDistributions
  
  public boolean hasExecutorMetricsDistributions()
  
  optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
  
  Specified by:
  
  hasExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  Whether the executorMetricsDistributions field is set.
- getExecutorMetricsDistributions
  
  public StoreTypes.ExecutorMetricsDistributions getExecutorMetricsDistributions()
  
  optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
  
  Specified by:
  
  getExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The executorMetricsDistributions.
- getExecutorMetricsDistributionsOrBuilder
  
  public StoreTypes.ExecutorMetricsDistributionsOrBuilder getExecutorMetricsDistributionsOrBuilder()
  
  optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
  
  Specified by:
  
  getExecutorMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilder
- getShuffleCorruptMergedBlockChunks
  
  public long getShuffleCorruptMergedBlockChunks()
  
  int64 shuffle_corrupt_merged_block_chunks = 53;
  
  Specified by:
  
  getShuffleCorruptMergedBlockChunks in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleCorruptMergedBlockChunks.
- getShuffleMergedFetchFallbackCount
  
  public long getShuffleMergedFetchFallbackCount()
  
  int64 shuffle_merged_fetch_fallback_count = 54;
  
  Specified by:
  
  getShuffleMergedFetchFallbackCount in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedFetchFallbackCount.
- getShuffleMergedRemoteBlocksFetched
  
  public long getShuffleMergedRemoteBlocksFetched()
  
  int64 shuffle_merged_remote_blocks_fetched = 55;
  
  Specified by:
  
  getShuffleMergedRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedRemoteBlocksFetched.
- getShuffleMergedLocalBlocksFetched
  
  public long getShuffleMergedLocalBlocksFetched()
  
  int64 shuffle_merged_local_blocks_fetched = 56;
  
  Specified by:
  
  getShuffleMergedLocalBlocksFetched in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedLocalBlocksFetched.
- getShuffleMergedRemoteChunksFetched
  
  public long getShuffleMergedRemoteChunksFetched()
  
  int64 shuffle_merged_remote_chunks_fetched = 57;
  
  Specified by:
  
  getShuffleMergedRemoteChunksFetched in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedRemoteChunksFetched.
- getShuffleMergedLocalChunksFetched
  
  public long getShuffleMergedLocalChunksFetched()
  
  int64 shuffle_merged_local_chunks_fetched = 58;
  
  Specified by:
  
  getShuffleMergedLocalChunksFetched in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedLocalChunksFetched.
- getShuffleMergedRemoteBytesRead
  
  public long getShuffleMergedRemoteBytesRead()
  
  int64 shuffle_merged_remote_bytes_read = 59;
  
  Specified by:
  
  getShuffleMergedRemoteBytesRead in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedRemoteBytesRead.
- getShuffleMergedLocalBytesRead
  
  public long getShuffleMergedLocalBytesRead()
  
  int64 shuffle_merged_local_bytes_read = 60;
  
  Specified by:
  
  getShuffleMergedLocalBytesRead in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedLocalBytesRead.
- getShuffleRemoteReqsDuration
  
  public long getShuffleRemoteReqsDuration()
  
  int64 shuffle_remote_reqs_duration = 61;
  
  Specified by:
  
  getShuffleRemoteReqsDuration in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleRemoteReqsDuration.
- getShuffleMergedRemoteReqsDuration
  
  public long getShuffleMergedRemoteReqsDuration()
  
  int64 shuffle_merged_remote_reqs_duration = 62;
  
  Specified by:
  
  getShuffleMergedRemoteReqsDuration in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergedRemoteReqsDuration.
- getIsShufflePushEnabled
  
  public boolean getIsShufflePushEnabled()
  
  bool is_shuffle_push_enabled = 63;
  
  Specified by:
  
  getIsShufflePushEnabled in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The isShufflePushEnabled.
- getShuffleMergersCount
  
  public int getShuffleMergersCount()
  
  int32 shuffle_mergers_count = 64;
  
  Specified by:
  
  getShuffleMergersCount in interface StoreTypes.StageDataOrBuilder
  
  Returns:
  
  The shuffleMergersCount.
- isInitialized
  
  public final boolean isInitialized()
  
  Specified by:
  
  isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
  
  Overrides:
  
  isInitialized in class com.google.protobuf.GeneratedMessageV3
- writeTo
  
  public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
  
  Specified by:
  
  writeTo in interface com.google.protobuf.MessageLite
  
  Overrides:
  
  writeTo in class com.google.protobuf.GeneratedMessageV3
  
  Throws:
  
  IOException
- getSerializedSize
  
  public int getSerializedSize()
  
  Specified by:
  
  getSerializedSize in interface com.google.protobuf.MessageLite
  
  Overrides:
  
  getSerializedSize in class com.google.protobuf.GeneratedMessageV3
- equals
  
  public boolean equals(Object obj)
  
  Specified by:
  
  equals in interface com.google.protobuf.Message
  
  Overrides:
  
  equals in class com.google.protobuf.AbstractMessage
- hashCode
  
  public int hashCode()
  
  Specified by:
  
  hashCode in interface com.google.protobuf.Message
  
  Overrides:
  
  hashCode in class com.google.protobuf.AbstractMessage
- parseFrom
  
  public static StoreTypes.StageData parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
  
  Throws:
  
  com.google.protobuf.InvalidProtocolBufferException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
  
  Throws:
  
  com.google.protobuf.InvalidProtocolBufferException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
  
  Throws:
  
  com.google.protobuf.InvalidProtocolBufferException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
  
  Throws:
  
  com.google.protobuf.InvalidProtocolBufferException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
  
  Throws:
  
  com.google.protobuf.InvalidProtocolBufferException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
  
  Throws:
  
  com.google.protobuf.InvalidProtocolBufferException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(InputStream input) throws IOException
  
  Throws:
  
  IOException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
  
  Throws:
  
  IOException
- parseDelimitedFrom
  
  public static StoreTypes.StageData parseDelimitedFrom(InputStream input) throws IOException
  
  Throws:
  
  IOException
- parseDelimitedFrom
  
  public static StoreTypes.StageData parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
  
  Throws:
  
  IOException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
  
  Throws:
  
  IOException
- parseFrom
  
  public static StoreTypes.StageData parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
  
  Throws:
  
  IOException
- newBuilderForType
  
  public StoreTypes.StageData.Builder newBuilderForType()
  
  Specified by:
  
  newBuilderForType in interface com.google.protobuf.Message
  
  Specified by:
  
  newBuilderForType in interface com.google.protobuf.MessageLite
- newBuilder
  
  public static StoreTypes.StageData.Builder newBuilder()
- newBuilder
  
  public static StoreTypes.StageData.Builder newBuilder(StoreTypes.StageData prototype)
- toBuilder
  
  public StoreTypes.StageData.Builder toBuilder()
  
  Specified by:
  
  toBuilder in interface com.google.protobuf.Message
  
  Specified by:
  
  toBuilder in interface com.google.protobuf.MessageLite
- getDefaultInstance
  
  public static StoreTypes.StageData getDefaultInstance()
- parser
  
  public static com.google.protobuf.Parser<StoreTypes.StageData> parser()
- getParserForType
  
  public com.google.protobuf.Parser<StoreTypes.StageData> getParserForType()
  
  Specified by:
  
  getParserForType in interface com.google.protobuf.Message
  
  Specified by:
  
  getParserForType in interface com.google.protobuf.MessageLite
  
  Overrides:
  
  getParserForType in class com.google.protobuf.GeneratedMessageV3
- getDefaultInstanceForType
  
  public StoreTypes.StageData getDefaultInstanceForType()
  
  Specified by:
  
  getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
  
  Specified by:
  
  getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

Class StoreTypes.StageData

Nested Class Summary

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

Field Summary

Method Summary

Methods inherited from class com.google.protobuf.GeneratedMessageV3

Methods inherited from class com.google.protobuf.AbstractMessage

Methods inherited from class com.google.protobuf.AbstractMessageLite

Methods inherited from class java.lang.Object

Methods inherited from interface com.google.protobuf.MessageLite

Methods inherited from interface com.google.protobuf.MessageOrBuilder

Field Details

STATUS_FIELD_NUMBER

STAGE_ID_FIELD_NUMBER

ATTEMPT_ID_FIELD_NUMBER

NUM_TASKS_FIELD_NUMBER

NUM_ACTIVE_TASKS_FIELD_NUMBER

NUM_COMPLETE_TASKS_FIELD_NUMBER

NUM_FAILED_TASKS_FIELD_NUMBER

NUM_KILLED_TASKS_FIELD_NUMBER

NUM_COMPLETED_INDICES_FIELD_NUMBER

SUBMISSION_TIME_FIELD_NUMBER

FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER

COMPLETION_TIME_FIELD_NUMBER

FAILURE_REASON_FIELD_NUMBER

EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

EXECUTOR_RUN_TIME_FIELD_NUMBER

EXECUTOR_CPU_TIME_FIELD_NUMBER

RESULT_SIZE_FIELD_NUMBER

JVM_GC_TIME_FIELD_NUMBER

RESULT_SERIALIZATION_TIME_FIELD_NUMBER

MEMORY_BYTES_SPILLED_FIELD_NUMBER

DISK_BYTES_SPILLED_FIELD_NUMBER

PEAK_EXECUTION_MEMORY_FIELD_NUMBER

INPUT_BYTES_FIELD_NUMBER

INPUT_RECORDS_FIELD_NUMBER

OUTPUT_BYTES_FIELD_NUMBER

OUTPUT_RECORDS_FIELD_NUMBER

SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER

SHUFFLE_READ_BYTES_FIELD_NUMBER

SHUFFLE_READ_RECORDS_FIELD_NUMBER

SHUFFLE_WRITE_BYTES_FIELD_NUMBER

SHUFFLE_WRITE_TIME_FIELD_NUMBER

SHUFFLE_WRITE_RECORDS_FIELD_NUMBER

NAME_FIELD_NUMBER

DESCRIPTION_FIELD_NUMBER

DETAILS_FIELD_NUMBER

SCHEDULING_POOL_FIELD_NUMBER

RDD_IDS_FIELD_NUMBER

ACCUMULATOR_UPDATES_FIELD_NUMBER

TASKS_FIELD_NUMBER

EXECUTOR_SUMMARY_FIELD_NUMBER

SPECULATION_SUMMARY_FIELD_NUMBER

KILLED_TASKS_SUMMARY_FIELD_NUMBER

RESOURCE_PROFILE_ID_FIELD_NUMBER

PEAK_EXECUTOR_METRICS_FIELD_NUMBER

TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER

EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER

SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER

IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER

SHUFFLE_MERGERS_COUNT_FIELD_NUMBER

Method Details

getDescriptor

getStatusValue

getStatus