Package org.apache.spark.status.protobuf

Class StoreTypes.TaskMetricDistributions.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

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

com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

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

All Implemented Interfaces:

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

Enclosing class:

StoreTypes.TaskMetricDistributions

public static final class StoreTypes.TaskMetricDistributions.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>
implements StoreTypes.TaskMetricDistributionsOrBuilder

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

Method Summary

Modifier and Type	Method	Description
StoreTypes.TaskMetricDistributions.Builder	addAllDiskBytesSpilled(Iterable<? extends Double> values)	repeated double disk_bytes_spilled = 14;
StoreTypes.TaskMetricDistributions.Builder	addAllDuration(Iterable<? extends Double> values)	repeated double duration = 2;
StoreTypes.TaskMetricDistributions.Builder	addAllExecutorCpuTime(Iterable<? extends Double> values)	repeated double executor_cpu_time = 6;
StoreTypes.TaskMetricDistributions.Builder	addAllExecutorDeserializeCpuTime(Iterable<? extends Double> values)	repeated double executor_deserialize_cpu_time = 4;
StoreTypes.TaskMetricDistributions.Builder	addAllExecutorDeserializeTime(Iterable<? extends Double> values)	repeated double executor_deserialize_time = 3;
StoreTypes.TaskMetricDistributions.Builder	addAllExecutorRunTime(Iterable<? extends Double> values)	repeated double executor_run_time = 5;
StoreTypes.TaskMetricDistributions.Builder	addAllGettingResultTime(Iterable<? extends Double> values)	repeated double getting_result_time = 10;
StoreTypes.TaskMetricDistributions.Builder	addAllJvmGcTime(Iterable<? extends Double> values)	repeated double jvm_gc_time = 8;
StoreTypes.TaskMetricDistributions.Builder	addAllMemoryBytesSpilled(Iterable<? extends Double> values)	repeated double memory_bytes_spilled = 13;
StoreTypes.TaskMetricDistributions.Builder	addAllPeakExecutionMemory(Iterable<? extends Double> values)	repeated double peak_execution_memory = 12;
StoreTypes.TaskMetricDistributions.Builder	addAllQuantiles(Iterable<? extends Double> values)	repeated double quantiles = 1;
StoreTypes.TaskMetricDistributions.Builder	addAllResultSerializationTime(Iterable<? extends Double> values)	repeated double result_serialization_time = 9;
StoreTypes.TaskMetricDistributions.Builder	addAllResultSize(Iterable<? extends Double> values)	repeated double result_size = 7;
StoreTypes.TaskMetricDistributions.Builder	addAllSchedulerDelay(Iterable<? extends Double> values)	repeated double scheduler_delay = 11;
StoreTypes.TaskMetricDistributions.Builder	addDiskBytesSpilled(double value)	repeated double disk_bytes_spilled = 14;
StoreTypes.TaskMetricDistributions.Builder	addDuration(double value)	repeated double duration = 2;
StoreTypes.TaskMetricDistributions.Builder	addExecutorCpuTime(double value)	repeated double executor_cpu_time = 6;
StoreTypes.TaskMetricDistributions.Builder	addExecutorDeserializeCpuTime(double value)	repeated double executor_deserialize_cpu_time = 4;
StoreTypes.TaskMetricDistributions.Builder	addExecutorDeserializeTime(double value)	repeated double executor_deserialize_time = 3;
StoreTypes.TaskMetricDistributions.Builder	addExecutorRunTime(double value)	repeated double executor_run_time = 5;
StoreTypes.TaskMetricDistributions.Builder	addGettingResultTime(double value)	repeated double getting_result_time = 10;
StoreTypes.TaskMetricDistributions.Builder	addJvmGcTime(double value)	repeated double jvm_gc_time = 8;
StoreTypes.TaskMetricDistributions.Builder	addMemoryBytesSpilled(double value)	repeated double memory_bytes_spilled = 13;
StoreTypes.TaskMetricDistributions.Builder	addPeakExecutionMemory(double value)	repeated double peak_execution_memory = 12;
StoreTypes.TaskMetricDistributions.Builder	addQuantiles(double value)	repeated double quantiles = 1;
StoreTypes.TaskMetricDistributions.Builder	addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
StoreTypes.TaskMetricDistributions.Builder	addResultSerializationTime(double value)	repeated double result_serialization_time = 9;
StoreTypes.TaskMetricDistributions.Builder	addResultSize(double value)	repeated double result_size = 7;
StoreTypes.TaskMetricDistributions.Builder	addSchedulerDelay(double value)	repeated double scheduler_delay = 11;
StoreTypes.TaskMetricDistributions	build()
StoreTypes.TaskMetricDistributions	buildPartial()
StoreTypes.TaskMetricDistributions.Builder	clear()
StoreTypes.TaskMetricDistributions.Builder	clearDiskBytesSpilled()	repeated double disk_bytes_spilled = 14;
StoreTypes.TaskMetricDistributions.Builder	clearDuration()	repeated double duration = 2;
StoreTypes.TaskMetricDistributions.Builder	clearExecutorCpuTime()	repeated double executor_cpu_time = 6;
StoreTypes.TaskMetricDistributions.Builder	clearExecutorDeserializeCpuTime()	repeated double executor_deserialize_cpu_time = 4;
StoreTypes.TaskMetricDistributions.Builder	clearExecutorDeserializeTime()	repeated double executor_deserialize_time = 3;
StoreTypes.TaskMetricDistributions.Builder	clearExecutorRunTime()	repeated double executor_run_time = 5;
StoreTypes.TaskMetricDistributions.Builder	clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
StoreTypes.TaskMetricDistributions.Builder	clearGettingResultTime()	repeated double getting_result_time = 10;
StoreTypes.TaskMetricDistributions.Builder	clearInputMetrics()	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.TaskMetricDistributions.Builder	clearJvmGcTime()	repeated double jvm_gc_time = 8;
StoreTypes.TaskMetricDistributions.Builder	clearMemoryBytesSpilled()	repeated double memory_bytes_spilled = 13;
StoreTypes.TaskMetricDistributions.Builder	clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
StoreTypes.TaskMetricDistributions.Builder	clearOutputMetrics()	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.TaskMetricDistributions.Builder	clearPeakExecutionMemory()	repeated double peak_execution_memory = 12;
StoreTypes.TaskMetricDistributions.Builder	clearQuantiles()	repeated double quantiles = 1;
StoreTypes.TaskMetricDistributions.Builder	clearResultSerializationTime()	repeated double result_serialization_time = 9;
StoreTypes.TaskMetricDistributions.Builder	clearResultSize()	repeated double result_size = 7;
StoreTypes.TaskMetricDistributions.Builder	clearSchedulerDelay()	repeated double scheduler_delay = 11;
StoreTypes.TaskMetricDistributions.Builder	clearShuffleReadMetrics()	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.TaskMetricDistributions.Builder	clearShuffleWriteMetrics()	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
StoreTypes.TaskMetricDistributions.Builder	clone()
StoreTypes.TaskMetricDistributions	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
double	getDiskBytesSpilled(int index)	repeated double disk_bytes_spilled = 14;
int	getDiskBytesSpilledCount()	repeated double disk_bytes_spilled = 14;
List<Double>	getDiskBytesSpilledList()	repeated double disk_bytes_spilled = 14;
double	getDuration(int index)	repeated double duration = 2;
int	getDurationCount()	repeated double duration = 2;
List<Double>	getDurationList()	repeated double duration = 2;
double	getExecutorCpuTime(int index)	repeated double executor_cpu_time = 6;
int	getExecutorCpuTimeCount()	repeated double executor_cpu_time = 6;
List<Double>	getExecutorCpuTimeList()	repeated double executor_cpu_time = 6;
double	getExecutorDeserializeCpuTime(int index)	repeated double executor_deserialize_cpu_time = 4;
int	getExecutorDeserializeCpuTimeCount()	repeated double executor_deserialize_cpu_time = 4;
List<Double>	getExecutorDeserializeCpuTimeList()	repeated double executor_deserialize_cpu_time = 4;
double	getExecutorDeserializeTime(int index)	repeated double executor_deserialize_time = 3;
int	getExecutorDeserializeTimeCount()	repeated double executor_deserialize_time = 3;
List<Double>	getExecutorDeserializeTimeList()	repeated double executor_deserialize_time = 3;
double	getExecutorRunTime(int index)	repeated double executor_run_time = 5;
int	getExecutorRunTimeCount()	repeated double executor_run_time = 5;
List<Double>	getExecutorRunTimeList()	repeated double executor_run_time = 5;
double	getGettingResultTime(int index)	repeated double getting_result_time = 10;
int	getGettingResultTimeCount()	repeated double getting_result_time = 10;
List<Double>	getGettingResultTimeList()	repeated double getting_result_time = 10;
StoreTypes.InputMetricDistributions	getInputMetrics()	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.InputMetricDistributions.Builder	getInputMetricsBuilder()	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.InputMetricDistributionsOrBuilder	getInputMetricsOrBuilder()	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
double	getJvmGcTime(int index)	repeated double jvm_gc_time = 8;
int	getJvmGcTimeCount()	repeated double jvm_gc_time = 8;
List<Double>	getJvmGcTimeList()	repeated double jvm_gc_time = 8;
double	getMemoryBytesSpilled(int index)	repeated double memory_bytes_spilled = 13;
int	getMemoryBytesSpilledCount()	repeated double memory_bytes_spilled = 13;
List<Double>	getMemoryBytesSpilledList()	repeated double memory_bytes_spilled = 13;
StoreTypes.OutputMetricDistributions	getOutputMetrics()	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.OutputMetricDistributions.Builder	getOutputMetricsBuilder()	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.OutputMetricDistributionsOrBuilder	getOutputMetricsOrBuilder()	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
double	getPeakExecutionMemory(int index)	repeated double peak_execution_memory = 12;
int	getPeakExecutionMemoryCount()	repeated double peak_execution_memory = 12;
List<Double>	getPeakExecutionMemoryList()	repeated double peak_execution_memory = 12;
double	getQuantiles(int index)	repeated double quantiles = 1;
int	getQuantilesCount()	repeated double quantiles = 1;
List<Double>	getQuantilesList()	repeated double quantiles = 1;
double	getResultSerializationTime(int index)	repeated double result_serialization_time = 9;
int	getResultSerializationTimeCount()	repeated double result_serialization_time = 9;
List<Double>	getResultSerializationTimeList()	repeated double result_serialization_time = 9;
double	getResultSize(int index)	repeated double result_size = 7;
int	getResultSizeCount()	repeated double result_size = 7;
List<Double>	getResultSizeList()	repeated double result_size = 7;
double	getSchedulerDelay(int index)	repeated double scheduler_delay = 11;
int	getSchedulerDelayCount()	repeated double scheduler_delay = 11;
List<Double>	getSchedulerDelayList()	repeated double scheduler_delay = 11;
StoreTypes.ShuffleReadMetricDistributions	getShuffleReadMetrics()	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.ShuffleReadMetricDistributions.Builder	getShuffleReadMetricsBuilder()	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.ShuffleReadMetricDistributionsOrBuilder	getShuffleReadMetricsOrBuilder()	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.ShuffleWriteMetricDistributions	getShuffleWriteMetrics()	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
StoreTypes.ShuffleWriteMetricDistributions.Builder	getShuffleWriteMetricsBuilder()	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
StoreTypes.ShuffleWriteMetricDistributionsOrBuilder	getShuffleWriteMetricsOrBuilder()	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
boolean	hasInputMetrics()	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
boolean	hasOutputMetrics()	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
boolean	hasShuffleReadMetrics()	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
boolean	hasShuffleWriteMetrics()	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
final boolean	isInitialized()
StoreTypes.TaskMetricDistributions.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.TaskMetricDistributions.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.TaskMetricDistributions.Builder	mergeFrom(StoreTypes.TaskMetricDistributions other)
StoreTypes.TaskMetricDistributions.Builder	mergeInputMetrics(StoreTypes.InputMetricDistributions value)	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.TaskMetricDistributions.Builder	mergeOutputMetrics(StoreTypes.OutputMetricDistributions value)	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.TaskMetricDistributions.Builder	mergeShuffleReadMetrics(StoreTypes.ShuffleReadMetricDistributions value)	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.TaskMetricDistributions.Builder	mergeShuffleWriteMetrics(StoreTypes.ShuffleWriteMetricDistributions value)	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
final StoreTypes.TaskMetricDistributions.Builder	mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
StoreTypes.TaskMetricDistributions.Builder	setDiskBytesSpilled(int index, double value)	repeated double disk_bytes_spilled = 14;
StoreTypes.TaskMetricDistributions.Builder	setDuration(int index, double value)	repeated double duration = 2;
StoreTypes.TaskMetricDistributions.Builder	setExecutorCpuTime(int index, double value)	repeated double executor_cpu_time = 6;
StoreTypes.TaskMetricDistributions.Builder	setExecutorDeserializeCpuTime(int index, double value)	repeated double executor_deserialize_cpu_time = 4;
StoreTypes.TaskMetricDistributions.Builder	setExecutorDeserializeTime(int index, double value)	repeated double executor_deserialize_time = 3;
StoreTypes.TaskMetricDistributions.Builder	setExecutorRunTime(int index, double value)	repeated double executor_run_time = 5;
StoreTypes.TaskMetricDistributions.Builder	setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
StoreTypes.TaskMetricDistributions.Builder	setGettingResultTime(int index, double value)	repeated double getting_result_time = 10;
StoreTypes.TaskMetricDistributions.Builder	setInputMetrics(StoreTypes.InputMetricDistributions value)	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.TaskMetricDistributions.Builder	setInputMetrics(StoreTypes.InputMetricDistributions.Builder builderForValue)	.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
StoreTypes.TaskMetricDistributions.Builder	setJvmGcTime(int index, double value)	repeated double jvm_gc_time = 8;
StoreTypes.TaskMetricDistributions.Builder	setMemoryBytesSpilled(int index, double value)	repeated double memory_bytes_spilled = 13;
StoreTypes.TaskMetricDistributions.Builder	setOutputMetrics(StoreTypes.OutputMetricDistributions value)	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.TaskMetricDistributions.Builder	setOutputMetrics(StoreTypes.OutputMetricDistributions.Builder builderForValue)	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
StoreTypes.TaskMetricDistributions.Builder	setPeakExecutionMemory(int index, double value)	repeated double peak_execution_memory = 12;
StoreTypes.TaskMetricDistributions.Builder	setQuantiles(int index, double value)	repeated double quantiles = 1;
StoreTypes.TaskMetricDistributions.Builder	setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
StoreTypes.TaskMetricDistributions.Builder	setResultSerializationTime(int index, double value)	repeated double result_serialization_time = 9;
StoreTypes.TaskMetricDistributions.Builder	setResultSize(int index, double value)	repeated double result_size = 7;
StoreTypes.TaskMetricDistributions.Builder	setSchedulerDelay(int index, double value)	repeated double scheduler_delay = 11;
StoreTypes.TaskMetricDistributions.Builder	setShuffleReadMetrics(StoreTypes.ShuffleReadMetricDistributions value)	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.TaskMetricDistributions.Builder	setShuffleReadMetrics(StoreTypes.ShuffleReadMetricDistributions.Builder builderForValue)	.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
StoreTypes.TaskMetricDistributions.Builder	setShuffleWriteMetrics(StoreTypes.ShuffleWriteMetricDistributions value)	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
StoreTypes.TaskMetricDistributions.Builder	setShuffleWriteMetrics(StoreTypes.ShuffleWriteMetricDistributions.Builder builderForValue)	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
final StoreTypes.TaskMetricDistributions.Builder	setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

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

getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForField

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

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

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

mergeFrom

Methods inherited from class java.lang.Object

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

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.TaskMetricDistributions.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.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.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.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

getDefaultInstanceForType

public StoreTypes.TaskMetricDistributions getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.TaskMetricDistributions build()

Specified by:

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

Specified by:

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

buildPartial

public StoreTypes.TaskMetricDistributions buildPartial()

Specified by:

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

Specified by:

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

clone

public StoreTypes.TaskMetricDistributions.Builder clone()

Specified by:

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

Specified by:

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

Overrides:

clone in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

setField

public StoreTypes.TaskMetricDistributions.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field,
 Object value)

Specified by:

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

Overrides:

setField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

clearField

public StoreTypes.TaskMetricDistributions.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)

Specified by:

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

Overrides:

clearField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

clearOneof

public StoreTypes.TaskMetricDistributions.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)

Specified by:

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

Overrides:

clearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

setRepeatedField

public StoreTypes.TaskMetricDistributions.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
 int index,
 Object value)

Specified by:

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

Overrides:

setRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

addRepeatedField

public StoreTypes.TaskMetricDistributions.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
 Object value)

Specified by:

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

Overrides:

addRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

mergeFrom

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

mergeFrom

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

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

mergeFrom

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

Throws:

IOException

getQuantilesList

public List<Double> getQuantilesList()

repeated double quantiles = 1;

Specified by:

getQuantilesList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the quantiles.

getQuantilesCount

public int getQuantilesCount()

repeated double quantiles = 1;

Specified by:

getQuantilesCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of quantiles.

getQuantiles

public double getQuantiles(int index)

repeated double quantiles = 1;

Specified by:

getQuantiles in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The quantiles at the given index.

setQuantiles

public StoreTypes.TaskMetricDistributions.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.TaskMetricDistributions.Builder addQuantiles(double value)

repeated double quantiles = 1;

Parameters:

value - The quantiles to add.

Returns:

This builder for chaining.

addAllQuantiles

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

repeated double quantiles = 1;

Parameters:

values - The quantiles to add.

Returns:

This builder for chaining.

clearQuantiles

public StoreTypes.TaskMetricDistributions.Builder clearQuantiles()

repeated double quantiles = 1;

Returns:

This builder for chaining.

getDurationList

public List<Double> getDurationList()

repeated double duration = 2;

Specified by:

getDurationList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the duration.

getDurationCount

public int getDurationCount()

repeated double duration = 2;

Specified by:

getDurationCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of duration.

getDuration

public double getDuration(int index)

repeated double duration = 2;

Specified by:

getDuration in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The duration at the given index.

setDuration

public StoreTypes.TaskMetricDistributions.Builder setDuration(int index,
 double value)

repeated double duration = 2;

Parameters:

index - The index to set the value at.

value - The duration to set.

Returns:

This builder for chaining.

addDuration

public StoreTypes.TaskMetricDistributions.Builder addDuration(double value)

repeated double duration = 2;

Parameters:

value - The duration to add.

Returns:

This builder for chaining.

addAllDuration

public StoreTypes.TaskMetricDistributions.Builder addAllDuration(Iterable<? extends Double> values)

repeated double duration = 2;

Parameters:

values - The duration to add.

Returns:

This builder for chaining.

clearDuration

public StoreTypes.TaskMetricDistributions.Builder clearDuration()

repeated double duration = 2;

Returns:

This builder for chaining.

getExecutorDeserializeTimeList

public List<Double> getExecutorDeserializeTimeList()

repeated double executor_deserialize_time = 3;

Specified by:

getExecutorDeserializeTimeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the executorDeserializeTime.

getExecutorDeserializeTimeCount

public int getExecutorDeserializeTimeCount()

repeated double executor_deserialize_time = 3;

Specified by:

getExecutorDeserializeTimeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of executorDeserializeTime.

getExecutorDeserializeTime

public double getExecutorDeserializeTime(int index)

repeated double executor_deserialize_time = 3;

Specified by:

getExecutorDeserializeTime in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The executorDeserializeTime at the given index.

setExecutorDeserializeTime

public StoreTypes.TaskMetricDistributions.Builder setExecutorDeserializeTime(int index,
 double value)

repeated double executor_deserialize_time = 3;

Parameters:

index - The index to set the value at.

value - The executorDeserializeTime to set.

Returns:

This builder for chaining.

addExecutorDeserializeTime

public StoreTypes.TaskMetricDistributions.Builder addExecutorDeserializeTime(double value)

repeated double executor_deserialize_time = 3;

Parameters:

value - The executorDeserializeTime to add.

Returns:

This builder for chaining.

addAllExecutorDeserializeTime

public StoreTypes.TaskMetricDistributions.Builder addAllExecutorDeserializeTime(Iterable<? extends Double> values)

repeated double executor_deserialize_time = 3;

Parameters:

values - The executorDeserializeTime to add.

Returns:

This builder for chaining.

clearExecutorDeserializeTime

public StoreTypes.TaskMetricDistributions.Builder clearExecutorDeserializeTime()

repeated double executor_deserialize_time = 3;

Returns:

This builder for chaining.

getExecutorDeserializeCpuTimeList

public List<Double> getExecutorDeserializeCpuTimeList()

repeated double executor_deserialize_cpu_time = 4;

Specified by:

getExecutorDeserializeCpuTimeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the executorDeserializeCpuTime.

getExecutorDeserializeCpuTimeCount

public int getExecutorDeserializeCpuTimeCount()

repeated double executor_deserialize_cpu_time = 4;

Specified by:

getExecutorDeserializeCpuTimeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of executorDeserializeCpuTime.

getExecutorDeserializeCpuTime

public double getExecutorDeserializeCpuTime(int index)

repeated double executor_deserialize_cpu_time = 4;

Specified by:

getExecutorDeserializeCpuTime in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The executorDeserializeCpuTime at the given index.

setExecutorDeserializeCpuTime

public StoreTypes.TaskMetricDistributions.Builder setExecutorDeserializeCpuTime(int index,
 double value)

repeated double executor_deserialize_cpu_time = 4;

Parameters:

index - The index to set the value at.

