Package org.apache.spark.status.protobuf

Class StoreTypes.ShuffleReadMetricDistributions.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ShuffleReadMetricDistributions.Builder>

org.apache.spark.status.protobuf.StoreTypes.ShuffleReadMetricDistributions.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Enclosing class:

StoreTypes.ShuffleReadMetricDistributions

public static final class StoreTypes.ShuffleReadMetricDistributions.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ShuffleReadMetricDistributions.Builder>
implements StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Protobuf type org.apache.spark.status.protobuf.ShuffleReadMetricDistributions

Method Summary

Modifier and Type	Method	Description
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllFetchWaitTime(Iterable<? extends Double> values)	repeated double fetch_wait_time = 5;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllLocalBlocksFetched(Iterable<? extends Double> values)	repeated double local_blocks_fetched = 4;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllReadBytes(Iterable<? extends Double> values)	repeated double read_bytes = 1;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllReadRecords(Iterable<? extends Double> values)	repeated double read_records = 2;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllRemoteBlocksFetched(Iterable<? extends Double> values)	repeated double remote_blocks_fetched = 3;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllRemoteBytesRead(Iterable<? extends Double> values)	repeated double remote_bytes_read = 6;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllRemoteBytesReadToDisk(Iterable<? extends Double> values)	repeated double remote_bytes_read_to_disk = 7;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllRemoteReqsDuration(Iterable<? extends Double> values)	repeated double remote_reqs_duration = 9;
StoreTypes.ShuffleReadMetricDistributions.Builder	addAllTotalBlocksFetched(Iterable<? extends Double> values)	repeated double total_blocks_fetched = 8;
StoreTypes.ShuffleReadMetricDistributions.Builder	addFetchWaitTime(double value)	repeated double fetch_wait_time = 5;
StoreTypes.ShuffleReadMetricDistributions.Builder	addLocalBlocksFetched(double value)	repeated double local_blocks_fetched = 4;
StoreTypes.ShuffleReadMetricDistributions.Builder	addReadBytes(double value)	repeated double read_bytes = 1;
StoreTypes.ShuffleReadMetricDistributions.Builder	addReadRecords(double value)	repeated double read_records = 2;
StoreTypes.ShuffleReadMetricDistributions.Builder	addRemoteBlocksFetched(double value)	repeated double remote_blocks_fetched = 3;
StoreTypes.ShuffleReadMetricDistributions.Builder	addRemoteBytesRead(double value)	repeated double remote_bytes_read = 6;
StoreTypes.ShuffleReadMetricDistributions.Builder	addRemoteBytesReadToDisk(double value)	repeated double remote_bytes_read_to_disk = 7;
StoreTypes.ShuffleReadMetricDistributions.Builder	addRemoteReqsDuration(double value)	repeated double remote_reqs_duration = 9;
StoreTypes.ShuffleReadMetricDistributions.Builder	addTotalBlocksFetched(double value)	repeated double total_blocks_fetched = 8;
StoreTypes.ShuffleReadMetricDistributions	build()
StoreTypes.ShuffleReadMetricDistributions	buildPartial()
StoreTypes.ShuffleReadMetricDistributions.Builder	clear()
StoreTypes.ShuffleReadMetricDistributions.Builder	clearFetchWaitTime()	repeated double fetch_wait_time = 5;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearLocalBlocksFetched()	repeated double local_blocks_fetched = 4;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearReadBytes()	repeated double read_bytes = 1;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearReadRecords()	repeated double read_records = 2;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearRemoteBlocksFetched()	repeated double remote_blocks_fetched = 3;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearRemoteBytesRead()	repeated double remote_bytes_read = 6;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearRemoteBytesReadToDisk()	repeated double remote_bytes_read_to_disk = 7;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearRemoteReqsDuration()	repeated double remote_reqs_duration = 9;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearShufflePushReadMetricsDist()	.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
StoreTypes.ShuffleReadMetricDistributions.Builder	clearTotalBlocksFetched()	repeated double total_blocks_fetched = 8;
StoreTypes.ShuffleReadMetricDistributions	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
double	getFetchWaitTime(int index)	repeated double fetch_wait_time = 5;
int	getFetchWaitTimeCount()	repeated double fetch_wait_time = 5;
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;
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;
List<Double>	getReadBytesList()	repeated double read_bytes = 1;
double	getReadRecords(int index)	repeated double read_records = 2;
int	getReadRecordsCount()	repeated double read_records = 2;
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;
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;
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;
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;
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.ShufflePushReadMetricDistributions.Builder	getShufflePushReadMetricsDistBuilder()	.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;
List<Double>	getTotalBlocksFetchedList()	repeated double total_blocks_fetched = 8;
boolean	hasShufflePushReadMetricsDist()	.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
final boolean	isInitialized()
StoreTypes.ShuffleReadMetricDistributions.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.ShuffleReadMetricDistributions.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.ShuffleReadMetricDistributions.Builder	mergeFrom(StoreTypes.ShuffleReadMetricDistributions other)
StoreTypes.ShuffleReadMetricDistributions.Builder	mergeShufflePushReadMetricsDist(StoreTypes.ShufflePushReadMetricDistributions value)	.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
StoreTypes.ShuffleReadMetricDistributions.Builder	setFetchWaitTime(int index, double value)	repeated double fetch_wait_time = 5;
StoreTypes.ShuffleReadMetricDistributions.Builder	setLocalBlocksFetched(int index, double value)	repeated double local_blocks_fetched = 4;
StoreTypes.ShuffleReadMetricDistributions.Builder	setReadBytes(int index, double value)	repeated double read_bytes = 1;
StoreTypes.ShuffleReadMetricDistributions.Builder	setReadRecords(int index, double value)	repeated double read_records = 2;
StoreTypes.ShuffleReadMetricDistributions.Builder	setRemoteBlocksFetched(int index, double value)	repeated double remote_blocks_fetched = 3;
StoreTypes.ShuffleReadMetricDistributions.Builder	setRemoteBytesRead(int index, double value)	repeated double remote_bytes_read = 6;
StoreTypes.ShuffleReadMetricDistributions.Builder	setRemoteBytesReadToDisk(int index, double value)	repeated double remote_bytes_read_to_disk = 7;
StoreTypes.ShuffleReadMetricDistributions.Builder	setRemoteReqsDuration(int index, double value)	repeated double remote_reqs_duration = 9;
StoreTypes.ShuffleReadMetricDistributions.Builder	setShufflePushReadMetricsDist(StoreTypes.ShufflePushReadMetricDistributions value)	.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
StoreTypes.ShuffleReadMetricDistributions.Builder	setShufflePushReadMetricsDist(StoreTypes.ShufflePushReadMetricDistributions.Builder builderForValue)	.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;
StoreTypes.ShuffleReadMetricDistributions.Builder	setTotalBlocksFetched(int index, double value)	repeated double total_blocks_fetched = 8;

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, mergeUnknownFields, newBuilderForField, setField, setRepeatedField, setUnknownFields

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.Message.Builder

