public static interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
double |
getFetchWaitTime(int index)
repeated double fetch_wait_time = 5; |
int |
getFetchWaitTimeCount()
repeated double fetch_wait_time = 5; |
java.util.List<Double> |
getFetchWaitTimeList()
repeated double fetch_wait_time = 5; |
double |
getLocalBlocksFetched(int index)
repeated double local_blocks_fetched = 4; |
int |
getLocalBlocksFetchedCount()
repeated double local_blocks_fetched = 4; |
java.util.List<Double> |
getLocalBlocksFetchedList()
repeated double local_blocks_fetched = 4; |
double |
getReadBytes(int index)
repeated double read_bytes = 1; |
int |
getReadBytesCount()
repeated double read_bytes = 1; |
java.util.List<Double> |
getReadBytesList()
repeated double read_bytes = 1; |
double |
getReadRecords(int index)
repeated double read_records = 2; |
int |
getReadRecordsCount()
repeated double read_records = 2; |
java.util.List<Double> |
getReadRecordsList()
repeated double read_records = 2; |
double |
getRemoteBlocksFetched(int index)
repeated double remote_blocks_fetched = 3; |
int |
getRemoteBlocksFetchedCount()
repeated double remote_blocks_fetched = 3; |
java.util.List<Double> |
getRemoteBlocksFetchedList()
repeated double remote_blocks_fetched = 3; |
double |
getRemoteBytesRead(int index)
repeated double remote_bytes_read = 6; |
int |
getRemoteBytesReadCount()
repeated double remote_bytes_read = 6; |
java.util.List<Double> |
getRemoteBytesReadList()
repeated double remote_bytes_read = 6; |
double |
getRemoteBytesReadToDisk(int index)
repeated double remote_bytes_read_to_disk = 7; |
int |
getRemoteBytesReadToDiskCount()
repeated double remote_bytes_read_to_disk = 7; |
java.util.List<Double> |
getRemoteBytesReadToDiskList()
repeated double remote_bytes_read_to_disk = 7; |
double |
getRemoteReqsDuration(int index)
repeated double remote_reqs_duration = 9; |
int |
getRemoteReqsDurationCount()
repeated double remote_reqs_duration = 9; |
java.util.List<Double> |
getRemoteReqsDurationList()
repeated double remote_reqs_duration = 9; |
StoreTypes.ShufflePushReadMetricDistributions |
getShufflePushReadMetricsDist()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10; |
StoreTypes.ShufflePushReadMetricDistributionsOrBuilder |
getShufflePushReadMetricsDistOrBuilder()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10; |
double |
getTotalBlocksFetched(int index)
repeated double total_blocks_fetched = 8; |
int |
getTotalBlocksFetchedCount()
repeated double total_blocks_fetched = 8; |
java.util.List<Double> |
getTotalBlocksFetchedList()
repeated double total_blocks_fetched = 8; |
boolean |
hasShufflePushReadMetricsDist()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
java.util.List<Double> getReadBytesList()
repeated double read_bytes = 1;
int getReadBytesCount()
repeated double read_bytes = 1;
double getReadBytes(int index)
repeated double read_bytes = 1;
index
- The index of the element to return.java.util.List<Double> getReadRecordsList()
repeated double read_records = 2;
int getReadRecordsCount()
repeated double read_records = 2;
double getReadRecords(int index)
repeated double read_records = 2;
index
- The index of the element to return.java.util.List<Double> getRemoteBlocksFetchedList()
repeated double remote_blocks_fetched = 3;
int getRemoteBlocksFetchedCount()
repeated double remote_blocks_fetched = 3;
double getRemoteBlocksFetched(int index)
repeated double remote_blocks_fetched = 3;
index
- The index of the element to return.java.util.List<Double> getLocalBlocksFetchedList()
repeated double local_blocks_fetched = 4;
int getLocalBlocksFetchedCount()
repeated double local_blocks_fetched = 4;
double getLocalBlocksFetched(int index)
repeated double local_blocks_fetched = 4;
index
- The index of the element to return.java.util.List<Double> getFetchWaitTimeList()
repeated double fetch_wait_time = 5;
int getFetchWaitTimeCount()
repeated double fetch_wait_time = 5;
double getFetchWaitTime(int index)
repeated double fetch_wait_time = 5;
index
- The index of the element to return.java.util.List<Double> getRemoteBytesReadList()
repeated double remote_bytes_read = 6;
int getRemoteBytesReadCount()
repeated double remote_bytes_read = 6;
double getRemoteBytesRead(int index)
repeated double remote_bytes_read = 6;
index
- The index of the element to return.java.util.List<Double> getRemoteBytesReadToDiskList()
repeated double remote_bytes_read_to_disk = 7;
int getRemoteBytesReadToDiskCount()
repeated double remote_bytes_read_to_disk = 7;
double getRemoteBytesReadToDisk(int index)
repeated double remote_bytes_read_to_disk = 7;
index
- The index of the element to return.java.util.List<Double> getTotalBlocksFetchedList()
repeated double total_blocks_fetched = 8;
int getTotalBlocksFetchedCount()
repeated double total_blocks_fetched = 8;
double getTotalBlocksFetched(int index)
repeated double total_blocks_fetched = 8;
index
- The index of the element to return.java.util.List<Double> getRemoteReqsDurationList()
repeated double remote_reqs_duration = 9;
int getRemoteReqsDurationCount()
repeated double remote_reqs_duration = 9;
double getRemoteReqsDuration(int index)
repeated double remote_reqs_duration = 9;
index
- The index of the element to return.boolean hasShufflePushReadMetricsDist()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
StoreTypes.ShufflePushReadMetricDistributions getShufflePushReadMetricsDist()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
StoreTypes.ShufflePushReadMetricDistributionsOrBuilder getShufflePushReadMetricsDistOrBuilder()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;