public static interface StoreTypes.ExecutorStageSummaryOrBuilder
extends com.google.protobuf.MessageOrBuilder
| Modifier and Type | Method and Description |
|---|---|
long |
getDiskBytesSpilled()
int64 disk_bytes_spilled = 14; |
int |
getFailedTasks()
int32 failed_tasks = 2; |
long |
getInputBytes()
int64 input_bytes = 5; |
long |
getInputRecords()
int64 input_records = 6; |
boolean |
getIsBlacklistedForStage()
bool is_blacklisted_for_stage = 15; |
boolean |
getIsExcludedForStage()
bool is_excluded_for_stage = 17; |
int |
getKilledTasks()
int32 killed_tasks = 4; |
long |
getMemoryBytesSpilled()
int64 memory_bytes_spilled = 13; |
long |
getOutputBytes()
int64 output_bytes = 7; |
long |
getOutputRecords()
int64 output_records = 8; |
StoreTypes.ExecutorMetrics |
getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; |
StoreTypes.ExecutorMetricsOrBuilder |
getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; |
long |
getShuffleRead()
int64 shuffle_read = 9; |
long |
getShuffleReadRecords()
int64 shuffle_read_records = 10; |
long |
getShuffleWrite()
int64 shuffle_write = 11; |
long |
getShuffleWriteRecords()
int64 shuffle_write_records = 12; |
int |
getSucceededTasks()
int32 succeeded_tasks = 3; |
long |
getTaskTime()
int64 task_time = 1; |
boolean |
hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneoflong getTaskTime()
int64 task_time = 1;int getFailedTasks()
int32 failed_tasks = 2;int getSucceededTasks()
int32 succeeded_tasks = 3;int getKilledTasks()
int32 killed_tasks = 4;long getInputBytes()
int64 input_bytes = 5;long getInputRecords()
int64 input_records = 6;long getOutputBytes()
int64 output_bytes = 7;long getOutputRecords()
int64 output_records = 8;long getShuffleRead()
int64 shuffle_read = 9;long getShuffleReadRecords()
int64 shuffle_read_records = 10;long getShuffleWrite()
int64 shuffle_write = 11;long getShuffleWriteRecords()
int64 shuffle_write_records = 12;long getMemoryBytesSpilled()
int64 memory_bytes_spilled = 13;long getDiskBytesSpilled()
int64 disk_bytes_spilled = 14;boolean getIsBlacklistedForStage()
bool is_blacklisted_for_stage = 15;boolean hasPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;boolean getIsExcludedForStage()
bool is_excluded_for_stage = 17;