value - The executorDeserializeCpuTime to set.

Returns:

This builder for chaining.

addExecutorDeserializeCpuTime

public StoreTypes.TaskMetricDistributions.Builder addExecutorDeserializeCpuTime(double value)

repeated double executor_deserialize_cpu_time = 4;

Parameters:

value - The executorDeserializeCpuTime to add.

Returns:

This builder for chaining.

addAllExecutorDeserializeCpuTime

public StoreTypes.TaskMetricDistributions.Builder addAllExecutorDeserializeCpuTime(Iterable<? extends Double> values)

repeated double executor_deserialize_cpu_time = 4;

Parameters:

values - The executorDeserializeCpuTime to add.

Returns:

This builder for chaining.

clearExecutorDeserializeCpuTime

public StoreTypes.TaskMetricDistributions.Builder clearExecutorDeserializeCpuTime()

repeated double executor_deserialize_cpu_time = 4;

Returns:

This builder for chaining.

getExecutorRunTimeList

public List<Double> getExecutorRunTimeList()

repeated double executor_run_time = 5;

Specified by:

getExecutorRunTimeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the executorRunTime.

getExecutorRunTimeCount

public int getExecutorRunTimeCount()

repeated double executor_run_time = 5;

Specified by:

getExecutorRunTimeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of executorRunTime.

getExecutorRunTime

public double getExecutorRunTime(int index)

repeated double executor_run_time = 5;

Specified by:

getExecutorRunTime in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The executorRunTime at the given index.

setExecutorRunTime

public StoreTypes.TaskMetricDistributions.Builder setExecutorRunTime(int index,
 double value)

repeated double executor_run_time = 5;

Parameters:

index - The index to set the value at.

value - The executorRunTime to set.

Returns:

This builder for chaining.

addExecutorRunTime

public StoreTypes.TaskMetricDistributions.Builder addExecutorRunTime(double value)

repeated double executor_run_time = 5;

Parameters:

value - The executorRunTime to add.

Returns:

This builder for chaining.

addAllExecutorRunTime

public StoreTypes.TaskMetricDistributions.Builder addAllExecutorRunTime(Iterable<? extends Double> values)

repeated double executor_run_time = 5;

Parameters:

values - The executorRunTime to add.

Returns:

This builder for chaining.

clearExecutorRunTime

public StoreTypes.TaskMetricDistributions.Builder clearExecutorRunTime()

repeated double executor_run_time = 5;

Returns:

This builder for chaining.

getExecutorCpuTimeList

public List<Double> getExecutorCpuTimeList()

repeated double executor_cpu_time = 6;

Specified by:

getExecutorCpuTimeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the executorCpuTime.

getExecutorCpuTimeCount

public int getExecutorCpuTimeCount()

repeated double executor_cpu_time = 6;

Specified by:

getExecutorCpuTimeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of executorCpuTime.

getExecutorCpuTime

public double getExecutorCpuTime(int index)

repeated double executor_cpu_time = 6;

Specified by:

getExecutorCpuTime in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The executorCpuTime at the given index.

setExecutorCpuTime

public StoreTypes.TaskMetricDistributions.Builder setExecutorCpuTime(int index,
 double value)

repeated double executor_cpu_time = 6;

Parameters:

index - The index to set the value at.

value - The executorCpuTime to set.

Returns:

This builder for chaining.

addExecutorCpuTime

public StoreTypes.TaskMetricDistributions.Builder addExecutorCpuTime(double value)

repeated double executor_cpu_time = 6;

Parameters:

value - The executorCpuTime to add.

Returns:

This builder for chaining.

addAllExecutorCpuTime

public StoreTypes.TaskMetricDistributions.Builder addAllExecutorCpuTime(Iterable<? extends Double> values)

repeated double executor_cpu_time = 6;

Parameters:

values - The executorCpuTime to add.

Returns:

This builder for chaining.

clearExecutorCpuTime

public StoreTypes.TaskMetricDistributions.Builder clearExecutorCpuTime()

repeated double executor_cpu_time = 6;

Returns:

This builder for chaining.

getResultSizeList

public List<Double> getResultSizeList()

repeated double result_size = 7;

Specified by:

getResultSizeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the resultSize.

getResultSizeCount

public int getResultSizeCount()

repeated double result_size = 7;

Specified by:

getResultSizeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of resultSize.

getResultSize

public double getResultSize(int index)

repeated double result_size = 7;

Specified by:

getResultSize in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The resultSize at the given index.

setResultSize

public StoreTypes.TaskMetricDistributions.Builder setResultSize(int index,
 double value)

repeated double result_size = 7;

Parameters:

index - The index to set the value at.

value - The resultSize to set.

Returns:

This builder for chaining.

addResultSize

public StoreTypes.TaskMetricDistributions.Builder addResultSize(double value)

repeated double result_size = 7;

Parameters:

value - The resultSize to add.

Returns:

This builder for chaining.

addAllResultSize

public StoreTypes.TaskMetricDistributions.Builder addAllResultSize(Iterable<? extends Double> values)

repeated double result_size = 7;

Parameters:

values - The resultSize to add.

Returns:

This builder for chaining.

clearResultSize

public StoreTypes.TaskMetricDistributions.Builder clearResultSize()

repeated double result_size = 7;

Returns:

This builder for chaining.

getJvmGcTimeList

public List<Double> getJvmGcTimeList()

repeated double jvm_gc_time = 8;

Specified by:

getJvmGcTimeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the jvmGcTime.

getJvmGcTimeCount

public int getJvmGcTimeCount()

repeated double jvm_gc_time = 8;

Specified by:

getJvmGcTimeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of jvmGcTime.

getJvmGcTime

public double getJvmGcTime(int index)

repeated double jvm_gc_time = 8;

Specified by:

getJvmGcTime in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The jvmGcTime at the given index.

setJvmGcTime

public StoreTypes.TaskMetricDistributions.Builder setJvmGcTime(int index,
 double value)

repeated double jvm_gc_time = 8;

Parameters:

index - The index to set the value at.

value - The jvmGcTime to set.

Returns:

This builder for chaining.

addJvmGcTime

public StoreTypes.TaskMetricDistributions.Builder addJvmGcTime(double value)

repeated double jvm_gc_time = 8;

Parameters:

value - The jvmGcTime to add.

Returns:

This builder for chaining.

addAllJvmGcTime

public StoreTypes.TaskMetricDistributions.Builder addAllJvmGcTime(Iterable<? extends Double> values)

repeated double jvm_gc_time = 8;

Parameters:

values - The jvmGcTime to add.

Returns:

This builder for chaining.

clearJvmGcTime

public StoreTypes.TaskMetricDistributions.Builder clearJvmGcTime()

repeated double jvm_gc_time = 8;

Returns:

This builder for chaining.

getResultSerializationTimeList

public List<Double> getResultSerializationTimeList()

repeated double result_serialization_time = 9;

Specified by:

getResultSerializationTimeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the resultSerializationTime.

getResultSerializationTimeCount

public int getResultSerializationTimeCount()

repeated double result_serialization_time = 9;

Specified by:

getResultSerializationTimeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of resultSerializationTime.

getResultSerializationTime

public double getResultSerializationTime(int index)

repeated double result_serialization_time = 9;

Specified by:

getResultSerializationTime in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The resultSerializationTime at the given index.

setResultSerializationTime

public StoreTypes.TaskMetricDistributions.Builder setResultSerializationTime(int index,
 double value)

repeated double result_serialization_time = 9;

Parameters:

index - The index to set the value at.

value - The resultSerializationTime to set.

Returns:

This builder for chaining.

addResultSerializationTime

public StoreTypes.TaskMetricDistributions.Builder addResultSerializationTime(double value)

repeated double result_serialization_time = 9;

Parameters:

value - The resultSerializationTime to add.

Returns:

This builder for chaining.

addAllResultSerializationTime

public StoreTypes.TaskMetricDistributions.Builder addAllResultSerializationTime(Iterable<? extends Double> values)

repeated double result_serialization_time = 9;

Parameters:

values - The resultSerializationTime to add.

Returns:

This builder for chaining.

clearResultSerializationTime

public StoreTypes.TaskMetricDistributions.Builder clearResultSerializationTime()

repeated double result_serialization_time = 9;

Returns:

This builder for chaining.

getGettingResultTimeList

public List<Double> getGettingResultTimeList()

repeated double getting_result_time = 10;

Specified by:

getGettingResultTimeList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the gettingResultTime.

getGettingResultTimeCount

public int getGettingResultTimeCount()

repeated double getting_result_time = 10;

Specified by:

getGettingResultTimeCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of gettingResultTime.

getGettingResultTime

public double getGettingResultTime(int index)

repeated double getting_result_time = 10;

Specified by:

getGettingResultTime in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The gettingResultTime at the given index.

setGettingResultTime

public StoreTypes.TaskMetricDistributions.Builder setGettingResultTime(int index,
 double value)

repeated double getting_result_time = 10;

Parameters:

index - The index to set the value at.

value - The gettingResultTime to set.

Returns:

This builder for chaining.

addGettingResultTime

public StoreTypes.TaskMetricDistributions.Builder addGettingResultTime(double value)

repeated double getting_result_time = 10;

Parameters:

value - The gettingResultTime to add.

Returns:

This builder for chaining.

addAllGettingResultTime

public StoreTypes.TaskMetricDistributions.Builder addAllGettingResultTime(Iterable<? extends Double> values)

repeated double getting_result_time = 10;

Parameters:

values - The gettingResultTime to add.

Returns:

This builder for chaining.

clearGettingResultTime

public StoreTypes.TaskMetricDistributions.Builder clearGettingResultTime()

repeated double getting_result_time = 10;

Returns:

This builder for chaining.

getSchedulerDelayList

public List<Double> getSchedulerDelayList()

repeated double scheduler_delay = 11;

Specified by:

getSchedulerDelayList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the schedulerDelay.

getSchedulerDelayCount

public int getSchedulerDelayCount()

repeated double scheduler_delay = 11;

Specified by:

getSchedulerDelayCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of schedulerDelay.

getSchedulerDelay

public double getSchedulerDelay(int index)

repeated double scheduler_delay = 11;

Specified by:

getSchedulerDelay in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The schedulerDelay at the given index.

setSchedulerDelay

public StoreTypes.TaskMetricDistributions.Builder setSchedulerDelay(int index,
 double value)

repeated double scheduler_delay = 11;

Parameters:

index - The index to set the value at.

value - The schedulerDelay to set.

Returns:

This builder for chaining.

addSchedulerDelay

public StoreTypes.TaskMetricDistributions.Builder addSchedulerDelay(double value)

repeated double scheduler_delay = 11;

Parameters:

value - The schedulerDelay to add.

Returns:

This builder for chaining.

addAllSchedulerDelay

public StoreTypes.TaskMetricDistributions.Builder addAllSchedulerDelay(Iterable<? extends Double> values)

repeated double scheduler_delay = 11;

Parameters:

values - The schedulerDelay to add.

Returns:

This builder for chaining.

clearSchedulerDelay

public StoreTypes.TaskMetricDistributions.Builder clearSchedulerDelay()

repeated double scheduler_delay = 11;

Returns:

This builder for chaining.

getPeakExecutionMemoryList

public List<Double> getPeakExecutionMemoryList()

repeated double peak_execution_memory = 12;

Specified by:

getPeakExecutionMemoryList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the peakExecutionMemory.

getPeakExecutionMemoryCount

public int getPeakExecutionMemoryCount()

repeated double peak_execution_memory = 12;

Specified by:

getPeakExecutionMemoryCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of peakExecutionMemory.

getPeakExecutionMemory

public double getPeakExecutionMemory(int index)

repeated double peak_execution_memory = 12;

Specified by:

getPeakExecutionMemory in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The peakExecutionMemory at the given index.

setPeakExecutionMemory

public StoreTypes.TaskMetricDistributions.Builder setPeakExecutionMemory(int index,
 double value)

repeated double peak_execution_memory = 12;

Parameters:

index - The index to set the value at.

value - The peakExecutionMemory to set.

Returns:

This builder for chaining.

addPeakExecutionMemory

public StoreTypes.TaskMetricDistributions.Builder addPeakExecutionMemory(double value)

repeated double peak_execution_memory = 12;

Parameters:

value - The peakExecutionMemory to add.

Returns:

This builder for chaining.

addAllPeakExecutionMemory

public StoreTypes.TaskMetricDistributions.Builder addAllPeakExecutionMemory(Iterable<? extends Double> values)

repeated double peak_execution_memory = 12;

Parameters:

values - The peakExecutionMemory to add.

Returns:

This builder for chaining.

clearPeakExecutionMemory

public StoreTypes.TaskMetricDistributions.Builder clearPeakExecutionMemory()

repeated double peak_execution_memory = 12;

Returns:

This builder for chaining.

getMemoryBytesSpilledList

public List<Double> getMemoryBytesSpilledList()

repeated double memory_bytes_spilled = 13;

Specified by:

getMemoryBytesSpilledList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the memoryBytesSpilled.

getMemoryBytesSpilledCount

public int getMemoryBytesSpilledCount()

repeated double memory_bytes_spilled = 13;

Specified by:

getMemoryBytesSpilledCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of memoryBytesSpilled.

getMemoryBytesSpilled

public double getMemoryBytesSpilled(int index)

repeated double memory_bytes_spilled = 13;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The memoryBytesSpilled at the given index.

setMemoryBytesSpilled

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

repeated double memory_bytes_spilled = 13;

Parameters:

index - The index to set the value at.

value - The memoryBytesSpilled to set.

Returns:

This builder for chaining.

addMemoryBytesSpilled

public StoreTypes.TaskMetricDistributions.Builder addMemoryBytesSpilled(double value)

repeated double memory_bytes_spilled = 13;

Parameters:

value - The memoryBytesSpilled to add.

Returns:

This builder for chaining.

addAllMemoryBytesSpilled

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

repeated double memory_bytes_spilled = 13;

Parameters:

values - The memoryBytesSpilled to add.

Returns:

This builder for chaining.

clearMemoryBytesSpilled

public StoreTypes.TaskMetricDistributions.Builder clearMemoryBytesSpilled()

repeated double memory_bytes_spilled = 13;

Returns:

This builder for chaining.

getDiskBytesSpilledList

public List<Double> getDiskBytesSpilledList()

repeated double disk_bytes_spilled = 14;

Specified by:

getDiskBytesSpilledList in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

A list containing the diskBytesSpilled.

getDiskBytesSpilledCount

public int getDiskBytesSpilledCount()

repeated double disk_bytes_spilled = 14;

Specified by:

getDiskBytesSpilledCount in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The count of diskBytesSpilled.

getDiskBytesSpilled

public double getDiskBytesSpilled(int index)

repeated double disk_bytes_spilled = 14;

Specified by:

getDiskBytesSpilled in interface StoreTypes.TaskMetricDistributionsOrBuilder

Parameters:

index - The index of the element to return.

Returns:

The diskBytesSpilled at the given index.

setDiskBytesSpilled

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

repeated double disk_bytes_spilled = 14;

Parameters:

index - The index to set the value at.

value - The diskBytesSpilled to set.

Returns:

This builder for chaining.

addDiskBytesSpilled

public StoreTypes.TaskMetricDistributions.Builder addDiskBytesSpilled(double value)

repeated double disk_bytes_spilled = 14;

Parameters:

value - The diskBytesSpilled to add.

Returns:

This builder for chaining.

addAllDiskBytesSpilled

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

repeated double disk_bytes_spilled = 14;

Parameters:

values - The diskBytesSpilled to add.

Returns:

This builder for chaining.

clearDiskBytesSpilled

public StoreTypes.TaskMetricDistributions.Builder clearDiskBytesSpilled()

repeated double disk_bytes_spilled = 14;

Returns:

This builder for chaining.

hasInputMetrics

public boolean hasInputMetrics()

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

Specified by:

hasInputMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

Whether the inputMetrics field is set.

getInputMetrics

public StoreTypes.InputMetricDistributions getInputMetrics()

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

Specified by:

getInputMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The inputMetrics.

setInputMetrics

public StoreTypes.TaskMetricDistributions.Builder setInputMetrics(StoreTypes.InputMetricDistributions value)

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

setInputMetrics

