Package org.apache.spark.status.protobuf
Class StoreTypes.ShuffleReadMetricDistributions
Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessageV3
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.GeneratedMessageV3
implements StoreTypes.ShuffleReadMetricDistributionsOrBuilder
Protobuf type
org.apache.spark.status.protobuf.ShuffleReadMetricDistributions
- See Also:
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic final class
Protobuf typeorg.apache.spark.status.protobuf.ShuffleReadMetricDistributions
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
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 -
Field Summary
Modifier and TypeFieldDescriptionstatic final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
-
Method Summary
Modifier and TypeMethodDescriptionboolean
static final com.google.protobuf.Descriptors.Descriptor
double
getFetchWaitTime
(int index) repeated double fetch_wait_time = 5;
int
repeated double fetch_wait_time = 5;
repeated double fetch_wait_time = 5;
double
getLocalBlocksFetched
(int index) repeated double local_blocks_fetched = 4;
int
repeated double local_blocks_fetched = 4;
repeated double local_blocks_fetched = 4;
com.google.protobuf.Parser<StoreTypes.ShuffleReadMetricDistributions>
double
getReadBytes
(int index) repeated double read_bytes = 1;
int
repeated double read_bytes = 1;
repeated double read_bytes = 1;
double
getReadRecords
(int index) repeated double read_records = 2;
int
repeated double read_records = 2;
repeated double read_records = 2;
double
getRemoteBlocksFetched
(int index) repeated double remote_blocks_fetched = 3;
int
repeated double remote_blocks_fetched = 3;
repeated double remote_blocks_fetched = 3;
double
getRemoteBytesRead
(int index) repeated double remote_bytes_read = 6;
int
repeated double remote_bytes_read = 6;
repeated double remote_bytes_read = 6;
double
getRemoteBytesReadToDisk
(int index) repeated double remote_bytes_read_to_disk = 7;
int
repeated double remote_bytes_read_to_disk = 7;
repeated double remote_bytes_read_to_disk = 7;
double
getRemoteReqsDuration
(int index) repeated double remote_reqs_duration = 9;
int
repeated 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;
double
getTotalBlocksFetched
(int index) repeated double total_blocks_fetched = 8;
int
repeated double total_blocks_fetched = 8;
repeated double total_blocks_fetched = 8;
int
hashCode()
boolean
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
final boolean
parseDelimitedFrom
(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()
void
writeTo
(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessageV3
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, toString
Methods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo
Methods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo
Methods 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:
getReadBytesList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the readBytes.
-
getReadBytesCount
public int getReadBytesCount()repeated double read_bytes = 1;
- Specified by:
getReadBytesCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of readBytes.
-
getReadBytes
public double getReadBytes(int index) repeated double read_bytes = 1;
- Specified by:
getReadBytes
in 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:
getReadRecordsList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the readRecords.
-
getReadRecordsCount
public int getReadRecordsCount()repeated double read_records = 2;
- Specified by:
getReadRecordsCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of readRecords.
-
getReadRecords
public double getReadRecords(int index) repeated double read_records = 2;
- Specified by:
getReadRecords
in 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:
getRemoteBlocksFetchedList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the remoteBlocksFetched.
-
getRemoteBlocksFetchedCount
public int getRemoteBlocksFetchedCount()repeated double remote_blocks_fetched = 3;
- Specified by:
getRemoteBlocksFetchedCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of remoteBlocksFetched.
-
getRemoteBlocksFetched
public double getRemoteBlocksFetched(int index) repeated double remote_blocks_fetched = 3;
- Specified by:
getRemoteBlocksFetched
in 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:
getLocalBlocksFetchedList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the localBlocksFetched.
-
getLocalBlocksFetchedCount
public int getLocalBlocksFetchedCount()repeated double local_blocks_fetched = 4;
- Specified by:
getLocalBlocksFetchedCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of localBlocksFetched.
-
getLocalBlocksFetched
public double getLocalBlocksFetched(int index) repeated double local_blocks_fetched = 4;
- Specified by:
getLocalBlocksFetched
in 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:
getFetchWaitTimeList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the fetchWaitTime.
-
getFetchWaitTimeCount
public int getFetchWaitTimeCount()repeated double fetch_wait_time = 5;
- Specified by:
getFetchWaitTimeCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of fetchWaitTime.
-
getFetchWaitTime
public double getFetchWaitTime(int index) repeated double fetch_wait_time = 5;
- Specified by:
getFetchWaitTime
in 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:
getRemoteBytesReadList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the remoteBytesRead.
-
getRemoteBytesReadCount
public int getRemoteBytesReadCount()repeated double remote_bytes_read = 6;
- Specified by:
getRemoteBytesReadCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of remoteBytesRead.
-
getRemoteBytesRead
public double getRemoteBytesRead(int index) repeated double remote_bytes_read = 6;
- Specified by:
getRemoteBytesRead
in 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:
getRemoteBytesReadToDiskList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the remoteBytesReadToDisk.
-
getRemoteBytesReadToDiskCount
public int getRemoteBytesReadToDiskCount()repeated double remote_bytes_read_to_disk = 7;
- Specified by:
getRemoteBytesReadToDiskCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of remoteBytesReadToDisk.
-
getRemoteBytesReadToDisk
public double getRemoteBytesReadToDisk(int index) repeated double remote_bytes_read_to_disk = 7;
- Specified by:
getRemoteBytesReadToDisk
in 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:
getTotalBlocksFetchedList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the totalBlocksFetched.
-
getTotalBlocksFetchedCount
public int getTotalBlocksFetchedCount()repeated double total_blocks_fetched = 8;
- Specified by:
getTotalBlocksFetchedCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of totalBlocksFetched.
-
getTotalBlocksFetched
public double getTotalBlocksFetched(int index) repeated double total_blocks_fetched = 8;
- Specified by:
getTotalBlocksFetched
in 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:
getRemoteReqsDurationList
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- A list containing the remoteReqsDuration.
-
getRemoteReqsDurationCount
public int getRemoteReqsDurationCount()repeated double remote_reqs_duration = 9;
- Specified by:
getRemoteReqsDurationCount
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The count of remoteReqsDuration.
-
getRemoteReqsDuration
public double getRemoteReqsDuration(int index) repeated double remote_reqs_duration = 9;
- Specified by:
getRemoteReqsDuration
in 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:
hasShufflePushReadMetricsDist
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- Whether the shufflePushReadMetricsDist field is set.
-
getShufflePushReadMetricsDist
.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
- Specified by:
getShufflePushReadMetricsDist
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
- Returns:
- The shufflePushReadMetricsDist.
-
getShufflePushReadMetricsDistOrBuilder
public StoreTypes.ShufflePushReadMetricDistributionsOrBuilder getShufflePushReadMetricsDistOrBuilder().org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
- Specified by:
getShufflePushReadMetricsDistOrBuilder
in interfaceStoreTypes.ShuffleReadMetricDistributionsOrBuilder
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in 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:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
public static StoreTypes.ShuffleReadMetricDistributions.Builder newBuilder(StoreTypes.ShuffleReadMetricDistributions prototype) -
toBuilder
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-