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, hasOneof
long 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;