mergeDelimitedFrom, mergeDelimitedFrom

Methods inherited from interface com.google.protobuf.MessageLite.Builder

mergeFrom

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Method Details

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

clear

public StoreTypes.ShuffleReadMetricDistributions.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ShuffleReadMetricDistributions.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ShuffleReadMetricDistributions.Builder>

getDefaultInstanceForType

public StoreTypes.ShuffleReadMetricDistributions getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.ShuffleReadMetricDistributions build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public StoreTypes.ShuffleReadMetricDistributions buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public StoreTypes.ShuffleReadMetricDistributions.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.ShuffleReadMetricDistributions.Builder>

mergeFrom

public StoreTypes.ShuffleReadMetricDistributions.Builder mergeFrom(StoreTypes.ShuffleReadMetricDistributions other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ShuffleReadMetricDistributions.Builder>

mergeFrom

public StoreTypes.ShuffleReadMetricDistributions.Builder mergeFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                            throws IOException

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.ShuffleReadMetricDistributions.Builder>

Throws:

IOException

getReadBytesList

public List<Double> getReadBytesList()

repeated double read_bytes = 1;

Specified by:

getReadBytesList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the readBytes.

getReadBytesCount

public int getReadBytesCount()

repeated double read_bytes = 1;

Specified by:

getReadBytesCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of readBytes.

getReadBytes

public double getReadBytes(int index)

repeated double read_bytes = 1;

Specified by:

getReadBytes in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The readBytes at the given index.

setReadBytes

public StoreTypes.ShuffleReadMetricDistributions.Builder setReadBytes(int index,
 double value)

repeated double read_bytes = 1;

Parameters:

index - The index to set the value at.

value - The readBytes to set.

Returns:

This builder for chaining.

addReadBytes

public StoreTypes.ShuffleReadMetricDistributions.Builder addReadBytes(double value)

repeated double read_bytes = 1;

Parameters:

value - The readBytes to add.

Returns:

This builder for chaining.

addAllReadBytes

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllReadBytes(Iterable<? extends Double> values)

repeated double read_bytes = 1;

Parameters:

values - The readBytes to add.

Returns:

This builder for chaining.

clearReadBytes

public StoreTypes.ShuffleReadMetricDistributions.Builder clearReadBytes()

repeated double read_bytes = 1;

Returns:

This builder for chaining.

getReadRecordsList

public List<Double> getReadRecordsList()

repeated double read_records = 2;

Specified by:

getReadRecordsList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the readRecords.

getReadRecordsCount

public int getReadRecordsCount()

repeated double read_records = 2;

Specified by:

getReadRecordsCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of readRecords.

getReadRecords

public double getReadRecords(int index)

repeated double read_records = 2;

Specified by:

getReadRecords in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The readRecords at the given index.

setReadRecords

public StoreTypes.ShuffleReadMetricDistributions.Builder setReadRecords(int index,
 double value)

repeated double read_records = 2;

Parameters:

index - The index to set the value at.

value - The readRecords to set.

Returns:

This builder for chaining.

addReadRecords

public StoreTypes.ShuffleReadMetricDistributions.Builder addReadRecords(double value)

repeated double read_records = 2;

Parameters:

value - The readRecords to add.

Returns:

This builder for chaining.

addAllReadRecords

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllReadRecords(Iterable<? extends Double> values)

repeated double read_records = 2;

Parameters:

values - The readRecords to add.

Returns:

This builder for chaining.

clearReadRecords

public StoreTypes.ShuffleReadMetricDistributions.Builder clearReadRecords()

repeated double read_records = 2;

Returns:

This builder for chaining.

getRemoteBlocksFetchedList

public List<Double> getRemoteBlocksFetchedList()

repeated double remote_blocks_fetched = 3;

Specified by:

getRemoteBlocksFetchedList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the remoteBlocksFetched.

getRemoteBlocksFetchedCount

public int getRemoteBlocksFetchedCount()

repeated double remote_blocks_fetched = 3;

Specified by:

getRemoteBlocksFetchedCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of remoteBlocksFetched.

getRemoteBlocksFetched

public double getRemoteBlocksFetched(int index)

repeated double remote_blocks_fetched = 3;

Specified by:

getRemoteBlocksFetched in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The remoteBlocksFetched at the given index.

setRemoteBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder setRemoteBlocksFetched(int index,
 double value)

repeated double remote_blocks_fetched = 3;

Parameters:

index - The index to set the value at.

value - The remoteBlocksFetched to set.

Returns:

This builder for chaining.

addRemoteBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder addRemoteBlocksFetched(double value)

repeated double remote_blocks_fetched = 3;

Parameters:

value - The remoteBlocksFetched to add.

Returns:

This builder for chaining.

addAllRemoteBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllRemoteBlocksFetched(Iterable<? extends Double> values)

repeated double remote_blocks_fetched = 3;

Parameters:

values - The remoteBlocksFetched to add.

Returns:

This builder for chaining.

clearRemoteBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder clearRemoteBlocksFetched()

repeated double remote_blocks_fetched = 3;

Returns:

This builder for chaining.

getLocalBlocksFetchedList

public List<Double> getLocalBlocksFetchedList()

repeated double local_blocks_fetched = 4;

Specified by:

getLocalBlocksFetchedList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the localBlocksFetched.

getLocalBlocksFetchedCount

public int getLocalBlocksFetchedCount()

repeated double local_blocks_fetched = 4;

Specified by:

getLocalBlocksFetchedCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of localBlocksFetched.

getLocalBlocksFetched

public double getLocalBlocksFetched(int index)

repeated double local_blocks_fetched = 4;

Specified by:

getLocalBlocksFetched in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The localBlocksFetched at the given index.

setLocalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder setLocalBlocksFetched(int index,
 double value)

repeated double local_blocks_fetched = 4;

Parameters:

index - The index to set the value at.

value - The localBlocksFetched to set.

Returns:

This builder for chaining.

addLocalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder addLocalBlocksFetched(double value)

repeated double local_blocks_fetched = 4;

Parameters:

value - The localBlocksFetched to add.

Returns:

This builder for chaining.

addAllLocalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllLocalBlocksFetched(Iterable<? extends Double> values)

repeated double local_blocks_fetched = 4;

Parameters:

values - The localBlocksFetched to add.

Returns:

This builder for chaining.

clearLocalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder clearLocalBlocksFetched()

repeated double local_blocks_fetched = 4;

Returns:

This builder for chaining.

getFetchWaitTimeList

public List<Double> getFetchWaitTimeList()

repeated double fetch_wait_time = 5;

Specified by:

getFetchWaitTimeList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the fetchWaitTime.

getFetchWaitTimeCount

public int getFetchWaitTimeCount()

repeated double fetch_wait_time = 5;

Specified by:

getFetchWaitTimeCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of fetchWaitTime.

getFetchWaitTime

public double getFetchWaitTime(int index)

repeated double fetch_wait_time = 5;

Specified by:

getFetchWaitTime in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The fetchWaitTime at the given index.

setFetchWaitTime

public StoreTypes.ShuffleReadMetricDistributions.Builder setFetchWaitTime(int index,
 double value)

repeated double fetch_wait_time = 5;

Parameters:

index - The index to set the value at.

value - The fetchWaitTime to set.

Returns:

This builder for chaining.

addFetchWaitTime

public StoreTypes.ShuffleReadMetricDistributions.Builder addFetchWaitTime(double value)

repeated double fetch_wait_time = 5;

Parameters:

value - The fetchWaitTime to add.

Returns:

This builder for chaining.

addAllFetchWaitTime

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllFetchWaitTime(Iterable<? extends Double> values)

repeated double fetch_wait_time = 5;

Parameters:

values - The fetchWaitTime to add.

Returns:

This builder for chaining.

clearFetchWaitTime

public StoreTypes.ShuffleReadMetricDistributions.Builder clearFetchWaitTime()

repeated double fetch_wait_time = 5;

Returns:

This builder for chaining.

getRemoteBytesReadList

public List<Double> getRemoteBytesReadList()

repeated double remote_bytes_read = 6;

Specified by:

getRemoteBytesReadList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the remoteBytesRead.

getRemoteBytesReadCount

public int getRemoteBytesReadCount()

repeated double remote_bytes_read = 6;

Specified by:

getRemoteBytesReadCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of remoteBytesRead.

getRemoteBytesRead

public double getRemoteBytesRead(int index)

repeated double remote_bytes_read = 6;

Specified by:

getRemoteBytesRead in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The remoteBytesRead at the given index.

setRemoteBytesRead

public StoreTypes.ShuffleReadMetricDistributions.Builder setRemoteBytesRead(int index,
 double value)

repeated double remote_bytes_read = 6;

Parameters:

index - The index to set the value at.

value - The remoteBytesRead to set.

Returns:

This builder for chaining.

addRemoteBytesRead

public StoreTypes.ShuffleReadMetricDistributions.Builder addRemoteBytesRead(double value)

repeated double remote_bytes_read = 6;

Parameters:

value - The remoteBytesRead to add.

Returns:

This builder for chaining.

addAllRemoteBytesRead

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllRemoteBytesRead(Iterable<? extends Double> values)

repeated double remote_bytes_read = 6;

Parameters:

values - The remoteBytesRead to add.

Returns:

This builder for chaining.

clearRemoteBytesRead

public StoreTypes.ShuffleReadMetricDistributions.Builder clearRemoteBytesRead()

repeated double remote_bytes_read = 6;

Returns:

This builder for chaining.

getRemoteBytesReadToDiskList

public List<Double> getRemoteBytesReadToDiskList()

repeated double remote_bytes_read_to_disk = 7;

Specified by:

getRemoteBytesReadToDiskList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the remoteBytesReadToDisk.

getRemoteBytesReadToDiskCount

public int getRemoteBytesReadToDiskCount()

repeated double remote_bytes_read_to_disk = 7;

Specified by:

getRemoteBytesReadToDiskCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of remoteBytesReadToDisk.

getRemoteBytesReadToDisk

public double getRemoteBytesReadToDisk(int index)

repeated double remote_bytes_read_to_disk = 7;

Specified by:

getRemoteBytesReadToDisk in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The remoteBytesReadToDisk at the given index.

setRemoteBytesReadToDisk

public StoreTypes.ShuffleReadMetricDistributions.Builder setRemoteBytesReadToDisk(int index,
 double value)

repeated double remote_bytes_read_to_disk = 7;

Parameters:

index - The index to set the value at.

value - The remoteBytesReadToDisk to set.

Returns:

This builder for chaining.

addRemoteBytesReadToDisk

public StoreTypes.ShuffleReadMetricDistributions.Builder addRemoteBytesReadToDisk(double value)

repeated double remote_bytes_read_to_disk = 7;

Parameters:

value - The remoteBytesReadToDisk to add.

Returns:

This builder for chaining.

addAllRemoteBytesReadToDisk

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllRemoteBytesReadToDisk(Iterable<? extends Double> values)

repeated double remote_bytes_read_to_disk = 7;

Parameters:

values - The remoteBytesReadToDisk to add.

Returns:

This builder for chaining.

clearRemoteBytesReadToDisk

public StoreTypes.ShuffleReadMetricDistributions.Builder clearRemoteBytesReadToDisk()

repeated double remote_bytes_read_to_disk = 7;

Returns:

This builder for chaining.

getTotalBlocksFetchedList

public List<Double> getTotalBlocksFetchedList()

repeated double total_blocks_fetched = 8;

Specified by:

getTotalBlocksFetchedList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the totalBlocksFetched.

getTotalBlocksFetchedCount

public int getTotalBlocksFetchedCount()

repeated double total_blocks_fetched = 8;

Specified by:

getTotalBlocksFetchedCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of totalBlocksFetched.

getTotalBlocksFetched

public double getTotalBlocksFetched(int index)

repeated double total_blocks_fetched = 8;

Specified by:

getTotalBlocksFetched in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The totalBlocksFetched at the given index.

setTotalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder setTotalBlocksFetched(int index,
 double value)

repeated double total_blocks_fetched = 8;

Parameters:

index - The index to set the value at.

value - The totalBlocksFetched to set.

Returns:

This builder for chaining.

addTotalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder addTotalBlocksFetched(double value)

repeated double total_blocks_fetched = 8;

Parameters:

value - The totalBlocksFetched to add.

Returns:

This builder for chaining.

addAllTotalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllTotalBlocksFetched(Iterable<? extends Double> values)

repeated double total_blocks_fetched = 8;

Parameters:

values - The totalBlocksFetched to add.

Returns:

This builder for chaining.

clearTotalBlocksFetched

public StoreTypes.ShuffleReadMetricDistributions.Builder clearTotalBlocksFetched()

repeated double total_blocks_fetched = 8;

Returns:

This builder for chaining.

getRemoteReqsDurationList

public List<Double> getRemoteReqsDurationList()

repeated double remote_reqs_duration = 9;

Specified by:

getRemoteReqsDurationList in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

A list containing the remoteReqsDuration.

getRemoteReqsDurationCount

public int getRemoteReqsDurationCount()

repeated double remote_reqs_duration = 9;

Specified by:

getRemoteReqsDurationCount in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The count of remoteReqsDuration.

getRemoteReqsDuration

public double getRemoteReqsDuration(int index)

repeated double remote_reqs_duration = 9;

Specified by:

getRemoteReqsDuration in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The remoteReqsDuration at the given index.

setRemoteReqsDuration

public StoreTypes.ShuffleReadMetricDistributions.Builder setRemoteReqsDuration(int index,
 double value)

repeated double remote_reqs_duration = 9;

Parameters:

index - The index to set the value at.

value - The remoteReqsDuration to set.

Returns:

This builder for chaining.

addRemoteReqsDuration

public StoreTypes.ShuffleReadMetricDistributions.Builder addRemoteReqsDuration(double value)

repeated double remote_reqs_duration = 9;

Parameters:

value - The remoteReqsDuration to add.

Returns:

This builder for chaining.

addAllRemoteReqsDuration

public StoreTypes.ShuffleReadMetricDistributions.Builder addAllRemoteReqsDuration(Iterable<? extends Double> values)

repeated double remote_reqs_duration = 9;

Parameters:

values - The remoteReqsDuration to add.

Returns:

This builder for chaining.

clearRemoteReqsDuration

public StoreTypes.ShuffleReadMetricDistributions.Builder clearRemoteReqsDuration()

repeated double remote_reqs_duration = 9;

Returns:

This builder for chaining.

hasShufflePushReadMetricsDist

public boolean hasShufflePushReadMetricsDist()

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

Specified by:

hasShufflePushReadMetricsDist in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

Whether the shufflePushReadMetricsDist field is set.

getShufflePushReadMetricsDist

public StoreTypes.ShufflePushReadMetricDistributions getShufflePushReadMetricsDist()

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

Specified by:

getShufflePushReadMetricsDist in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder

Returns:

The shufflePushReadMetricsDist.

setShufflePushReadMetricsDist

public StoreTypes.ShuffleReadMetricDistributions.Builder setShufflePushReadMetricsDist(StoreTypes.ShufflePushReadMetricDistributions value)

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

setShufflePushReadMetricsDist

public StoreTypes.ShuffleReadMetricDistributions.Builder setShufflePushReadMetricsDist(StoreTypes.ShufflePushReadMetricDistributions.Builder builderForValue)

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

mergeShufflePushReadMetricsDist

public StoreTypes.ShuffleReadMetricDistributions.Builder mergeShufflePushReadMetricsDist(StoreTypes.ShufflePushReadMetricDistributions value)

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

clearShufflePushReadMetricsDist

public StoreTypes.ShuffleReadMetricDistributions.Builder clearShufflePushReadMetricsDist()

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

getShufflePushReadMetricsDistBuilder

public StoreTypes.ShufflePushReadMetricDistributions.Builder getShufflePushReadMetricsDistBuilder()

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

getShufflePushReadMetricsDistOrBuilder

public StoreTypes.ShufflePushReadMetricDistributionsOrBuilder getShufflePushReadMetricsDistOrBuilder()

.org.apache.spark.status.protobuf.ShufflePushReadMetricDistributions shuffle_push_read_metrics_dist = 10;

Specified by:

getShufflePushReadMetricsDistOrBuilder in interface StoreTypes.ShuffleReadMetricDistributionsOrBuilder