public StoreTypes.TaskMetricDistributions.Builder setInputMetrics(StoreTypes.InputMetricDistributions.Builder builderForValue)

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

mergeInputMetrics

public StoreTypes.TaskMetricDistributions.Builder mergeInputMetrics(StoreTypes.InputMetricDistributions value)

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

clearInputMetrics

public StoreTypes.TaskMetricDistributions.Builder clearInputMetrics()

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

getInputMetricsBuilder

public StoreTypes.InputMetricDistributions.Builder getInputMetricsBuilder()

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

getInputMetricsOrBuilder

public StoreTypes.InputMetricDistributionsOrBuilder getInputMetricsOrBuilder()

.org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

Specified by:

getInputMetricsOrBuilder in interface StoreTypes.TaskMetricDistributionsOrBuilder

hasOutputMetrics

public boolean hasOutputMetrics()

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

Specified by:

hasOutputMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

Whether the outputMetrics field is set.

getOutputMetrics

public StoreTypes.OutputMetricDistributions getOutputMetrics()

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

Specified by:

getOutputMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The outputMetrics.

setOutputMetrics

public StoreTypes.TaskMetricDistributions.Builder setOutputMetrics(StoreTypes.OutputMetricDistributions value)

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

setOutputMetrics

public StoreTypes.TaskMetricDistributions.Builder setOutputMetrics(StoreTypes.OutputMetricDistributions.Builder builderForValue)

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

mergeOutputMetrics

public StoreTypes.TaskMetricDistributions.Builder mergeOutputMetrics(StoreTypes.OutputMetricDistributions value)

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

clearOutputMetrics

public StoreTypes.TaskMetricDistributions.Builder clearOutputMetrics()

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

getOutputMetricsBuilder

public StoreTypes.OutputMetricDistributions.Builder getOutputMetricsBuilder()

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

getOutputMetricsOrBuilder

public StoreTypes.OutputMetricDistributionsOrBuilder getOutputMetricsOrBuilder()

.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

Specified by:

getOutputMetricsOrBuilder in interface StoreTypes.TaskMetricDistributionsOrBuilder

hasShuffleReadMetrics

public boolean hasShuffleReadMetrics()

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

Specified by:

hasShuffleReadMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

Whether the shuffleReadMetrics field is set.

getShuffleReadMetrics

public StoreTypes.ShuffleReadMetricDistributions getShuffleReadMetrics()

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

Specified by:

getShuffleReadMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The shuffleReadMetrics.

setShuffleReadMetrics

public StoreTypes.TaskMetricDistributions.Builder setShuffleReadMetrics(StoreTypes.ShuffleReadMetricDistributions value)

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

setShuffleReadMetrics

public StoreTypes.TaskMetricDistributions.Builder setShuffleReadMetrics(StoreTypes.ShuffleReadMetricDistributions.Builder builderForValue)

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

mergeShuffleReadMetrics

public StoreTypes.TaskMetricDistributions.Builder mergeShuffleReadMetrics(StoreTypes.ShuffleReadMetricDistributions value)

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

clearShuffleReadMetrics

public StoreTypes.TaskMetricDistributions.Builder clearShuffleReadMetrics()

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

getShuffleReadMetricsBuilder

public StoreTypes.ShuffleReadMetricDistributions.Builder getShuffleReadMetricsBuilder()

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

getShuffleReadMetricsOrBuilder

public StoreTypes.ShuffleReadMetricDistributionsOrBuilder getShuffleReadMetricsOrBuilder()

.org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

Specified by:

getShuffleReadMetricsOrBuilder in interface StoreTypes.TaskMetricDistributionsOrBuilder

hasShuffleWriteMetrics

public boolean hasShuffleWriteMetrics()

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

Specified by:

hasShuffleWriteMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

Whether the shuffleWriteMetrics field is set.

getShuffleWriteMetrics

public StoreTypes.ShuffleWriteMetricDistributions getShuffleWriteMetrics()

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

Specified by:

getShuffleWriteMetrics in interface StoreTypes.TaskMetricDistributionsOrBuilder

Returns:

The shuffleWriteMetrics.

setShuffleWriteMetrics

public StoreTypes.TaskMetricDistributions.Builder setShuffleWriteMetrics(StoreTypes.ShuffleWriteMetricDistributions value)

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

setShuffleWriteMetrics

public StoreTypes.TaskMetricDistributions.Builder setShuffleWriteMetrics(StoreTypes.ShuffleWriteMetricDistributions.Builder builderForValue)

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

mergeShuffleWriteMetrics

public StoreTypes.TaskMetricDistributions.Builder mergeShuffleWriteMetrics(StoreTypes.ShuffleWriteMetricDistributions value)

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

clearShuffleWriteMetrics

public StoreTypes.TaskMetricDistributions.Builder clearShuffleWriteMetrics()

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

getShuffleWriteMetricsBuilder

public StoreTypes.ShuffleWriteMetricDistributions.Builder getShuffleWriteMetricsBuilder()

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

getShuffleWriteMetricsOrBuilder

public StoreTypes.ShuffleWriteMetricDistributionsOrBuilder getShuffleWriteMetricsOrBuilder()

.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;

Specified by:

getShuffleWriteMetricsOrBuilder in interface StoreTypes.TaskMetricDistributionsOrBuilder

setUnknownFields

public final StoreTypes.TaskMetricDistributions.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

Specified by:

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

Overrides:

setUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>

mergeUnknownFields

public final StoreTypes.TaskMetricDistributions.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

Specified by:

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

Overrides:

mergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskMetricDistributions.Builder>