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; |
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, getUnknownFields, hasField, hasOneof
findInitializationErrors, getInitializationErrorString, toString
toByteArray, toByteString, writeDelimitedTo, writeTo
public 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 static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public int getStatusValue()
.org.apache.spark.status.protobuf.StageStatus status = 1;
getStatusValue
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.StageStatus getStatus()
.org.apache.spark.status.protobuf.StageStatus status = 1;
getStatus
in interface StoreTypes.StageDataOrBuilder
public long getStageId()
int64 stage_id = 2;
getStageId
in interface StoreTypes.StageDataOrBuilder
public int getAttemptId()
int32 attempt_id = 3;
getAttemptId
in interface StoreTypes.StageDataOrBuilder
public int getNumTasks()
int32 num_tasks = 4;
getNumTasks
in interface StoreTypes.StageDataOrBuilder
public int getNumActiveTasks()
int32 num_active_tasks = 5;
getNumActiveTasks
in interface StoreTypes.StageDataOrBuilder
public int getNumCompleteTasks()
int32 num_complete_tasks = 6;
getNumCompleteTasks
in interface StoreTypes.StageDataOrBuilder
public int getNumFailedTasks()
int32 num_failed_tasks = 7;
getNumFailedTasks
in interface StoreTypes.StageDataOrBuilder
public int getNumKilledTasks()
int32 num_killed_tasks = 8;
getNumKilledTasks
in interface StoreTypes.StageDataOrBuilder
public int getNumCompletedIndices()
int32 num_completed_indices = 9;
getNumCompletedIndices
in interface StoreTypes.StageDataOrBuilder
public boolean hasSubmissionTime()
optional int64 submission_time = 10;
hasSubmissionTime
in interface StoreTypes.StageDataOrBuilder
public long getSubmissionTime()
optional int64 submission_time = 10;
getSubmissionTime
in interface StoreTypes.StageDataOrBuilder
public boolean hasFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;
hasFirstTaskLaunchedTime
in interface StoreTypes.StageDataOrBuilder
public long getFirstTaskLaunchedTime()
optional int64 first_task_launched_time = 11;
getFirstTaskLaunchedTime
in interface StoreTypes.StageDataOrBuilder
public boolean hasCompletionTime()
optional int64 completion_time = 12;
hasCompletionTime
in interface StoreTypes.StageDataOrBuilder
public long getCompletionTime()
optional int64 completion_time = 12;
getCompletionTime
in interface StoreTypes.StageDataOrBuilder
public boolean hasFailureReason()
optional string failure_reason = 13;
hasFailureReason
in interface StoreTypes.StageDataOrBuilder
public String getFailureReason()
optional string failure_reason = 13;
getFailureReason
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getFailureReasonBytes()
optional string failure_reason = 13;
getFailureReasonBytes
in interface StoreTypes.StageDataOrBuilder
public long getExecutorDeserializeTime()
int64 executor_deserialize_time = 14;
getExecutorDeserializeTime
in interface StoreTypes.StageDataOrBuilder
public long getExecutorDeserializeCpuTime()
int64 executor_deserialize_cpu_time = 15;
getExecutorDeserializeCpuTime
in interface StoreTypes.StageDataOrBuilder
public long getExecutorRunTime()
int64 executor_run_time = 16;
getExecutorRunTime
in interface StoreTypes.StageDataOrBuilder
public long getExecutorCpuTime()
int64 executor_cpu_time = 17;
getExecutorCpuTime
in interface StoreTypes.StageDataOrBuilder
public long getResultSize()
int64 result_size = 18;
getResultSize
in interface StoreTypes.StageDataOrBuilder
public long getJvmGcTime()
int64 jvm_gc_time = 19;
getJvmGcTime
in interface StoreTypes.StageDataOrBuilder
public long getResultSerializationTime()
int64 result_serialization_time = 20;
getResultSerializationTime
in interface StoreTypes.StageDataOrBuilder
public long getMemoryBytesSpilled()
int64 memory_bytes_spilled = 21;
getMemoryBytesSpilled
in interface StoreTypes.StageDataOrBuilder
public long getDiskBytesSpilled()
int64 disk_bytes_spilled = 22;
getDiskBytesSpilled
in interface StoreTypes.StageDataOrBuilder
public long getPeakExecutionMemory()
int64 peak_execution_memory = 23;
getPeakExecutionMemory
in interface StoreTypes.StageDataOrBuilder
public long getInputBytes()
int64 input_bytes = 24;
getInputBytes
in interface StoreTypes.StageDataOrBuilder
public long getInputRecords()
int64 input_records = 25;
getInputRecords
in interface StoreTypes.StageDataOrBuilder
public long getOutputBytes()
int64 output_bytes = 26;
getOutputBytes
in interface StoreTypes.StageDataOrBuilder
public long getOutputRecords()
int64 output_records = 27;
getOutputRecords
in interface StoreTypes.StageDataOrBuilder
public long getShuffleRemoteBlocksFetched()
int64 shuffle_remote_blocks_fetched = 28;
getShuffleRemoteBlocksFetched
in interface StoreTypes.StageDataOrBuilder
public long getShuffleLocalBlocksFetched()
int64 shuffle_local_blocks_fetched = 29;
getShuffleLocalBlocksFetched
in interface StoreTypes.StageDataOrBuilder
public long getShuffleFetchWaitTime()
int64 shuffle_fetch_wait_time = 30;
getShuffleFetchWaitTime
in interface StoreTypes.StageDataOrBuilder
public long getShuffleRemoteBytesRead()
int64 shuffle_remote_bytes_read = 31;
getShuffleRemoteBytesRead
in interface StoreTypes.StageDataOrBuilder
public long getShuffleRemoteBytesReadToDisk()
int64 shuffle_remote_bytes_read_to_disk = 32;
getShuffleRemoteBytesReadToDisk
in interface StoreTypes.StageDataOrBuilder
public long getShuffleLocalBytesRead()
int64 shuffle_local_bytes_read = 33;
getShuffleLocalBytesRead
in interface StoreTypes.StageDataOrBuilder
public long getShuffleReadBytes()
int64 shuffle_read_bytes = 34;
getShuffleReadBytes
in interface StoreTypes.StageDataOrBuilder
public long getShuffleReadRecords()
int64 shuffle_read_records = 35;
getShuffleReadRecords
in interface StoreTypes.StageDataOrBuilder
public long getShuffleWriteBytes()
int64 shuffle_write_bytes = 36;
getShuffleWriteBytes
in interface StoreTypes.StageDataOrBuilder
public long getShuffleWriteTime()
int64 shuffle_write_time = 37;
getShuffleWriteTime
in interface StoreTypes.StageDataOrBuilder
public long getShuffleWriteRecords()
int64 shuffle_write_records = 38;
getShuffleWriteRecords
in interface StoreTypes.StageDataOrBuilder
public boolean hasName()
optional string name = 39;
hasName
in interface StoreTypes.StageDataOrBuilder
public String getName()
optional string name = 39;
getName
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getNameBytes()
optional string name = 39;
getNameBytes
in interface StoreTypes.StageDataOrBuilder
public boolean hasDescription()
optional string description = 40;
hasDescription
in interface StoreTypes.StageDataOrBuilder
public String getDescription()
optional string description = 40;
getDescription
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getDescriptionBytes()
optional string description = 40;
getDescriptionBytes
in interface StoreTypes.StageDataOrBuilder
public boolean hasDetails()
optional string details = 41;
hasDetails
in interface StoreTypes.StageDataOrBuilder
public String getDetails()
optional string details = 41;
getDetails
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getDetailsBytes()
optional string details = 41;
getDetailsBytes
in interface StoreTypes.StageDataOrBuilder
public boolean hasSchedulingPool()
optional string scheduling_pool = 42;
hasSchedulingPool
in interface StoreTypes.StageDataOrBuilder
public String getSchedulingPool()
optional string scheduling_pool = 42;
getSchedulingPool
in interface StoreTypes.StageDataOrBuilder
public com.google.protobuf.ByteString getSchedulingPoolBytes()
optional string scheduling_pool = 42;
getSchedulingPoolBytes
in interface StoreTypes.StageDataOrBuilder
public java.util.List<Long> getRddIdsList()
repeated int64 rdd_ids = 43;
getRddIdsList
in interface StoreTypes.StageDataOrBuilder
public int getRddIdsCount()
repeated int64 rdd_ids = 43;
getRddIdsCount
in interface StoreTypes.StageDataOrBuilder
public long getRddIds(int index)
repeated int64 rdd_ids = 43;
getRddIds
in interface StoreTypes.StageDataOrBuilder
index
- The index of the element to return.public java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdatesList
in interface StoreTypes.StageDataOrBuilder
public java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdatesOrBuilderList
in interface StoreTypes.StageDataOrBuilder
public int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdatesCount
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdates
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 44;
getAccumulatorUpdatesOrBuilder
in interface StoreTypes.StageDataOrBuilder
public int getTasksCount()
StoreTypes.StageDataOrBuilder
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksCount
in interface StoreTypes.StageDataOrBuilder
public boolean containsTasks(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
containsTasks
in interface StoreTypes.StageDataOrBuilder
@Deprecated public java.util.Map<Long,StoreTypes.TaskData> getTasks()
getTasksMap()
instead.getTasks
in interface StoreTypes.StageDataOrBuilder
public java.util.Map<Long,StoreTypes.TaskData> getTasksMap()
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksMap
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.TaskData getTasksOrDefault(long key, StoreTypes.TaskData defaultValue)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksOrDefault
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.TaskData getTasksOrThrow(long key)
map<int64, .org.apache.spark.status.protobuf.TaskData> tasks = 45;
getTasksOrThrow
in interface StoreTypes.StageDataOrBuilder
public int getExecutorSummaryCount()
StoreTypes.StageDataOrBuilder
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryCount
in interface StoreTypes.StageDataOrBuilder
public boolean containsExecutorSummary(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
containsExecutorSummary
in interface StoreTypes.StageDataOrBuilder
@Deprecated public java.util.Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummary()
getExecutorSummaryMap()
instead.getExecutorSummary
in interface StoreTypes.StageDataOrBuilder
public java.util.Map<String,StoreTypes.ExecutorStageSummary> getExecutorSummaryMap()
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryMap
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorStageSummary getExecutorSummaryOrDefault(String key, StoreTypes.ExecutorStageSummary defaultValue)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryOrDefault
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorStageSummary getExecutorSummaryOrThrow(String key)
map<string, .org.apache.spark.status.protobuf.ExecutorStageSummary> executor_summary = 46;
getExecutorSummaryOrThrow
in interface StoreTypes.StageDataOrBuilder
public boolean hasSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
hasSpeculationSummary
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.SpeculationStageSummary getSpeculationSummary()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
getSpeculationSummary
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.SpeculationStageSummaryOrBuilder getSpeculationSummaryOrBuilder()
optional .org.apache.spark.status.protobuf.SpeculationStageSummary speculation_summary = 47;
getSpeculationSummaryOrBuilder
in interface StoreTypes.StageDataOrBuilder
public int getKilledTasksSummaryCount()
StoreTypes.StageDataOrBuilder
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryCount
in interface StoreTypes.StageDataOrBuilder
public boolean containsKilledTasksSummary(String key)
map<string, int32> killed_tasks_summary = 48;
containsKilledTasksSummary
in interface StoreTypes.StageDataOrBuilder
@Deprecated public java.util.Map<String,Integer> getKilledTasksSummary()
getKilledTasksSummaryMap()
instead.getKilledTasksSummary
in interface StoreTypes.StageDataOrBuilder
public java.util.Map<String,Integer> getKilledTasksSummaryMap()
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryMap
in interface StoreTypes.StageDataOrBuilder
public int getKilledTasksSummaryOrDefault(String key, int defaultValue)
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryOrDefault
in interface StoreTypes.StageDataOrBuilder
public int getKilledTasksSummaryOrThrow(String key)
map<string, int32> killed_tasks_summary = 48;
getKilledTasksSummaryOrThrow
in interface StoreTypes.StageDataOrBuilder
public int getResourceProfileId()
int32 resource_profile_id = 49;
getResourceProfileId
in interface StoreTypes.StageDataOrBuilder
public boolean hasPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
hasPeakExecutorMetrics
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorMetrics getPeakExecutorMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
getPeakExecutorMetrics
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorMetricsOrBuilder getPeakExecutorMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_executor_metrics = 50;
getPeakExecutorMetricsOrBuilder
in interface StoreTypes.StageDataOrBuilder
public boolean hasTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
hasTaskMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.TaskMetricDistributions getTaskMetricsDistributions()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
getTaskMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.TaskMetricDistributionsOrBuilder getTaskMetricsDistributionsOrBuilder()
optional .org.apache.spark.status.protobuf.TaskMetricDistributions task_metrics_distributions = 51;
getTaskMetricsDistributionsOrBuilder
in interface StoreTypes.StageDataOrBuilder
public boolean hasExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
hasExecutorMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorMetricsDistributions getExecutorMetricsDistributions()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
getExecutorMetricsDistributions
in interface StoreTypes.StageDataOrBuilder
public StoreTypes.ExecutorMetricsDistributionsOrBuilder getExecutorMetricsDistributionsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetricsDistributions executor_metrics_distributions = 52;
getExecutorMetricsDistributionsOrBuilder
in interface StoreTypes.StageDataOrBuilder
public long getShuffleCorruptMergedBlockChunks()
int64 shuffle_corrupt_merged_block_chunks = 53;
getShuffleCorruptMergedBlockChunks
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedFetchFallbackCount()
int64 shuffle_merged_fetch_fallback_count = 54;
getShuffleMergedFetchFallbackCount
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedRemoteBlocksFetched()
int64 shuffle_merged_remote_blocks_fetched = 55;
getShuffleMergedRemoteBlocksFetched
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedLocalBlocksFetched()
int64 shuffle_merged_local_blocks_fetched = 56;
getShuffleMergedLocalBlocksFetched
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedRemoteChunksFetched()
int64 shuffle_merged_remote_chunks_fetched = 57;
getShuffleMergedRemoteChunksFetched
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedLocalChunksFetched()
int64 shuffle_merged_local_chunks_fetched = 58;
getShuffleMergedLocalChunksFetched
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedRemoteBytesRead()
int64 shuffle_merged_remote_bytes_read = 59;
getShuffleMergedRemoteBytesRead
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedLocalBytesRead()
int64 shuffle_merged_local_bytes_read = 60;
getShuffleMergedLocalBytesRead
in interface StoreTypes.StageDataOrBuilder
public long getShuffleRemoteReqsDuration()
int64 shuffle_remote_reqs_duration = 61;
getShuffleRemoteReqsDuration
in interface StoreTypes.StageDataOrBuilder
public long getShuffleMergedRemoteReqsDuration()
int64 shuffle_merged_remote_reqs_duration = 62;
getShuffleMergedRemoteReqsDuration
in interface StoreTypes.StageDataOrBuilder
public boolean getIsShufflePushEnabled()
bool is_shuffle_push_enabled = 63;
getIsShufflePushEnabled
in interface StoreTypes.StageDataOrBuilder
public int getShuffleMergersCount()
int32 shuffle_mergers_count = 64;
getShuffleMergersCount
in interface StoreTypes.StageDataOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
java.io.IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static StoreTypes.StageData parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StageData parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StageData parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StageData parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StageData parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StageData parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.StageData parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.StageData parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.StageData parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.StageData parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.StageData parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.StageData parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public StoreTypes.StageData.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public 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.Message
toBuilder
in interface com.google.protobuf.MessageLite
public 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.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public StoreTypes.StageData getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder