Package org.apache.spark.status.protobuf
Class StoreTypes.ShuffleReadMetricDistributions
Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
org.apache.spark.status.protobuf.StoreTypes.ShuffleReadMetricDistributions
- All Implemented Interfaces:
com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Serializable,StoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Enclosing class:
- StoreTypes
public static final class StoreTypes.ShuffleReadMetricDistributions
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.ShuffleReadMetricDistributionsOrBuilder
Protobuf type
org.apache.spark.status.protobuf.ShuffleReadMetricDistributions- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classProtobuf typeorg.apache.spark.status.protobuf.ShuffleReadMetricDistributionsNested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT, BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message, T extends Object> -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final int -
Method Summary
Modifier and TypeMethodDescriptionbooleanstatic final com.google.protobuf.Descriptors.DescriptordoublegetFetchWaitTime(int index) repeated double fetch_wait_time = 5;intrepeated double fetch_wait_time = 5;repeated double fetch_wait_time = 5;doublegetLocalBlocksFetched(int index) repeated double local_blocks_fetched = 4;intrepeated double local_blocks_fetched = 4;repeated double local_blocks_fetched = 4;com.google.protobuf.Parser<StoreTypes.ShuffleReadMetricDistributions>doublegetReadBytes(int index) repeated double read_bytes = 1;intrepeated double read_bytes = 1;repeated double read_bytes = 1;doublegetReadRecords(int index) repeated double read_records = 2;intrepeated double read_records = 2;repeated double read_records = 2;doublegetRemoteBlocksFetched(int index) repeated double remote_blocks_fetched = 3;intrepeated double remote_blocks_fetched = 3;repeated double remote_blocks_fetched = 3;doublegetRemoteBytesRead(int index) repeated double remote_bytes_read = 6;intrepeated double remote_bytes_read = 6;repeated double remote_bytes_read = 6;doublegetRemoteBytesReadToDisk(int index) repeated double remote_bytes_read_to_disk = 7;intrepeated double remote_bytes_read_to_disk = 7;repeated double remote_bytes_read_to_disk = 7;doublegetRemoteReqsDuration(int index) repeated double remote_reqs_duration = 9;intrepeated double remote_reqs_duration = 9;repeated double remote_reqs_duration = 9;int.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;doublegetTotalBlocksFetched(int index) repeated double total_blocks_fetched = 8;intrepeated double total_blocks_fetched = 8;repeated double total_blocks_fetched = 8;inthashCode()boolean.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;final booleanparseDelimitedFrom(InputStream input) parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(byte[] data) parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(com.google.protobuf.ByteString data) parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(com.google.protobuf.CodedInputStream input) parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(InputStream input) parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(ByteBuffer data) parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static com.google.protobuf.Parser<StoreTypes.ShuffleReadMetricDistributions>parser()voidwriteTo(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessage
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtensionMethods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Field Details
-
READ_BYTES_FIELD_NUMBER
public static final int READ_BYTES_FIELD_NUMBER- See Also:
-
READ_RECORDS_FIELD_NUMBER
public static final int READ_RECORDS_FIELD_NUMBER- See Also:
-
REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
public static final int REMOTE_BLOCKS_FETCHED_FIELD_NUMBER- See Also:
-
LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
public static final int LOCAL_BLOCKS_FETCHED_FIELD_NUMBER- See Also:
-
FETCH_WAIT_TIME_FIELD_NUMBER
public static final int FETCH_WAIT_TIME_FIELD_NUMBER- See Also:
-
REMOTE_BYTES_READ_FIELD_NUMBER
public static final int REMOTE_BYTES_READ_FIELD_NUMBER- See Also:
-
REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
public static final int REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER- See Also:
-
TOTAL_BLOCKS_FETCHED_FIELD_NUMBER
public static final int TOTAL_BLOCKS_FETCHED_FIELD_NUMBER- See Also:
-
REMOTE_REQS_DURATION_FIELD_NUMBER
public static final int REMOTE_REQS_DURATION_FIELD_NUMBER- See Also:
-
SHUFFLE_PUSH_READ_METRICS_DIST_FIELD_NUMBER
public static final int SHUFFLE_PUSH_READ_METRICS_DIST_FIELD_NUMBER- See Also:
-
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
getReadBytesList
repeated double read_bytes = 1;- Specified by:
getReadBytesListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the readBytes.
-
getReadBytesCount
public int getReadBytesCount()repeated double read_bytes = 1;- Specified by:
getReadBytesCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of readBytes.
-
getReadBytes
public double getReadBytes(int index) repeated double read_bytes = 1;- Specified by:
getReadBytesin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The readBytes at the given index.
-
getReadRecordsList
repeated double read_records = 2;- Specified by:
getReadRecordsListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the readRecords.
-
getReadRecordsCount
public int getReadRecordsCount()repeated double read_records = 2;- Specified by:
getReadRecordsCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of readRecords.
-
getReadRecords
public double getReadRecords(int index) repeated double read_records = 2;- Specified by:
getReadRecordsin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The readRecords at the given index.
-
getRemoteBlocksFetchedList
repeated double remote_blocks_fetched = 3;- Specified by:
getRemoteBlocksFetchedListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the remoteBlocksFetched.
-
getRemoteBlocksFetchedCount
public int getRemoteBlocksFetchedCount()repeated double remote_blocks_fetched = 3;- Specified by:
getRemoteBlocksFetchedCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of remoteBlocksFetched.
-
getRemoteBlocksFetched
public double getRemoteBlocksFetched(int index) repeated double remote_blocks_fetched = 3;- Specified by:
getRemoteBlocksFetchedin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The remoteBlocksFetched at the given index.
-
getLocalBlocksFetchedList
repeated double local_blocks_fetched = 4;- Specified by:
getLocalBlocksFetchedListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the localBlocksFetched.
-
getLocalBlocksFetchedCount
public int getLocalBlocksFetchedCount()repeated double local_blocks_fetched = 4;- Specified by:
getLocalBlocksFetchedCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of localBlocksFetched.
-
getLocalBlocksFetched
public double getLocalBlocksFetched(int index) repeated double local_blocks_fetched = 4;- Specified by:
getLocalBlocksFetchedin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The localBlocksFetched at the given index.
-
getFetchWaitTimeList
repeated double fetch_wait_time = 5;- Specified by:
getFetchWaitTimeListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the fetchWaitTime.
-
getFetchWaitTimeCount
public int getFetchWaitTimeCount()repeated double fetch_wait_time = 5;- Specified by:
getFetchWaitTimeCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of fetchWaitTime.
-
getFetchWaitTime
public double getFetchWaitTime(int index) repeated double fetch_wait_time = 5;- Specified by:
getFetchWaitTimein interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The fetchWaitTime at the given index.
-
getRemoteBytesReadList
repeated double remote_bytes_read = 6;- Specified by:
getRemoteBytesReadListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the remoteBytesRead.
-
getRemoteBytesReadCount
public int getRemoteBytesReadCount()repeated double remote_bytes_read = 6;- Specified by:
getRemoteBytesReadCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of remoteBytesRead.
-
getRemoteBytesRead
public double getRemoteBytesRead(int index) repeated double remote_bytes_read = 6;- Specified by:
getRemoteBytesReadin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The remoteBytesRead at the given index.
-
getRemoteBytesReadToDiskList
repeated double remote_bytes_read_to_disk = 7;- Specified by:
getRemoteBytesReadToDiskListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the remoteBytesReadToDisk.
-
getRemoteBytesReadToDiskCount
public int getRemoteBytesReadToDiskCount()repeated double remote_bytes_read_to_disk = 7;- Specified by:
getRemoteBytesReadToDiskCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of remoteBytesReadToDisk.
-
getRemoteBytesReadToDisk
public double getRemoteBytesReadToDisk(int index) repeated double remote_bytes_read_to_disk = 7;- Specified by:
getRemoteBytesReadToDiskin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The remoteBytesReadToDisk at the given index.
-
getTotalBlocksFetchedList
repeated double total_blocks_fetched = 8;- Specified by:
getTotalBlocksFetchedListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the totalBlocksFetched.
-
getTotalBlocksFetchedCount
public int getTotalBlocksFetchedCount()repeated double total_blocks_fetched = 8;- Specified by:
getTotalBlocksFetchedCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of totalBlocksFetched.
-
getTotalBlocksFetched
public double getTotalBlocksFetched(int index) repeated double total_blocks_fetched = 8;- Specified by:
getTotalBlocksFetchedin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The totalBlocksFetched at the given index.
-
getRemoteReqsDurationList
repeated double remote_reqs_duration = 9;- Specified by:
getRemoteReqsDurationListin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- A list containing the remoteReqsDuration.
-
getRemoteReqsDurationCount
public int getRemoteReqsDurationCount()repeated double remote_reqs_duration = 9;- Specified by:
getRemoteReqsDurationCountin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The count of remoteReqsDuration.
-
getRemoteReqsDuration
public double getRemoteReqsDuration(int index) repeated double remote_reqs_duration = 9;- Specified by:
getRemoteReqsDurationin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Parameters:
index- The index of the element to return.- Returns:
- The remoteReqsDuration at the given index.
-
hasShufflePushReadMetricsDist
public boolean hasShufflePushReadMetricsDist().org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;- Specified by:
hasShufflePushReadMetricsDistin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- Whether the shufflePushReadMetricsDist field is set.
-
getShufflePushReadMetricsDist
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;- Specified by:
getShufflePushReadMetricsDistin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder- Returns:
- The shufflePushReadMetricsDist.
-
getShufflePushReadMetricsDistOrBuilder
public StoreTypes.ShufflePushReadMetricDistributionsOrBuilder getShufflePushReadMetricsDistOrBuilder().org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;- Specified by:
getShufflePushReadMetricsDistOrBuilderin interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage
-
writeTo
- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessage- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessage
-
equals
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(InputStream input) throws IOException - Throws:
IOException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseDelimitedFrom
public static StoreTypes.ShuffleReadMetricDistributions parseDelimitedFrom(InputStream input) throws IOException - Throws:
IOException
-
parseDelimitedFrom
public static StoreTypes.ShuffleReadMetricDistributions parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.CodedInputStream input) throws IOException - Throws:
IOException
-
parseFrom
public static StoreTypes.ShuffleReadMetricDistributions parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
newBuilderForType
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
public static StoreTypes.ShuffleReadMetricDistributions.Builder newBuilder(StoreTypes.ShuffleReadMetricDistributions prototype) -
toBuilder
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessage
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-