public static final class StoreTypes.StageData extends com.google.protobuf.GeneratedMessageV3 implements StoreTypes.StageDataOrBuilder
org.apache.spark.status.protobuf.StageData| Modifier and Type | Class and Description |
|---|---|
static class |
StoreTypes.StageData.Builder
Protobuf type
org.apache.spark.status.protobuf.StageData |
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| Modifier and Type | Method and 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; |
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; |
static StoreTypes.StageData |
getDefaultInstance() |
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() |
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; |
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; |
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; |
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; |
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; |
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; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
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; |
boolean |
isInitialized() |
static StoreTypes.StageData.Builder |
newBuilder() |
static StoreTypes.StageData.Builder |
newBuilder(StoreTypes.StageData prototype) |
StoreTypes.StageData.Builder |
newBuilderForType() |
static StoreTypes.StageData |
parseDelimitedFrom(java.io.InputStream input) |
static StoreTypes.StageData |
parseDelimitedFrom(java.io.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(java.nio.ByteBuffer data) |
static StoreTypes.StageData |
parseFrom(java.nio.ByteBuffer 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(java.io.InputStream input) |
static StoreTypes.StageData |
parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<StoreTypes.StageData> |
parser() |
StoreTypes.StageData.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneoffindInitializationErrors, getInitializationErrorString, toStringtoByteArray, toByteString, writeDelimitedTo, writeTopublic static final int STATUS_FIELD_NUMBER
public static final int STAGE_ID_FIELD_NUMBER
public static final int ATTEMPT_ID_FIELD_NUMBER
public static final int NUM_TASKS_FIELD_NUMBER
public static final int NUM_ACTIVE_TASKS_FIELD_NUMBER
public static final int NUM_COMPLETE_TASKS_FIELD_NUMBER
public static final int NUM_FAILED_TASKS_FIELD_NUMBER
public static final int NUM_KILLED_TASKS_FIELD_NUMBER
public static final int NUM_COMPLETED_INDICES_FIELD_NUMBER
public static final int SUBMISSION_TIME_FIELD_NUMBER
public static final int FIRST_TASK_LAUNCHED_TIME_FIELD_NUMBER
public static final int COMPLETION_TIME_FIELD_NUMBER
public static final int FAILURE_REASON_FIELD_NUMBER
public static final int EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER
public static final int EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER
public static final int EXECUTOR_RUN_TIME_FIELD_NUMBER
public static final int EXECUTOR_CPU_TIME_FIELD_NUMBER
public static final int RESULT_SIZE_FIELD_NUMBER
public static final int JVM_GC_TIME_FIELD_NUMBER
public static final int RESULT_SERIALIZATION_TIME_FIELD_NUMBER
public static final int MEMORY_BYTES_SPILLED_FIELD_NUMBER
public static final int DISK_BYTES_SPILLED_FIELD_NUMBER
public static final int PEAK_EXECUTION_MEMORY_FIELD_NUMBER
public static final int INPUT_BYTES_FIELD_NUMBER
public static final int INPUT_RECORDS_FIELD_NUMBER
public static final int OUTPUT_BYTES_FIELD_NUMBER
public static final int OUTPUT_RECORDS_FIELD_NUMBER
public static final int SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
public static final int SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
public static final int SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER
public static final int SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER
public static final int SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
public static final int SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER
public static final int SHUFFLE_READ_BYTES_FIELD_NUMBER
public static final int SHUFFLE_READ_RECORDS_FIELD_NUMBER
public static final int SHUFFLE_WRITE_BYTES_FIELD_NUMBER
public static final int SHUFFLE_WRITE_TIME_FIELD_NUMBER
public static final int SHUFFLE_WRITE_RECORDS_FIELD_NUMBER
public static final int NAME_FIELD_NUMBER
public static final int DESCRIPTION_FIELD_NUMBER
public static final int DETAILS_FIELD_NUMBER
public static final int SCHEDULING_POOL_FIELD_NUMBER
public static final int RDD_IDS_FIELD_NUMBER
public static final int ACCUMULATOR_UPDATES_FIELD_NUMBER
public static final int TASKS_FIELD_NUMBER
public static final int EXECUTOR_SUMMARY_FIELD_NUMBER
public static final int SPECULATION_SUMMARY_FIELD_NUMBER
public static final int KILLED_TASKS_SUMMARY_FIELD_NUMBER
public static final int RESOURCE_PROFILE_ID_FIELD_NUMBER
public static final int PEAK_EXECUTOR_METRICS_FIELD_NUMBER
public static final int TASK_METRICS_DISTRIBUTIONS_FIELD_NUMBER
public static final int EXECUTOR_METRICS_DISTRIBUTIONS_FIELD_NUMBER
public static final int SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER
public static final int SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER
public static final int SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
public static final int SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
public static final int SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER
public static final int SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER
public static final int SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER
public static final int SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER
public static final int SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER
public static final int SHUFFLE_MERGED_REMOTE_REQS_DURATION_FIELD_NUMBER
public static final int IS_SHUFFLE_PUSH_ENABLED_FIELD_NUMBER
public static final int SHUFFLE_MERGERS_COUNT_FIELD_NUMBER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields in interface com.google.protobuf.MessageOrBuildergetUnknownFields in class com.google.protobuf.GeneratedMessageV3public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public int getStatusValue()
.org.apache.spark.status.protobuf.StageStatus status = 1;getStatusValue in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.StageStatus getStatus()
.org.apache.spark.status.protobuf.StageStatus status = 1;getStatus in interface StoreTypes.StageDataOrBuilderpublic long getStageId()
int64 stage_id = 2;getStageId in interface StoreTypes.StageDataOrBuilderpublic int getAttemptId()
int32 attempt_id = 3;getAttemptId in interface StoreTypes.StageDataOrBuilderpublic int getNumTasks()
int32 num_tasks = 4;getNumTasks in interface StoreTypes.StageDataOrBuilderpublic int getNumActiveTasks()
int32 num_active_tasks = 5;getNumActiveTasks in interface StoreTypes.StageDataOrBuilderpublic int getNumCompleteTasks()
int32 num_complete_tasks = 6;getNumCompleteTasks in interface StoreTypes.StageDataOrBuilderpublic int getNumFailedTasks()
int32 num_failed_tasks = 7;getNumFailedTasks in interface StoreTypes.StageDataOrBuilderpublic int getNumKilledTasks()
int32 num_killed_tasks = 8;getNumKilledTasks in interface StoreTypes.StageDataOrBuilderpublic int getNumCompletedIndices()
int32 num_completed_indices = 9;getNumCompletedIndices in interface StoreTypes.StageDataOrBuilderpublic boolean hasSubmissionTime()
optional int64 submission_time = 10;hasSubmissionTime in interface StoreTypes.StageDataOrBuilderpublic long getSubmissionTime()
optional int64 submission_time = 10;getSubmissionTime in interface StoreTypes.StageDataOrBuilderpublic boolean hasFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;hasFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilderpublic long getFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;getFirstTaskLaunchedTime in interface StoreTypes.StageDataOrBuilderpublic boolean hasCompletionTime()
optional int64 completion_time = 12;hasCompletionTime in interface StoreTypes.StageDataOrBuilderpublic long getCompletionTime()
optional int64 completion_time = 12;getCompletionTime in interface StoreTypes.StageDataOrBuilderpublic boolean hasFailureReason()
optional string failure_reason = 13;hasFailureReason in interface StoreTypes.StageDataOrBuilderpublic String getFailureReason()
optional string failure_reason = 13;getFailureReason in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getFailureReasonBytes()
optional string failure_reason = 13;getFailureReasonBytes in interface StoreTypes.StageDataOrBuilderpublic long getExecutorDeserializeTime()
int64 executor_deserialize_time = 14;getExecutorDeserializeTime in interface StoreTypes.StageDataOrBuilderpublic long getExecutorDeserializeCpuTime()
int64 executor_deserialize_cpu_time = 15;getExecutorDeserializeCpuTime in interface StoreTypes.StageDataOrBuilderpublic long getExecutorRunTime()
int64 executor_run_time = 16;getExecutorRunTime in interface StoreTypes.StageDataOrBuilderpublic long getExecutorCpuTime()
int64 executor_cpu_time = 17;getExecutorCpuTime in interface StoreTypes.StageDataOrBuilderpublic long getResultSize()
int64 result_size = 18;getResultSize in interface StoreTypes.StageDataOrBuilderpublic long getJvmGcTime()
int64 jvm_gc_time = 19;getJvmGcTime in interface StoreTypes.StageDataOrBuilderpublic long getResultSerializationTime()
int64 result_serialization_time = 20;getResultSerializationTime in interface StoreTypes.StageDataOrBuilderpublic long getMemoryBytesSpilled()
int64 memory_bytes_spilled = 21;getMemoryBytesSpilled in interface StoreTypes.StageDataOrBuilderpublic long getDiskBytesSpilled()
int64 disk_bytes_spilled = 22;getDiskBytesSpilled in interface StoreTypes.StageDataOrBuilderpublic long getPeakExecutionMemory()
int64 peak_execution_memory = 23;getPeakExecutionMemory in interface StoreTypes.StageDataOrBuilderpublic long getInputBytes()
int64 input_bytes = 24;getInputBytes in interface StoreTypes.StageDataOrBuilderpublic long getInputRecords()
int64 input_records = 25;getInputRecords in interface StoreTypes.StageDataOrBuilderpublic long getOutputBytes()
int64 output_bytes = 26;getOutputBytes in interface StoreTypes.StageDataOrBuilderpublic long getOutputRecords()
int64 output_records = 27;getOutputRecords in interface StoreTypes.StageDataOrBuilderpublic long getShuffleRemoteBlocksFetched()
int64 shuffle_remote_blocks_fetched = 28;getShuffleRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic long getShuffleLocalBlocksFetched()
int64 shuffle_local_blocks_fetched = 29;getShuffleLocalBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic long getShuffleFetchWaitTime()
int64 shuffle_fetch_wait_time = 30;getShuffleFetchWaitTime in interface StoreTypes.StageDataOrBuilderpublic long getShuffleRemoteBytesRead()
int64 shuffle_remote_bytes_read = 31;getShuffleRemoteBytesRead in interface StoreTypes.StageDataOrBuilderpublic long getShuffleRemoteBytesReadToDisk()
int64 shuffle_remote_bytes_read_to_disk = 32;getShuffleRemoteBytesReadToDisk in interface StoreTypes.StageDataOrBuilderpublic long getShuffleLocalBytesRead()
int64 shuffle_local_bytes_read = 33;getShuffleLocalBytesRead in interface StoreTypes.StageDataOrBuilderpublic long getShuffleReadBytes()
int64 shuffle_read_bytes = 34;getShuffleReadBytes in interface StoreTypes.StageDataOrBuilderpublic long getShuffleReadRecords()
int64 shuffle_read_records = 35;getShuffleReadRecords in interface StoreTypes.StageDataOrBuilderpublic long getShuffleWriteBytes()
int64 shuffle_write_bytes = 36;getShuffleWriteBytes in interface StoreTypes.StageDataOrBuilderpublic long getShuffleWriteTime()
int64 shuffle_write_time = 37;getShuffleWriteTime in interface StoreTypes.StageDataOrBuilderpublic long getShuffleWriteRecords()
int64 shuffle_write_records = 38;getShuffleWriteRecords in interface StoreTypes.StageDataOrBuilderpublic boolean hasName()
optional string name = 39;hasName in interface StoreTypes.StageDataOrBuilderpublic String getName()
optional string name = 39;getName in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getNameBytes()
optional string name = 39;getNameBytes in interface StoreTypes.StageDataOrBuilderpublic boolean hasDescription()
optional string description = 40;hasDescription in interface StoreTypes.StageDataOrBuilderpublic String getDescription()
optional string description = 40;getDescription in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getDescriptionBytes()
optional string description = 40;getDescriptionBytes in interface StoreTypes.StageDataOrBuilderpublic boolean hasDetails()
optional string details = 41;hasDetails in interface StoreTypes.StageDataOrBuilderpublic String getDetails()
optional string details = 41;getDetails in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getDetailsBytes()
optional string details = 41;getDetailsBytes in interface StoreTypes.StageDataOrBuilderpublic boolean hasSchedulingPool()
optional string scheduling_pool = 42;hasSchedulingPool in interface StoreTypes.StageDataOrBuilderpublic String getSchedulingPool()
optional string scheduling_pool = 42;getSchedulingPool in interface StoreTypes.StageDataOrBuilderpublic com.google.protobuf.ByteString getSchedulingPoolBytes()
optional string scheduling_pool = 42;getSchedulingPoolBytes in interface StoreTypes.StageDataOrBuilderpublic java.util.List<Long> getRddIdsList()
repeated int64 rdd_ids = 43;getRddIdsList in interface StoreTypes.StageDataOrBuilderpublic int getRddIdsCount()
repeated int64 rdd_ids = 43;getRddIdsCount in interface StoreTypes.StageDataOrBuilderpublic long getRddIds(int index)
repeated int64 rdd_ids = 43;getRddIds in interface StoreTypes.StageDataOrBuilderindex - The index of the element to return.public java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesList in interface StoreTypes.StageDataOrBuilderpublic java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesOrBuilderList in interface StoreTypes.StageDataOrBuilderpublic int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesCount in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdates in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;getAccumulatorUpdatesOrBuilder in interface StoreTypes.StageDataOrBuilderpublic int getTasksCount()
StoreTypes.StageDataOrBuildermap<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksCount in interface StoreTypes.StageDataOrBuilderpublic boolean containsTasks(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;containsTasks in interface StoreTypes.StageDataOrBuilder@Deprecated public java.util.Map<Long,StoreTypes.TaskData> getTasks()
getTasksMap() instead.getTasks in interface StoreTypes.StageDataOrBuilderpublic java.util.Map<Long,StoreTypes.TaskData> getTasksMap()
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksMap in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.TaskData getTasksOrDefault(long key, StoreTypes.TaskData defaultValue)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksOrDefault in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.TaskData getTasksOrThrow(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;getTasksOrThrow in interface StoreTypes.StageDataOrBuilderpublic int getExecutorSummaryCount()
StoreTypes.StageDataOrBuildermap<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryCount in interface StoreTypes.StageDataOrBuilderpublic boolean containsExecutorSummary(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;containsExecutorSummary in interface StoreTypes.StageDataOrBuilder@Deprecated public java.util.Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummary()
getExecutorSummaryMap() instead.getExecutorSummary in interface StoreTypes.StageDataOrBuilderpublic java.util.Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummaryMap()
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryMap in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorStageSummary getExecutorSummaryOrDefault(String key, StoreTypes.ExecutorStageSummary defaultValue)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryOrDefault in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorStageSummary getExecutorSummaryOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;getExecutorSummaryOrThrow in interface StoreTypes.StageDataOrBuilderpublic boolean hasSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;hasSpeculationSummary in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.SpeculationStageSummary getSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;getSpeculationSummary in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.SpeculationStageSummaryOrBuilder getSpeculationSummaryOrBuilder()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;getSpeculationSummaryOrBuilder in interface StoreTypes.StageDataOrBuilderpublic int getKilledTasksSummaryCount()
StoreTypes.StageDataOrBuildermap<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryCount in interface StoreTypes.StageDataOrBuilderpublic boolean containsKilledTasksSummary(String key)
map<string, int32> killed_tasks_summary = 48;containsKilledTasksSummary in interface StoreTypes.StageDataOrBuilder@Deprecated public java.util.Map<String,Integer> getKilledTasksSummary()
getKilledTasksSummaryMap() instead.getKilledTasksSummary in interface StoreTypes.StageDataOrBuilderpublic java.util.Map<String,Integer> getKilledTasksSummaryMap()
map<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryMap in interface StoreTypes.StageDataOrBuilderpublic int getKilledTasksSummaryOrDefault(String key,
int defaultValue)
map<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryOrDefault in interface StoreTypes.StageDataOrBuilderpublic int getKilledTasksSummaryOrThrow(String key)
map<string, int32> killed_tasks_summary = 48;getKilledTasksSummaryOrThrow in interface StoreTypes.StageDataOrBuilderpublic int getResourceProfileId()
int32 resource_profile_id = 49;getResourceProfileId in interface StoreTypes.StageDataOrBuilderpublic boolean hasPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;hasPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorMetrics getPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;getPeakExecutorMetrics in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorMetricsOrBuilder getPeakExecutorMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;getPeakExecutorMetricsOrBuilder in interface StoreTypes.StageDataOrBuilderpublic boolean hasTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;hasTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.TaskMetricDistributions getTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;getTaskMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.TaskMetricDistributionsOrBuilder getTaskMetricsDistributionsOrBuilder()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;getTaskMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilderpublic boolean hasExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;hasExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorMetricsDistributions getExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;getExecutorMetricsDistributions in interface StoreTypes.StageDataOrBuilderpublic StoreTypes.ExecutorMetricsDistributionsOrBuilder getExecutorMetricsDistributionsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;getExecutorMetricsDistributionsOrBuilder in interface StoreTypes.StageDataOrBuilderpublic long getShuffleCorruptMergedBlockChunks()
int64 shuffle_corrupt_merged_block_chunks = 53;getShuffleCorruptMergedBlockChunks in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedFetchFallbackCount()
int64 shuffle_merged_fetch_fallback_count = 54;getShuffleMergedFetchFallbackCount in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedRemoteBlocksFetched()
int64 shuffle_merged_remote_blocks_fetched = 55;getShuffleMergedRemoteBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedLocalBlocksFetched()
int64 shuffle_merged_local_blocks_fetched = 56;getShuffleMergedLocalBlocksFetched in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedRemoteChunksFetched()
int64 shuffle_merged_remote_chunks_fetched = 57;getShuffleMergedRemoteChunksFetched in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedLocalChunksFetched()
int64 shuffle_merged_local_chunks_fetched = 58;getShuffleMergedLocalChunksFetched in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedRemoteBytesRead()
int64 shuffle_merged_remote_bytes_read = 59;getShuffleMergedRemoteBytesRead in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedLocalBytesRead()
int64 shuffle_merged_local_bytes_read = 60;getShuffleMergedLocalBytesRead in interface StoreTypes.StageDataOrBuilderpublic long getShuffleRemoteReqsDuration()
int64 shuffle_remote_reqs_duration = 61;getShuffleRemoteReqsDuration in interface StoreTypes.StageDataOrBuilderpublic long getShuffleMergedRemoteReqsDuration()
int64 shuffle_merged_remote_reqs_duration = 62;getShuffleMergedRemoteReqsDuration in interface StoreTypes.StageDataOrBuilderpublic boolean getIsShufflePushEnabled()
bool is_shuffle_push_enabled = 63;getIsShufflePushEnabled in interface StoreTypes.StageDataOrBuilderpublic int getShuffleMergersCount()
int32 shuffle_mergers_count = 64;getShuffleMergersCount in interface StoreTypes.StageDataOrBuilderpublic final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException
writeTo in interface com.google.protobuf.MessageLitewriteTo in class com.google.protobuf.GeneratedMessageV3java.io.IOExceptionpublic int getSerializedSize()
getSerializedSize in interface com.google.protobuf.MessageLitegetSerializedSize in class com.google.protobuf.GeneratedMessageV3public boolean equals(Object obj)
equals in interface com.google.protobuf.Messageequals in class com.google.protobuf.AbstractMessagepublic int hashCode()
hashCode in interface com.google.protobuf.MessagehashCode in class com.google.protobuf.AbstractMessagepublic static StoreTypes.StageData parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.StageData parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.StageData parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.StageData parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.StageData parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.StageData parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferExceptionpublic static StoreTypes.StageData parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.StageData parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.StageData parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.StageData parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.StageData parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOExceptionpublic static StoreTypes.StageData parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOExceptionpublic StoreTypes.StageData.Builder newBuilderForType()
newBuilderForType in interface com.google.protobuf.MessagenewBuilderForType in interface com.google.protobuf.MessageLitepublic static StoreTypes.StageData.Builder newBuilder()
public static StoreTypes.StageData.Builder newBuilder(StoreTypes.StageData prototype)
public StoreTypes.StageData.Builder toBuilder()
toBuilder in interface com.google.protobuf.MessagetoBuilder in interface com.google.protobuf.MessageLitepublic static StoreTypes.StageData getDefaultInstance()
public static com.google.protobuf.Parser<StoreTypes.StageData> parser()
public com.google.protobuf.Parser<StoreTypes.StageData> getParserForType()
getParserForType in interface com.google.protobuf.MessagegetParserForType in interface com.google.protobuf.MessageLitegetParserForType in class com.google.protobuf.GeneratedMessageV3public StoreTypes.StageData getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder