Package org.apache.spark.status.protobuf

Class StoreTypes.ExecutorMetricsDistributions.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

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

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

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

All Implemented Interfaces:

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

Enclosing class:

StoreTypes.ExecutorMetricsDistributions

public static final class StoreTypes.ExecutorMetricsDistributions.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ExecutorMetricsDistributions.Builder>
implements StoreTypes.ExecutorMetricsDistributionsOrBuilder

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

Method Summary

Modifier and Type	Method	Description
StoreTypes.ExecutorMetricsDistributions.Builder	addAllDiskBytesSpilled(Iterable<? extends Double> values)	repeated double disk_bytes_spilled = 15;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllFailedTasks(Iterable<? extends Double> values)	repeated double failed_tasks = 3;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllInputBytes(Iterable<? extends Double> values)	repeated double input_bytes = 6;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllInputRecords(Iterable<? extends Double> values)	repeated double input_records = 7;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllKilledTasks(Iterable<? extends Double> values)	repeated double killed_tasks = 5;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllMemoryBytesSpilled(Iterable<? extends Double> values)	repeated double memory_bytes_spilled = 14;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllOutputBytes(Iterable<? extends Double> values)	repeated double output_bytes = 8;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllOutputRecords(Iterable<? extends Double> values)	repeated double output_records = 9;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllQuantiles(Iterable<? extends Double> values)	repeated double quantiles = 1;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllShuffleRead(Iterable<? extends Double> values)	repeated double shuffle_read = 10;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllShuffleReadRecords(Iterable<? extends Double> values)	repeated double shuffle_read_records = 11;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllShuffleWrite(Iterable<? extends Double> values)	repeated double shuffle_write = 12;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllShuffleWriteRecords(Iterable<? extends Double> values)	repeated double shuffle_write_records = 13;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllSucceededTasks(Iterable<? extends Double> values)	repeated double succeeded_tasks = 4;
StoreTypes.ExecutorMetricsDistributions.Builder	addAllTaskTime(Iterable<? extends Double> values)	repeated double task_time = 2;
StoreTypes.ExecutorMetricsDistributions.Builder	addDiskBytesSpilled(double value)	repeated double disk_bytes_spilled = 15;
StoreTypes.ExecutorMetricsDistributions.Builder	addFailedTasks(double value)	repeated double failed_tasks = 3;
StoreTypes.ExecutorMetricsDistributions.Builder	addInputBytes(double value)	repeated double input_bytes = 6;
StoreTypes.ExecutorMetricsDistributions.Builder	addInputRecords(double value)	repeated double input_records = 7;
StoreTypes.ExecutorMetricsDistributions.Builder	addKilledTasks(double value)	repeated double killed_tasks = 5;
StoreTypes.ExecutorMetricsDistributions.Builder	addMemoryBytesSpilled(double value)	repeated double memory_bytes_spilled = 14;
StoreTypes.ExecutorMetricsDistributions.Builder	addOutputBytes(double value)	repeated double output_bytes = 8;
StoreTypes.ExecutorMetricsDistributions.Builder	addOutputRecords(double value)	repeated double output_records = 9;
StoreTypes.ExecutorMetricsDistributions.Builder	addQuantiles(double value)	repeated double quantiles = 1;
StoreTypes.ExecutorMetricsDistributions.Builder	addShuffleRead(double value)	repeated double shuffle_read = 10;
StoreTypes.ExecutorMetricsDistributions.Builder	addShuffleReadRecords(double value)	repeated double shuffle_read_records = 11;
StoreTypes.ExecutorMetricsDistributions.Builder	addShuffleWrite(double value)	repeated double shuffle_write = 12;
StoreTypes.ExecutorMetricsDistributions.Builder	addShuffleWriteRecords(double value)	repeated double shuffle_write_records = 13;
StoreTypes.ExecutorMetricsDistributions.Builder	addSucceededTasks(double value)	repeated double succeeded_tasks = 4;
StoreTypes.ExecutorMetricsDistributions.Builder	addTaskTime(double value)	repeated double task_time = 2;
StoreTypes.ExecutorMetricsDistributions	build()
StoreTypes.ExecutorMetricsDistributions	buildPartial()
StoreTypes.ExecutorMetricsDistributions.Builder	clear()
StoreTypes.ExecutorMetricsDistributions.Builder	clearDiskBytesSpilled()	repeated double disk_bytes_spilled = 15;
StoreTypes.ExecutorMetricsDistributions.Builder	clearFailedTasks()	repeated double failed_tasks = 3;
StoreTypes.ExecutorMetricsDistributions.Builder	clearInputBytes()	repeated double input_bytes = 6;
StoreTypes.ExecutorMetricsDistributions.Builder	clearInputRecords()	repeated double input_records = 7;
StoreTypes.ExecutorMetricsDistributions.Builder	clearKilledTasks()	repeated double killed_tasks = 5;
StoreTypes.ExecutorMetricsDistributions.Builder	clearMemoryBytesSpilled()	repeated double memory_bytes_spilled = 14;
StoreTypes.ExecutorMetricsDistributions.Builder	clearOutputBytes()	repeated double output_bytes = 8;
StoreTypes.ExecutorMetricsDistributions.Builder	clearOutputRecords()	repeated double output_records = 9;
StoreTypes.ExecutorMetricsDistributions.Builder	clearPeakMemoryMetrics()	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorMetricsDistributions.Builder	clearQuantiles()	repeated double quantiles = 1;
StoreTypes.ExecutorMetricsDistributions.Builder	clearShuffleRead()	repeated double shuffle_read = 10;
StoreTypes.ExecutorMetricsDistributions.Builder	clearShuffleReadRecords()	repeated double shuffle_read_records = 11;
StoreTypes.ExecutorMetricsDistributions.Builder	clearShuffleWrite()	repeated double shuffle_write = 12;
StoreTypes.ExecutorMetricsDistributions.Builder	clearShuffleWriteRecords()	repeated double shuffle_write_records = 13;
StoreTypes.ExecutorMetricsDistributions.Builder	clearSucceededTasks()	repeated double succeeded_tasks = 4;
StoreTypes.ExecutorMetricsDistributions.Builder	clearTaskTime()	repeated double task_time = 2;
StoreTypes.ExecutorMetricsDistributions	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
double	getDiskBytesSpilled(int index)	repeated double disk_bytes_spilled = 15;
int	getDiskBytesSpilledCount()	repeated double disk_bytes_spilled = 15;
List<Double>	getDiskBytesSpilledList()	repeated double disk_bytes_spilled = 15;
double	getFailedTasks(int index)	repeated double failed_tasks = 3;
int	getFailedTasksCount()	repeated double failed_tasks = 3;
List<Double>	getFailedTasksList()	repeated double failed_tasks = 3;
double	getInputBytes(int index)	repeated double input_bytes = 6;
int	getInputBytesCount()	repeated double input_bytes = 6;
List<Double>	getInputBytesList()	repeated double input_bytes = 6;
double	getInputRecords(int index)	repeated double input_records = 7;
int	getInputRecordsCount()	repeated double input_records = 7;
List<Double>	getInputRecordsList()	repeated double input_records = 7;
double	getKilledTasks(int index)	repeated double killed_tasks = 5;
int	getKilledTasksCount()	repeated double killed_tasks = 5;
List<Double>	getKilledTasksList()	repeated double killed_tasks = 5;
double	getMemoryBytesSpilled(int index)	repeated double memory_bytes_spilled = 14;
int	getMemoryBytesSpilledCount()	repeated double memory_bytes_spilled = 14;
List<Double>	getMemoryBytesSpilledList()	repeated double memory_bytes_spilled = 14;
double	getOutputBytes(int index)	repeated double output_bytes = 8;
int	getOutputBytesCount()	repeated double output_bytes = 8;
List<Double>	getOutputBytesList()	repeated double output_bytes = 8;
double	getOutputRecords(int index)	repeated double output_records = 9;
int	getOutputRecordsCount()	repeated double output_records = 9;
List<Double>	getOutputRecordsList()	repeated double output_records = 9;
StoreTypes.ExecutorPeakMetricsDistributions	getPeakMemoryMetrics()	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorPeakMetricsDistributions.Builder	getPeakMemoryMetricsBuilder()	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorPeakMetricsDistributionsOrBuilder	getPeakMemoryMetricsOrBuilder()	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
double	getQuantiles(int index)	repeated double quantiles = 1;
int	getQuantilesCount()	repeated double quantiles = 1;
List<Double>	getQuantilesList()	repeated double quantiles = 1;
double	getShuffleRead(int index)	repeated double shuffle_read = 10;
int	getShuffleReadCount()	repeated double shuffle_read = 10;
List<Double>	getShuffleReadList()	repeated double shuffle_read = 10;
double	getShuffleReadRecords(int index)	repeated double shuffle_read_records = 11;
int	getShuffleReadRecordsCount()	repeated double shuffle_read_records = 11;
List<Double>	getShuffleReadRecordsList()	repeated double shuffle_read_records = 11;
double	getShuffleWrite(int index)	repeated double shuffle_write = 12;
int	getShuffleWriteCount()	repeated double shuffle_write = 12;
List<Double>	getShuffleWriteList()	repeated double shuffle_write = 12;
double	getShuffleWriteRecords(int index)	repeated double shuffle_write_records = 13;
int	getShuffleWriteRecordsCount()	repeated double shuffle_write_records = 13;
List<Double>	getShuffleWriteRecordsList()	repeated double shuffle_write_records = 13;
double	getSucceededTasks(int index)	repeated double succeeded_tasks = 4;
int	getSucceededTasksCount()	repeated double succeeded_tasks = 4;
List<Double>	getSucceededTasksList()	repeated double succeeded_tasks = 4;
double	getTaskTime(int index)	repeated double task_time = 2;
int	getTaskTimeCount()	repeated double task_time = 2;
List<Double>	getTaskTimeList()	repeated double task_time = 2;
boolean	hasPeakMemoryMetrics()	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
final boolean	isInitialized()
StoreTypes.ExecutorMetricsDistributions.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.ExecutorMetricsDistributions.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.ExecutorMetricsDistributions.Builder	mergeFrom(StoreTypes.ExecutorMetricsDistributions other)
StoreTypes.ExecutorMetricsDistributions.Builder	mergePeakMemoryMetrics(StoreTypes.ExecutorPeakMetricsDistributions value)	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorMetricsDistributions.Builder	setDiskBytesSpilled(int index, double value)	repeated double disk_bytes_spilled = 15;
StoreTypes.ExecutorMetricsDistributions.Builder	setFailedTasks(int index, double value)	repeated double failed_tasks = 3;
StoreTypes.ExecutorMetricsDistributions.Builder	setInputBytes(int index, double value)	repeated double input_bytes = 6;
StoreTypes.ExecutorMetricsDistributions.Builder	setInputRecords(int index, double value)	repeated double input_records = 7;
StoreTypes.ExecutorMetricsDistributions.Builder	setKilledTasks(int index, double value)	repeated double killed_tasks = 5;
StoreTypes.ExecutorMetricsDistributions.Builder	setMemoryBytesSpilled(int index, double value)	repeated double memory_bytes_spilled = 14;
StoreTypes.ExecutorMetricsDistributions.Builder	setOutputBytes(int index, double value)	repeated double output_bytes = 8;
StoreTypes.ExecutorMetricsDistributions.Builder	setOutputRecords(int index, double value)	repeated double output_records = 9;
StoreTypes.ExecutorMetricsDistributions.Builder	setPeakMemoryMetrics(StoreTypes.ExecutorPeakMetricsDistributions value)	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorMetricsDistributions.Builder	setPeakMemoryMetrics(StoreTypes.ExecutorPeakMetricsDistributions.Builder builderForValue)	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
StoreTypes.ExecutorMetricsDistributions.Builder	setQuantiles(int index, double value)	repeated double quantiles = 1;
StoreTypes.ExecutorMetricsDistributions.Builder	setShuffleRead(int index, double value)	repeated double shuffle_read = 10;
StoreTypes.ExecutorMetricsDistributions.Builder	setShuffleReadRecords(int index, double value)	repeated double shuffle_read_records = 11;
StoreTypes.ExecutorMetricsDistributions.Builder	setShuffleWrite(int index, double value)	repeated double shuffle_write = 12;
StoreTypes.ExecutorMetricsDistributions.Builder	setShuffleWriteRecords(int index, double value)	repeated double shuffle_write_records = 13;
StoreTypes.ExecutorMetricsDistributions.Builder	setSucceededTasks(int index, double value)	repeated double succeeded_tasks = 4;
StoreTypes.ExecutorMetricsDistributions.Builder	setTaskTime(int index, double value)	repeated double task_time = 2;

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.ExecutorMetricsDistributions.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.ExecutorMetricsDistributions.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.ExecutorMetricsDistributions.Builder>

getDefaultInstanceForType

public StoreTypes.ExecutorMetricsDistributions getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.ExecutorMetricsDistributions build()

Specified by:

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

Specified by:

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

buildPartial

public StoreTypes.ExecutorMetricsDistributions buildPartial()

Specified by:

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

Specified by:

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

mergeFrom

public StoreTypes.ExecutorMetricsDistributions.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.ExecutorMetricsDistributions.Builder>

mergeFrom

public StoreTypes.ExecutorMetricsDistributions.Builder mergeFrom(StoreTypes.ExecutorMetricsDistributions 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.ExecutorMetricsDistributions.Builder>

mergeFrom

public StoreTypes.ExecutorMetricsDistributions.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.ExecutorMetricsDistributions.Builder>

Throws:

IOException

getQuantilesList

public List<Double> getQuantilesList()

repeated double quantiles = 1;

Specified by:

getQuantilesList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the quantiles.

getQuantilesCount

public int getQuantilesCount()

repeated double quantiles = 1;

Specified by:

getQuantilesCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of quantiles.

getQuantiles

public double getQuantiles(int index)

repeated double quantiles = 1;

Specified by:

getQuantiles in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The quantiles at the given index.

setQuantiles

public StoreTypes.ExecutorMetricsDistributions.Builder setQuantiles(int index,
 double value)

repeated double quantiles = 1;

Parameters:

index - The index to set the value at.

value - The quantiles to set.

Returns:

This builder for chaining.

addQuantiles

public StoreTypes.ExecutorMetricsDistributions.Builder addQuantiles(double value)

repeated double quantiles = 1;

Parameters:

value - The quantiles to add.

Returns:

This builder for chaining.

addAllQuantiles

public StoreTypes.ExecutorMetricsDistributions.Builder addAllQuantiles(Iterable<? extends Double> values)

repeated double quantiles = 1;

Parameters:

values - The quantiles to add.

Returns:

This builder for chaining.

clearQuantiles

public StoreTypes.ExecutorMetricsDistributions.Builder clearQuantiles()

repeated double quantiles = 1;

Returns:

This builder for chaining.

getTaskTimeList

public List<Double> getTaskTimeList()

repeated double task_time = 2;

Specified by:

getTaskTimeList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the taskTime.

getTaskTimeCount

public int getTaskTimeCount()

repeated double task_time = 2;

Specified by:

getTaskTimeCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of taskTime.

getTaskTime

public double getTaskTime(int index)

repeated double task_time = 2;

Specified by:

getTaskTime in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The taskTime at the given index.

setTaskTime

public StoreTypes.ExecutorMetricsDistributions.Builder setTaskTime(int index,
 double value)

repeated double task_time = 2;

Parameters:

index - The index to set the value at.

value - The taskTime to set.

Returns:

This builder for chaining.

addTaskTime

public StoreTypes.ExecutorMetricsDistributions.Builder addTaskTime(double value)

repeated double task_time = 2;

Parameters:

value - The taskTime to add.

Returns:

This builder for chaining.

addAllTaskTime

public StoreTypes.ExecutorMetricsDistributions.Builder addAllTaskTime(Iterable<? extends Double> values)

repeated double task_time = 2;

Parameters:

values - The taskTime to add.

Returns:

This builder for chaining.

clearTaskTime

public StoreTypes.ExecutorMetricsDistributions.Builder clearTaskTime()

repeated double task_time = 2;

Returns:

This builder for chaining.

getFailedTasksList

public List<Double> getFailedTasksList()

repeated double failed_tasks = 3;

Specified by:

getFailedTasksList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the failedTasks.

getFailedTasksCount

public int getFailedTasksCount()

repeated double failed_tasks = 3;

Specified by:

getFailedTasksCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of failedTasks.

getFailedTasks

public double getFailedTasks(int index)

repeated double failed_tasks = 3;

Specified by:

getFailedTasks in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The failedTasks at the given index.

setFailedTasks

public StoreTypes.ExecutorMetricsDistributions.Builder setFailedTasks(int index,
 double value)

repeated double failed_tasks = 3;

Parameters:

index - The index to set the value at.

value - The failedTasks to set.

Returns:

This builder for chaining.

addFailedTasks

public StoreTypes.ExecutorMetricsDistributions.Builder addFailedTasks(double value)

repeated double failed_tasks = 3;

Parameters:

value - The failedTasks to add.

Returns:

This builder for chaining.

addAllFailedTasks

public StoreTypes.ExecutorMetricsDistributions.Builder addAllFailedTasks(Iterable<? extends Double> values)

repeated double failed_tasks = 3;

Parameters:

values - The failedTasks to add.

Returns:

This builder for chaining.

clearFailedTasks

public StoreTypes.ExecutorMetricsDistributions.Builder clearFailedTasks()

repeated double failed_tasks = 3;

Returns:

This builder for chaining.

getSucceededTasksList

public List<Double> getSucceededTasksList()

repeated double succeeded_tasks = 4;

Specified by:

getSucceededTasksList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the succeededTasks.

getSucceededTasksCount

public int getSucceededTasksCount()

repeated double succeeded_tasks = 4;

Specified by:

getSucceededTasksCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of succeededTasks.

getSucceededTasks

public double getSucceededTasks(int index)

repeated double succeeded_tasks = 4;

Specified by:

getSucceededTasks in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The succeededTasks at the given index.

setSucceededTasks

public StoreTypes.ExecutorMetricsDistributions.Builder setSucceededTasks(int index,
 double value)

repeated double succeeded_tasks = 4;

Parameters:

index - The index to set the value at.

value - The succeededTasks to set.

Returns:

This builder for chaining.

addSucceededTasks

public StoreTypes.ExecutorMetricsDistributions.Builder addSucceededTasks(double value)

repeated double succeeded_tasks = 4;

Parameters:

value - The succeededTasks to add.

Returns:

This builder for chaining.

addAllSucceededTasks

public StoreTypes.ExecutorMetricsDistributions.Builder addAllSucceededTasks(Iterable<? extends Double> values)

repeated double succeeded_tasks = 4;

Parameters:

values - The succeededTasks to add.

Returns:

This builder for chaining.

clearSucceededTasks

public StoreTypes.ExecutorMetricsDistributions.Builder clearSucceededTasks()

repeated double succeeded_tasks = 4;

Returns:

This builder for chaining.

getKilledTasksList

public List<Double> getKilledTasksList()

repeated double killed_tasks = 5;

Specified by:

getKilledTasksList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the killedTasks.

getKilledTasksCount

public int getKilledTasksCount()

repeated double killed_tasks = 5;

Specified by:

getKilledTasksCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of killedTasks.

getKilledTasks

public double getKilledTasks(int index)

repeated double killed_tasks = 5;

Specified by:

getKilledTasks in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The killedTasks at the given index.

setKilledTasks

public StoreTypes.ExecutorMetricsDistributions.Builder setKilledTasks(int index,
 double value)

repeated double killed_tasks = 5;

Parameters:

index - The index to set the value at.

value - The killedTasks to set.

Returns:

This builder for chaining.

addKilledTasks

public StoreTypes.ExecutorMetricsDistributions.Builder addKilledTasks(double value)

repeated double killed_tasks = 5;

Parameters:

value - The killedTasks to add.

Returns:

This builder for chaining.

addAllKilledTasks

public StoreTypes.ExecutorMetricsDistributions.Builder addAllKilledTasks(Iterable<? extends Double> values)

repeated double killed_tasks = 5;

Parameters:

values - The killedTasks to add.

Returns:

This builder for chaining.

clearKilledTasks

public StoreTypes.ExecutorMetricsDistributions.Builder clearKilledTasks()

repeated double killed_tasks = 5;

Returns:

This builder for chaining.

getInputBytesList

public List<Double> getInputBytesList()

repeated double input_bytes = 6;

Specified by:

getInputBytesList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the inputBytes.

getInputBytesCount

public int getInputBytesCount()

repeated double input_bytes = 6;

Specified by:

getInputBytesCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of inputBytes.

getInputBytes

public double getInputBytes(int index)

repeated double input_bytes = 6;

Specified by:

getInputBytes in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The inputBytes at the given index.

setInputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder setInputBytes(int index,
 double value)

repeated double input_bytes = 6;

Parameters:

index - The index to set the value at.

value - The inputBytes to set.

Returns:

This builder for chaining.

addInputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder addInputBytes(double value)

repeated double input_bytes = 6;

Parameters:

value - The inputBytes to add.

Returns:

This builder for chaining.

addAllInputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder addAllInputBytes(Iterable<? extends Double> values)

repeated double input_bytes = 6;

Parameters:

values - The inputBytes to add.

Returns:

This builder for chaining.

clearInputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder clearInputBytes()

repeated double input_bytes = 6;

Returns:

This builder for chaining.

getInputRecordsList

public List<Double> getInputRecordsList()

repeated double input_records = 7;

Specified by:

getInputRecordsList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the inputRecords.

getInputRecordsCount

public int getInputRecordsCount()

repeated double input_records = 7;

Specified by:

getInputRecordsCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of inputRecords.

getInputRecords

public double getInputRecords(int index)

repeated double input_records = 7;

Specified by:

getInputRecords in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The inputRecords at the given index.

setInputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder setInputRecords(int index,
 double value)

repeated double input_records = 7;

Parameters:

index - The index to set the value at.

value - The inputRecords to set.

Returns:

This builder for chaining.

addInputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addInputRecords(double value)

repeated double input_records = 7;

Parameters:

value - The inputRecords to add.

Returns:

This builder for chaining.

addAllInputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addAllInputRecords(Iterable<? extends Double> values)

repeated double input_records = 7;

Parameters:

values - The inputRecords to add.

Returns:

This builder for chaining.

clearInputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder clearInputRecords()

repeated double input_records = 7;

Returns:

This builder for chaining.

getOutputBytesList

public List<Double> getOutputBytesList()

repeated double output_bytes = 8;

Specified by:

getOutputBytesList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the outputBytes.

getOutputBytesCount

public int getOutputBytesCount()

repeated double output_bytes = 8;

Specified by:

getOutputBytesCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of outputBytes.

getOutputBytes

public double getOutputBytes(int index)

repeated double output_bytes = 8;

Specified by:

getOutputBytes in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The outputBytes at the given index.

setOutputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder setOutputBytes(int index,
 double value)

repeated double output_bytes = 8;

Parameters:

index - The index to set the value at.

value - The outputBytes to set.

Returns:

This builder for chaining.

addOutputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder addOutputBytes(double value)

repeated double output_bytes = 8;

Parameters:

value - The outputBytes to add.

Returns:

This builder for chaining.

addAllOutputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder addAllOutputBytes(Iterable<? extends Double> values)

repeated double output_bytes = 8;

Parameters:

values - The outputBytes to add.

Returns:

This builder for chaining.

clearOutputBytes

public StoreTypes.ExecutorMetricsDistributions.Builder clearOutputBytes()

repeated double output_bytes = 8;

Returns:

This builder for chaining.

getOutputRecordsList

public List<Double> getOutputRecordsList()

repeated double output_records = 9;

Specified by:

getOutputRecordsList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the outputRecords.

getOutputRecordsCount

public int getOutputRecordsCount()

repeated double output_records = 9;

Specified by:

getOutputRecordsCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of outputRecords.

getOutputRecords

public double getOutputRecords(int index)

repeated double output_records = 9;

Specified by:

getOutputRecords in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The outputRecords at the given index.

setOutputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder setOutputRecords(int index,
 double value)

repeated double output_records = 9;

Parameters:

index - The index to set the value at.

value - The outputRecords to set.

Returns:

This builder for chaining.

addOutputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addOutputRecords(double value)

repeated double output_records = 9;

Parameters:

value - The outputRecords to add.

Returns:

This builder for chaining.

addAllOutputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addAllOutputRecords(Iterable<? extends Double> values)

repeated double output_records = 9;

Parameters:

values - The outputRecords to add.

Returns:

This builder for chaining.

clearOutputRecords

public StoreTypes.ExecutorMetricsDistributions.Builder clearOutputRecords()

repeated double output_records = 9;

Returns:

This builder for chaining.

getShuffleReadList

public List<Double> getShuffleReadList()

repeated double shuffle_read = 10;

Specified by:

getShuffleReadList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the shuffleRead.

getShuffleReadCount

public int getShuffleReadCount()

repeated double shuffle_read = 10;

Specified by:

getShuffleReadCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of shuffleRead.

getShuffleRead

public double getShuffleRead(int index)

repeated double shuffle_read = 10;

Specified by:

getShuffleRead in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The shuffleRead at the given index.

setShuffleRead

public StoreTypes.ExecutorMetricsDistributions.Builder setShuffleRead(int index,
 double value)

repeated double shuffle_read = 10;

Parameters:

index - The index to set the value at.

value - The shuffleRead to set.

Returns:

This builder for chaining.

addShuffleRead

public StoreTypes.ExecutorMetricsDistributions.Builder addShuffleRead(double value)

repeated double shuffle_read = 10;

Parameters:

value - The shuffleRead to add.

Returns:

This builder for chaining.

addAllShuffleRead

public StoreTypes.ExecutorMetricsDistributions.Builder addAllShuffleRead(Iterable<? extends Double> values)

repeated double shuffle_read = 10;

Parameters:

values - The shuffleRead to add.

Returns:

This builder for chaining.

clearShuffleRead

public StoreTypes.ExecutorMetricsDistributions.Builder clearShuffleRead()

repeated double shuffle_read = 10;

Returns:

This builder for chaining.

getShuffleReadRecordsList

public List<Double> getShuffleReadRecordsList()

repeated double shuffle_read_records = 11;

Specified by:

getShuffleReadRecordsList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the shuffleReadRecords.

getShuffleReadRecordsCount

public int getShuffleReadRecordsCount()

repeated double shuffle_read_records = 11;

Specified by:

getShuffleReadRecordsCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of shuffleReadRecords.

getShuffleReadRecords

public double getShuffleReadRecords(int index)

repeated double shuffle_read_records = 11;

Specified by:

getShuffleReadRecords in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The shuffleReadRecords at the given index.

setShuffleReadRecords

public StoreTypes.ExecutorMetricsDistributions.Builder setShuffleReadRecords(int index,
 double value)

repeated double shuffle_read_records = 11;

Parameters:

index - The index to set the value at.

value - The shuffleReadRecords to set.

Returns:

This builder for chaining.

addShuffleReadRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addShuffleReadRecords(double value)

repeated double shuffle_read_records = 11;

Parameters:

value - The shuffleReadRecords to add.

Returns:

This builder for chaining.

addAllShuffleReadRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addAllShuffleReadRecords(Iterable<? extends Double> values)

repeated double shuffle_read_records = 11;

Parameters:

values - The shuffleReadRecords to add.

Returns:

This builder for chaining.

clearShuffleReadRecords

public StoreTypes.ExecutorMetricsDistributions.Builder clearShuffleReadRecords()

repeated double shuffle_read_records = 11;

Returns:

This builder for chaining.

getShuffleWriteList

public List<Double> getShuffleWriteList()

repeated double shuffle_write = 12;

Specified by:

getShuffleWriteList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the shuffleWrite.

getShuffleWriteCount

public int getShuffleWriteCount()

repeated double shuffle_write = 12;

Specified by:

getShuffleWriteCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of shuffleWrite.

getShuffleWrite

public double getShuffleWrite(int index)

repeated double shuffle_write = 12;

Specified by:

getShuffleWrite in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The shuffleWrite at the given index.

setShuffleWrite

public StoreTypes.ExecutorMetricsDistributions.Builder setShuffleWrite(int index,
 double value)

repeated double shuffle_write = 12;

Parameters:

index - The index to set the value at.

value - The shuffleWrite to set.

Returns:

This builder for chaining.

addShuffleWrite

public StoreTypes.ExecutorMetricsDistributions.Builder addShuffleWrite(double value)

repeated double shuffle_write = 12;

Parameters:

value - The shuffleWrite to add.

Returns:

This builder for chaining.

addAllShuffleWrite

public StoreTypes.ExecutorMetricsDistributions.Builder addAllShuffleWrite(Iterable<? extends Double> values)

repeated double shuffle_write = 12;

Parameters:

values - The shuffleWrite to add.

Returns:

This builder for chaining.

clearShuffleWrite

public StoreTypes.ExecutorMetricsDistributions.Builder clearShuffleWrite()

repeated double shuffle_write = 12;

Returns:

This builder for chaining.

getShuffleWriteRecordsList

public List<Double> getShuffleWriteRecordsList()

repeated double shuffle_write_records = 13;

Specified by:

getShuffleWriteRecordsList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the shuffleWriteRecords.

getShuffleWriteRecordsCount

public int getShuffleWriteRecordsCount()

repeated double shuffle_write_records = 13;

Specified by:

getShuffleWriteRecordsCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of shuffleWriteRecords.

getShuffleWriteRecords

public double getShuffleWriteRecords(int index)

repeated double shuffle_write_records = 13;

Specified by:

getShuffleWriteRecords in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The shuffleWriteRecords at the given index.

setShuffleWriteRecords

public StoreTypes.ExecutorMetricsDistributions.Builder setShuffleWriteRecords(int index,
 double value)

repeated double shuffle_write_records = 13;

Parameters:

index - The index to set the value at.

value - The shuffleWriteRecords to set.

Returns:

This builder for chaining.

addShuffleWriteRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addShuffleWriteRecords(double value)

repeated double shuffle_write_records = 13;

Parameters:

value - The shuffleWriteRecords to add.

Returns:

This builder for chaining.

addAllShuffleWriteRecords

public StoreTypes.ExecutorMetricsDistributions.Builder addAllShuffleWriteRecords(Iterable<? extends Double> values)

repeated double shuffle_write_records = 13;

Parameters:

values - The shuffleWriteRecords to add.

Returns:

This builder for chaining.

clearShuffleWriteRecords

public StoreTypes.ExecutorMetricsDistributions.Builder clearShuffleWriteRecords()

repeated double shuffle_write_records = 13;

Returns:

This builder for chaining.

getMemoryBytesSpilledList

public List<Double> getMemoryBytesSpilledList()

repeated double memory_bytes_spilled = 14;

Specified by:

getMemoryBytesSpilledList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the memoryBytesSpilled.

getMemoryBytesSpilledCount

public int getMemoryBytesSpilledCount()

repeated double memory_bytes_spilled = 14;

Specified by:

getMemoryBytesSpilledCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of memoryBytesSpilled.

getMemoryBytesSpilled

public double getMemoryBytesSpilled(int index)

repeated double memory_bytes_spilled = 14;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The memoryBytesSpilled at the given index.

setMemoryBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder setMemoryBytesSpilled(int index,
 double value)

repeated double memory_bytes_spilled = 14;

Parameters:

index - The index to set the value at.

value - The memoryBytesSpilled to set.

Returns:

This builder for chaining.

addMemoryBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder addMemoryBytesSpilled(double value)

repeated double memory_bytes_spilled = 14;

Parameters:

value - The memoryBytesSpilled to add.

Returns:

This builder for chaining.

addAllMemoryBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder addAllMemoryBytesSpilled(Iterable<? extends Double> values)

repeated double memory_bytes_spilled = 14;

Parameters:

values - The memoryBytesSpilled to add.

Returns:

This builder for chaining.

clearMemoryBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder clearMemoryBytesSpilled()

repeated double memory_bytes_spilled = 14;

Returns:

This builder for chaining.

getDiskBytesSpilledList

public List<Double> getDiskBytesSpilledList()

repeated double disk_bytes_spilled = 15;

Specified by:

getDiskBytesSpilledList in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

A list containing the diskBytesSpilled.

getDiskBytesSpilledCount

public int getDiskBytesSpilledCount()

repeated double disk_bytes_spilled = 15;

Specified by:

getDiskBytesSpilledCount in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The count of diskBytesSpilled.

getDiskBytesSpilled

public double getDiskBytesSpilled(int index)

repeated double disk_bytes_spilled = 15;

Specified by:

getDiskBytesSpilled in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The diskBytesSpilled at the given index.

setDiskBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder setDiskBytesSpilled(int index,
 double value)

repeated double disk_bytes_spilled = 15;

Parameters:

index - The index to set the value at.

value - The diskBytesSpilled to set.

Returns:

This builder for chaining.

addDiskBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder addDiskBytesSpilled(double value)

repeated double disk_bytes_spilled = 15;

Parameters:

value - The diskBytesSpilled to add.

Returns:

This builder for chaining.

addAllDiskBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder addAllDiskBytesSpilled(Iterable<? extends Double> values)

repeated double disk_bytes_spilled = 15;

Parameters:

values - The diskBytesSpilled to add.

Returns:

This builder for chaining.

clearDiskBytesSpilled

public StoreTypes.ExecutorMetricsDistributions.Builder clearDiskBytesSpilled()

repeated double disk_bytes_spilled = 15;

Returns:

This builder for chaining.

hasPeakMemoryMetrics

public boolean hasPeakMemoryMetrics()

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

Specified by:

hasPeakMemoryMetrics in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

Whether the peakMemoryMetrics field is set.

getPeakMemoryMetrics

public StoreTypes.ExecutorPeakMetricsDistributions getPeakMemoryMetrics()

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

Specified by:

getPeakMemoryMetrics in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

Returns:

The peakMemoryMetrics.

setPeakMemoryMetrics

public StoreTypes.ExecutorMetricsDistributions.Builder setPeakMemoryMetrics(StoreTypes.ExecutorPeakMetricsDistributions value)

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

setPeakMemoryMetrics

public StoreTypes.ExecutorMetricsDistributions.Builder setPeakMemoryMetrics(StoreTypes.ExecutorPeakMetricsDistributions.Builder builderForValue)

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

mergePeakMemoryMetrics

public StoreTypes.ExecutorMetricsDistributions.Builder mergePeakMemoryMetrics(StoreTypes.ExecutorPeakMetricsDistributions value)

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

clearPeakMemoryMetrics

public StoreTypes.ExecutorMetricsDistributions.Builder clearPeakMemoryMetrics()

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

getPeakMemoryMetricsBuilder

public StoreTypes.ExecutorPeakMetricsDistributions.Builder getPeakMemoryMetricsBuilder()

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

getPeakMemoryMetricsOrBuilder

public StoreTypes.ExecutorPeakMetricsDistributionsOrBuilder getPeakMemoryMetricsOrBuilder()

.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;

Specified by:

getPeakMemoryMetricsOrBuilder in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder