public static final class StoreTypes.ShuffleReadMetricDistributions extends com.google.protobuf.GeneratedMessageV3 implements StoreTypes.ShuffleReadMetricDistributionsOrBuilder
org.apache.spark.status.protobuf.ShuffleReadMetricDistributions
Modifier and Type | Class and Description |
---|---|
static class |
StoreTypes.ShuffleReadMetricDistributions.Builder
Protobuf type
org.apache.spark.status.protobuf.ShuffleReadMetricDistributions |
com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
Modifier and Type | Field and Description |
---|---|
static int |
FETCH_WAIT_TIME_FIELD_NUMBER |
static int |
LOCAL_BLOCKS_FETCHED_FIELD_NUMBER |
static int |
READ_BYTES_FIELD_NUMBER |
static int |
READ_RECORDS_FIELD_NUMBER |
static int |
REMOTE_BLOCKS_FETCHED_FIELD_NUMBER |
static int |
REMOTE_BYTES_READ_FIELD_NUMBER |
static int |
REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER |
static int |
REMOTE_REQS_DURATION_FIELD_NUMBER |
static int |
SHUFFLE_PUSH_READ_METRICS_DIST_FIELD_NUMBER |
static int |
TOTAL_BLOCKS_FETCHED_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
static StoreTypes.ShuffleReadMetricDistributions |
getDefaultInstance() |
StoreTypes.ShuffleReadMetricDistributions |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
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; |
com.google.protobuf.Parser<StoreTypes.ShuffleReadMetricDistributions> |
getParserForType() |
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; |
int |
getSerializedSize() |
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; |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
int |
hashCode() |
boolean |
hasShufflePushReadMetricsDist()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10; |
boolean |
isInitialized() |
static StoreTypes.ShuffleReadMetricDistributions.Builder |
newBuilder() |
static StoreTypes.ShuffleReadMetricDistributions.Builder |
newBuilder(StoreTypes.ShuffleReadMetricDistributions prototype) |
StoreTypes.ShuffleReadMetricDistributions.Builder |
newBuilderForType() |
static StoreTypes.ShuffleReadMetricDistributions |
parseDelimitedFrom(java.io.InputStream input) |
static StoreTypes.ShuffleReadMetricDistributions |
parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(byte[] data) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(java.nio.ByteBuffer data) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(com.google.protobuf.ByteString data) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(com.google.protobuf.CodedInputStream input) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(java.io.InputStream input) |
static StoreTypes.ShuffleReadMetricDistributions |
parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<StoreTypes.ShuffleReadMetricDistributions> |
parser() |
StoreTypes.ShuffleReadMetricDistributions.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof
findInitializationErrors, getInitializationErrorString, toString
toByteArray, toByteString, writeDelimitedTo, writeTo
public static final int READ_BYTES_FIELD_NUMBER
public static final int READ_RECORDS_FIELD_NUMBER
public static final int REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
public static final int LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
public static final int FETCH_WAIT_TIME_FIELD_NUMBER
public static final int REMOTE_BYTES_READ_FIELD_NUMBER
public static final int REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
public static final int TOTAL_BLOCKS_FETCHED_FIELD_NUMBER
public static final int REMOTE_REQS_DURATION_FIELD_NUMBER
public static final int SHUFFLE_PUSH_READ_METRICS_DIST_FIELD_NUMBER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public java.util.List<Double> getReadBytesList()
repeated double read_bytes = 1;
getReadBytesList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getReadBytesCount()
repeated double read_bytes = 1;
getReadBytesCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getReadBytes(int index)
repeated double read_bytes = 1;
getReadBytes
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getReadRecordsList()
repeated double read_records = 2;
getReadRecordsList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getReadRecordsCount()
repeated double read_records = 2;
getReadRecordsCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getReadRecords(int index)
repeated double read_records = 2;
getReadRecords
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getRemoteBlocksFetchedList()
repeated double remote_blocks_fetched = 3;
getRemoteBlocksFetchedList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getRemoteBlocksFetchedCount()
repeated double remote_blocks_fetched = 3;
getRemoteBlocksFetchedCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getRemoteBlocksFetched(int index)
repeated double remote_blocks_fetched = 3;
getRemoteBlocksFetched
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getLocalBlocksFetchedList()
repeated double local_blocks_fetched = 4;
getLocalBlocksFetchedList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getLocalBlocksFetchedCount()
repeated double local_blocks_fetched = 4;
getLocalBlocksFetchedCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getLocalBlocksFetched(int index)
repeated double local_blocks_fetched = 4;
getLocalBlocksFetched
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getFetchWaitTimeList()
repeated double fetch_wait_time = 5;
getFetchWaitTimeList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getFetchWaitTimeCount()
repeated double fetch_wait_time = 5;
getFetchWaitTimeCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getFetchWaitTime(int index)
repeated double fetch_wait_time = 5;
getFetchWaitTime
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getRemoteBytesReadList()
repeated double remote_bytes_read = 6;
getRemoteBytesReadList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getRemoteBytesReadCount()
repeated double remote_bytes_read = 6;
getRemoteBytesReadCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getRemoteBytesRead(int index)
repeated double remote_bytes_read = 6;
getRemoteBytesRead
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getRemoteBytesReadToDiskList()
repeated double remote_bytes_read_to_disk = 7;
getRemoteBytesReadToDiskList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getRemoteBytesReadToDiskCount()
repeated double remote_bytes_read_to_disk = 7;
getRemoteBytesReadToDiskCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getRemoteBytesReadToDisk(int index)
repeated double remote_bytes_read_to_disk = 7;
getRemoteBytesReadToDisk
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getTotalBlocksFetchedList()
repeated double total_blocks_fetched = 8;
getTotalBlocksFetchedList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getTotalBlocksFetchedCount()
repeated double total_blocks_fetched = 8;
getTotalBlocksFetchedCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getTotalBlocksFetched(int index)
repeated double total_blocks_fetched = 8;
getTotalBlocksFetched
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public java.util.List<Double> getRemoteReqsDurationList()
repeated double remote_reqs_duration = 9;
getRemoteReqsDurationList
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public int getRemoteReqsDurationCount()
repeated double remote_reqs_duration = 9;
getRemoteReqsDurationCount
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public double getRemoteReqsDuration(int index)
repeated double remote_reqs_duration = 9;
getRemoteReqsDuration
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
index
- The index of the element to return.public boolean hasShufflePushReadMetricsDist()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
hasShufflePushReadMetricsDist
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public StoreTypes.ShufflePushReadMetricDistributions getShufflePushReadMetricsDist()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
getShufflePushReadMetricsDist
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public StoreTypes.ShufflePushReadMetricDistributionsOrBuilder getShufflePushReadMetricsDistOrBuilder()
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
getShufflePushReadMetricsDistOrBuilder
in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
java.io.IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.ShuffleReadMetricDistributions parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.ShuffleReadMetricDistributions parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOException
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public StoreTypes.ShuffleReadMetricDistributions.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static StoreTypes.ShuffleReadMetricDistributions.Builder newBuilder()
public static StoreTypes.ShuffleReadMetricDistributions.Builder newBuilder(StoreTypes.ShuffleReadMetricDistributions prototype)
public StoreTypes.ShuffleReadMetricDistributions.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
public static StoreTypes.ShuffleReadMetricDistributions getDefaultInstance()
public static com.google.protobuf.Parser<StoreTypes.ShuffleReadMetricDistributions> parser()
public com.google.protobuf.Parser<StoreTypes.ShuffleReadMetricDistributions> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public StoreTypes.ShuffleReadMetricDistributions getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder