public static interface StoreTypes.ExecutorMetricsDistributionsOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
double |
getDiskBytesSpilled(int index)
repeated double disk_bytes_spilled = 15; |
int |
getDiskBytesSpilledCount()
repeated double disk_bytes_spilled = 15; |
java.util.List<Double> |
getDiskBytesSpilledList()
repeated double disk_bytes_spilled = 15; |
double |
getFailedTasks(int index)
repeated double failed_tasks = 3; |
int |
getFailedTasksCount()
repeated double failed_tasks = 3; |
java.util.List<Double> |
getFailedTasksList()
repeated double failed_tasks = 3; |
double |
getInputBytes(int index)
repeated double input_bytes = 6; |
int |
getInputBytesCount()
repeated double input_bytes = 6; |
java.util.List<Double> |
getInputBytesList()
repeated double input_bytes = 6; |
double |
getInputRecords(int index)
repeated double input_records = 7; |
int |
getInputRecordsCount()
repeated double input_records = 7; |
java.util.List<Double> |
getInputRecordsList()
repeated double input_records = 7; |
double |
getKilledTasks(int index)
repeated double killed_tasks = 5; |
int |
getKilledTasksCount()
repeated double killed_tasks = 5; |
java.util.List<Double> |
getKilledTasksList()
repeated double killed_tasks = 5; |
double |
getMemoryBytesSpilled(int index)
repeated double memory_bytes_spilled = 14; |
int |
getMemoryBytesSpilledCount()
repeated double memory_bytes_spilled = 14; |
java.util.List<Double> |
getMemoryBytesSpilledList()
repeated double memory_bytes_spilled = 14; |
double |
getOutputBytes(int index)
repeated double output_bytes = 8; |
int |
getOutputBytesCount()
repeated double output_bytes = 8; |
java.util.List<Double> |
getOutputBytesList()
repeated double output_bytes = 8; |
double |
getOutputRecords(int index)
repeated double output_records = 9; |
int |
getOutputRecordsCount()
repeated double output_records = 9; |
java.util.List<Double> |
getOutputRecordsList()
repeated double output_records = 9; |
StoreTypes.ExecutorPeakMetricsDistributions |
getPeakMemoryMetrics()
.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16; |
StoreTypes.ExecutorPeakMetricsDistributionsOrBuilder |
getPeakMemoryMetricsOrBuilder()
.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16; |
double |
getQuantiles(int index)
repeated double quantiles = 1; |
int |
getQuantilesCount()
repeated double quantiles = 1; |
java.util.List<Double> |
getQuantilesList()
repeated double quantiles = 1; |
double |
getShuffleRead(int index)
repeated double shuffle_read = 10; |
int |
getShuffleReadCount()
repeated double shuffle_read = 10; |
java.util.List<Double> |
getShuffleReadList()
repeated double shuffle_read = 10; |
double |
getShuffleReadRecords(int index)
repeated double shuffle_read_records = 11; |
int |
getShuffleReadRecordsCount()
repeated double shuffle_read_records = 11; |
java.util.List<Double> |
getShuffleReadRecordsList()
repeated double shuffle_read_records = 11; |
double |
getShuffleWrite(int index)
repeated double shuffle_write = 12; |
int |
getShuffleWriteCount()
repeated double shuffle_write = 12; |
java.util.List<Double> |
getShuffleWriteList()
repeated double shuffle_write = 12; |
double |
getShuffleWriteRecords(int index)
repeated double shuffle_write_records = 13; |
int |
getShuffleWriteRecordsCount()
repeated double shuffle_write_records = 13; |
java.util.List<Double> |
getShuffleWriteRecordsList()
repeated double shuffle_write_records = 13; |
double |
getSucceededTasks(int index)
repeated double succeeded_tasks = 4; |
int |
getSucceededTasksCount()
repeated double succeeded_tasks = 4; |
java.util.List<Double> |
getSucceededTasksList()
repeated double succeeded_tasks = 4; |
double |
getTaskTime(int index)
repeated double task_time = 2; |
int |
getTaskTimeCount()
repeated double task_time = 2; |
java.util.List<Double> |
getTaskTimeList()
repeated double task_time = 2; |
boolean |
hasPeakMemoryMetrics()
.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
java.util.List<Double> getQuantilesList()
repeated double quantiles = 1;
int getQuantilesCount()
repeated double quantiles = 1;
double getQuantiles(int index)
repeated double quantiles = 1;
index
- The index of the element to return.java.util.List<Double> getTaskTimeList()
repeated double task_time = 2;
int getTaskTimeCount()
repeated double task_time = 2;
double getTaskTime(int index)
repeated double task_time = 2;
index
- The index of the element to return.java.util.List<Double> getFailedTasksList()
repeated double failed_tasks = 3;
int getFailedTasksCount()
repeated double failed_tasks = 3;
double getFailedTasks(int index)
repeated double failed_tasks = 3;
index
- The index of the element to return.java.util.List<Double> getSucceededTasksList()
repeated double succeeded_tasks = 4;
int getSucceededTasksCount()
repeated double succeeded_tasks = 4;
double getSucceededTasks(int index)
repeated double succeeded_tasks = 4;
index
- The index of the element to return.java.util.List<Double> getKilledTasksList()
repeated double killed_tasks = 5;
int getKilledTasksCount()
repeated double killed_tasks = 5;
double getKilledTasks(int index)
repeated double killed_tasks = 5;
index
- The index of the element to return.java.util.List<Double> getInputBytesList()
repeated double input_bytes = 6;
int getInputBytesCount()
repeated double input_bytes = 6;
double getInputBytes(int index)
repeated double input_bytes = 6;
index
- The index of the element to return.java.util.List<Double> getInputRecordsList()
repeated double input_records = 7;
int getInputRecordsCount()
repeated double input_records = 7;
double getInputRecords(int index)
repeated double input_records = 7;
index
- The index of the element to return.java.util.List<Double> getOutputBytesList()
repeated double output_bytes = 8;
int getOutputBytesCount()
repeated double output_bytes = 8;
double getOutputBytes(int index)
repeated double output_bytes = 8;
index
- The index of the element to return.java.util.List<Double> getOutputRecordsList()
repeated double output_records = 9;
int getOutputRecordsCount()
repeated double output_records = 9;
double getOutputRecords(int index)
repeated double output_records = 9;
index
- The index of the element to return.java.util.List<Double> getShuffleReadList()
repeated double shuffle_read = 10;
int getShuffleReadCount()
repeated double shuffle_read = 10;
double getShuffleRead(int index)
repeated double shuffle_read = 10;
index
- The index of the element to return.java.util.List<Double> getShuffleReadRecordsList()
repeated double shuffle_read_records = 11;
int getShuffleReadRecordsCount()
repeated double shuffle_read_records = 11;
double getShuffleReadRecords(int index)
repeated double shuffle_read_records = 11;
index
- The index of the element to return.java.util.List<Double> getShuffleWriteList()
repeated double shuffle_write = 12;
int getShuffleWriteCount()
repeated double shuffle_write = 12;
double getShuffleWrite(int index)
repeated double shuffle_write = 12;
index
- The index of the element to return.java.util.List<Double> getShuffleWriteRecordsList()
repeated double shuffle_write_records = 13;
int getShuffleWriteRecordsCount()
repeated double shuffle_write_records = 13;
double getShuffleWriteRecords(int index)
repeated double shuffle_write_records = 13;
index
- The index of the element to return.java.util.List<Double> getMemoryBytesSpilledList()
repeated double memory_bytes_spilled = 14;
int getMemoryBytesSpilledCount()
repeated double memory_bytes_spilled = 14;
double getMemoryBytesSpilled(int index)
repeated double memory_bytes_spilled = 14;
index
- The index of the element to return.java.util.List<Double> getDiskBytesSpilledList()
repeated double disk_bytes_spilled = 15;
int getDiskBytesSpilledCount()
repeated double disk_bytes_spilled = 15;
double getDiskBytesSpilled(int index)
repeated double disk_bytes_spilled = 15;
index
- The index of the element to return.boolean hasPeakMemoryMetrics()
.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorPeakMetricsDistributions getPeakMemoryMetrics()
.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorPeakMetricsDistributionsOrBuilder getPeakMemoryMetricsOrBuilder()
.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;