public static interface StoreTypes.TaskMetricDistributionsOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
double |
getDiskBytesSpilled(int index)
repeated double disk_bytes_spilled = 14; |
int |
getDiskBytesSpilledCount()
repeated double disk_bytes_spilled = 14; |
java.util.List<Double> |
getDiskBytesSpilledList()
repeated double disk_bytes_spilled = 14; |
double |
getDuration(int index)
repeated double duration = 2; |
int |
getDurationCount()
repeated double duration = 2; |
java.util.List<Double> |
getDurationList()
repeated double duration = 2; |
double |
getExecutorCpuTime(int index)
repeated double executor_cpu_time = 6; |
int |
getExecutorCpuTimeCount()
repeated double executor_cpu_time = 6; |
java.util.List<Double> |
getExecutorCpuTimeList()
repeated double executor_cpu_time = 6; |
double |
getExecutorDeserializeCpuTime(int index)
repeated double executor_deserialize_cpu_time = 4; |
int |
getExecutorDeserializeCpuTimeCount()
repeated double executor_deserialize_cpu_time = 4; |
java.util.List<Double> |
getExecutorDeserializeCpuTimeList()
repeated double executor_deserialize_cpu_time = 4; |
double |
getExecutorDeserializeTime(int index)
repeated double executor_deserialize_time = 3; |
int |
getExecutorDeserializeTimeCount()
repeated double executor_deserialize_time = 3; |
java.util.List<Double> |
getExecutorDeserializeTimeList()
repeated double executor_deserialize_time = 3; |
double |
getExecutorRunTime(int index)
repeated double executor_run_time = 5; |
int |
getExecutorRunTimeCount()
repeated double executor_run_time = 5; |
java.util.List<Double> |
getExecutorRunTimeList()
repeated double executor_run_time = 5; |
double |
getGettingResultTime(int index)
repeated double getting_result_time = 10; |
int |
getGettingResultTimeCount()
repeated double getting_result_time = 10; |
java.util.List<Double> |
getGettingResultTimeList()
repeated double getting_result_time = 10; |
StoreTypes.InputMetricDistributions |
getInputMetrics()
.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15; |
StoreTypes.InputMetricDistributionsOrBuilder |
getInputMetricsOrBuilder()
.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15; |
double |
getJvmGcTime(int index)
repeated double jvm_gc_time = 8; |
int |
getJvmGcTimeCount()
repeated double jvm_gc_time = 8; |
java.util.List<Double> |
getJvmGcTimeList()
repeated double jvm_gc_time = 8; |
double |
getMemoryBytesSpilled(int index)
repeated double memory_bytes_spilled = 13; |
int |
getMemoryBytesSpilledCount()
repeated double memory_bytes_spilled = 13; |
java.util.List<Double> |
getMemoryBytesSpilledList()
repeated double memory_bytes_spilled = 13; |
StoreTypes.OutputMetricDistributions |
getOutputMetrics()
.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16; |
StoreTypes.OutputMetricDistributionsOrBuilder |
getOutputMetricsOrBuilder()
.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16; |
double |
getPeakExecutionMemory(int index)
repeated double peak_execution_memory = 12; |
int |
getPeakExecutionMemoryCount()
repeated double peak_execution_memory = 12; |
java.util.List<Double> |
getPeakExecutionMemoryList()
repeated double peak_execution_memory = 12; |
double |
getQuantiles(int index)
repeated double quantiles = 1; |
int |
getQuantilesCount()
repeated double quantiles = 1; |
java.util.List<Double> |
getQuantilesList()
repeated double quantiles = 1; |
double |
getResultSerializationTime(int index)
repeated double result_serialization_time = 9; |
int |
getResultSerializationTimeCount()
repeated double result_serialization_time = 9; |
java.util.List<Double> |
getResultSerializationTimeList()
repeated double result_serialization_time = 9; |
double |
getResultSize(int index)
repeated double result_size = 7; |
int |
getResultSizeCount()
repeated double result_size = 7; |
java.util.List<Double> |
getResultSizeList()
repeated double result_size = 7; |
double |
getSchedulerDelay(int index)
repeated double scheduler_delay = 11; |
int |
getSchedulerDelayCount()
repeated double scheduler_delay = 11; |
java.util.List<Double> |
getSchedulerDelayList()
repeated double scheduler_delay = 11; |
StoreTypes.ShuffleReadMetricDistributions |
getShuffleReadMetrics()
.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17; |
StoreTypes.ShuffleReadMetricDistributionsOrBuilder |
getShuffleReadMetricsOrBuilder()
.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17; |
StoreTypes.ShuffleWriteMetricDistributions |
getShuffleWriteMetrics()
.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18; |
StoreTypes.ShuffleWriteMetricDistributionsOrBuilder |
getShuffleWriteMetricsOrBuilder()
.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18; |
boolean |
hasInputMetrics()
.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15; |
boolean |
hasOutputMetrics()
.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16; |
boolean |
hasShuffleReadMetrics()
.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17; |
boolean |
hasShuffleWriteMetrics()
.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18; |
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> getDurationList()
repeated double duration = 2;
int getDurationCount()
repeated double duration = 2;
double getDuration(int index)
repeated double duration = 2;
index
- The index of the element to return.java.util.List<Double> getExecutorDeserializeTimeList()
repeated double executor_deserialize_time = 3;
int getExecutorDeserializeTimeCount()
repeated double executor_deserialize_time = 3;
double getExecutorDeserializeTime(int index)
repeated double executor_deserialize_time = 3;
index
- The index of the element to return.java.util.List<Double> getExecutorDeserializeCpuTimeList()
repeated double executor_deserialize_cpu_time = 4;
int getExecutorDeserializeCpuTimeCount()
repeated double executor_deserialize_cpu_time = 4;
double getExecutorDeserializeCpuTime(int index)
repeated double executor_deserialize_cpu_time = 4;
index
- The index of the element to return.java.util.List<Double> getExecutorRunTimeList()
repeated double executor_run_time = 5;
int getExecutorRunTimeCount()
repeated double executor_run_time = 5;
double getExecutorRunTime(int index)
repeated double executor_run_time = 5;
index
- The index of the element to return.java.util.List<Double> getExecutorCpuTimeList()
repeated double executor_cpu_time = 6;
int getExecutorCpuTimeCount()
repeated double executor_cpu_time = 6;
double getExecutorCpuTime(int index)
repeated double executor_cpu_time = 6;
index
- The index of the element to return.java.util.List<Double> getResultSizeList()
repeated double result_size = 7;
int getResultSizeCount()
repeated double result_size = 7;
double getResultSize(int index)
repeated double result_size = 7;
index
- The index of the element to return.java.util.List<Double> getJvmGcTimeList()
repeated double jvm_gc_time = 8;
int getJvmGcTimeCount()
repeated double jvm_gc_time = 8;
double getJvmGcTime(int index)
repeated double jvm_gc_time = 8;
index
- The index of the element to return.java.util.List<Double> getResultSerializationTimeList()
repeated double result_serialization_time = 9;
int getResultSerializationTimeCount()
repeated double result_serialization_time = 9;
double getResultSerializationTime(int index)
repeated double result_serialization_time = 9;
index
- The index of the element to return.java.util.List<Double> getGettingResultTimeList()
repeated double getting_result_time = 10;
int getGettingResultTimeCount()
repeated double getting_result_time = 10;
double getGettingResultTime(int index)
repeated double getting_result_time = 10;
index
- The index of the element to return.java.util.List<Double> getSchedulerDelayList()
repeated double scheduler_delay = 11;
int getSchedulerDelayCount()
repeated double scheduler_delay = 11;
double getSchedulerDelay(int index)
repeated double scheduler_delay = 11;
index
- The index of the element to return.java.util.List<Double> getPeakExecutionMemoryList()
repeated double peak_execution_memory = 12;
int getPeakExecutionMemoryCount()
repeated double peak_execution_memory = 12;
double getPeakExecutionMemory(int index)
repeated double peak_execution_memory = 12;
index
- The index of the element to return.java.util.List<Double> getMemoryBytesSpilledList()
repeated double memory_bytes_spilled = 13;
int getMemoryBytesSpilledCount()
repeated double memory_bytes_spilled = 13;
double getMemoryBytesSpilled(int index)
repeated double memory_bytes_spilled = 13;
index
- The index of the element to return.java.util.List<Double> getDiskBytesSpilledList()
repeated double disk_bytes_spilled = 14;
int getDiskBytesSpilledCount()
repeated double disk_bytes_spilled = 14;
double getDiskBytesSpilled(int index)
repeated double disk_bytes_spilled = 14;
index
- The index of the element to return.boolean hasInputMetrics()
.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.InputMetricDistributions getInputMetrics()
.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.InputMetricDistributionsOrBuilder getInputMetricsOrBuilder()
.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
boolean hasOutputMetrics()
.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.OutputMetricDistributions getOutputMetrics()
.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.OutputMetricDistributionsOrBuilder getOutputMetricsOrBuilder()
.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
boolean hasShuffleReadMetrics()
.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.ShuffleReadMetricDistributions getShuffleReadMetrics()
.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.ShuffleReadMetricDistributionsOrBuilder getShuffleReadMetricsOrBuilder()
.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
boolean hasShuffleWriteMetrics()
.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
StoreTypes.ShuffleWriteMetricDistributions getShuffleWriteMetrics()
.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
StoreTypes.ShuffleWriteMetricDistributionsOrBuilder getShuffleWriteMetricsOrBuilder()
.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;