Package org.apache.spark.status.protobuf

Class StoreTypes.TaskMetricDistributions

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

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

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Serializable, StoreTypes.TaskMetricDistributionsOrBuilder

Enclosing class:

StoreTypes

public static final class StoreTypes.TaskMetricDistributions
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.TaskMetricDistributionsOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	StoreTypes.TaskMetricDistributions.Builder	Protobuf type org.apache.spark.status.protobuf.TaskMetricDistributions

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage

com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT,BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message,T extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DISK_BYTES_SPILLED_FIELD_NUMBER
static final int	DURATION_FIELD_NUMBER
static final int	EXECUTOR_CPU_TIME_FIELD_NUMBER
static final int	EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER
static final int	EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER
static final int	EXECUTOR_RUN_TIME_FIELD_NUMBER
static final int	GETTING_RESULT_TIME_FIELD_NUMBER
static final int	INPUT_METRICS_FIELD_NUMBER
static final int	JVM_GC_TIME_FIELD_NUMBER
static final int	MEMORY_BYTES_SPILLED_FIELD_NUMBER
static final int	OUTPUT_METRICS_FIELD_NUMBER
static final int	PEAK_EXECUTION_MEMORY_FIELD_NUMBER
static final int	QUANTILES_FIELD_NUMBER
static final int	RESULT_SERIALIZATION_TIME_FIELD_NUMBER
static final int	RESULT_SIZE_FIELD_NUMBER
static final int	SCHEDULER_DELAY_FIELD_NUMBER
static final int	SHUFFLE_READ_METRICS_FIELD_NUMBER
static final int	SHUFFLE_WRITE_METRICS_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
static StoreTypes.TaskMetricDistributions	getDefaultInstance()
StoreTypes.TaskMetricDistributions	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
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.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.OutputMetricDistributionsOrBuilder	getOutputMetricsOrBuilder()	.org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
com.google.protobuf.Parser<StoreTypes.TaskMetricDistributions>	getParserForType()
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;
int	getSerializedSize()
StoreTypes.ShuffleReadMetricDistributions	getShuffleReadMetrics()	.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.ShuffleWriteMetricDistributionsOrBuilder	getShuffleWriteMetricsOrBuilder()	.org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
int	hashCode()
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()
static StoreTypes.TaskMetricDistributions.Builder	newBuilder()
static StoreTypes.TaskMetricDistributions.Builder	newBuilder(StoreTypes.TaskMetricDistributions prototype)
StoreTypes.TaskMetricDistributions.Builder	newBuilderForType()
static StoreTypes.TaskMetricDistributions	parseDelimitedFrom(InputStream input)
static StoreTypes.TaskMetricDistributions	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetricDistributions	parseFrom(byte[] data)
static StoreTypes.TaskMetricDistributions	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetricDistributions	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.TaskMetricDistributions	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetricDistributions	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.TaskMetricDistributions	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetricDistributions	parseFrom(InputStream input)
static StoreTypes.TaskMetricDistributions	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetricDistributions	parseFrom(ByteBuffer data)
static StoreTypes.TaskMetricDistributions	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.TaskMetricDistributions>	parser()
StoreTypes.TaskMetricDistributions.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessage

getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtension

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Field Details

QUANTILES_FIELD_NUMBER

public static final int QUANTILES_FIELD_NUMBER

See Also:

• Constant Field Values

DURATION_FIELD_NUMBER

public static final int DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

public static final int EXECUTOR_DESERIALIZE_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

public static final int EXECUTOR_DESERIALIZE_CPU_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_RUN_TIME_FIELD_NUMBER

public static final int EXECUTOR_RUN_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_CPU_TIME_FIELD_NUMBER

public static final int EXECUTOR_CPU_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

RESULT_SIZE_FIELD_NUMBER

public static final int RESULT_SIZE_FIELD_NUMBER

See Also:

• Constant Field Values

JVM_GC_TIME_FIELD_NUMBER

public static final int JVM_GC_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

RESULT_SERIALIZATION_TIME_FIELD_NUMBER

public static final int RESULT_SERIALIZATION_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

GETTING_RESULT_TIME_FIELD_NUMBER

public static final int GETTING_RESULT_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SCHEDULER_DELAY_FIELD_NUMBER

public static final int SCHEDULER_DELAY_FIELD_NUMBER

See Also:

• Constant Field Values

PEAK_EXECUTION_MEMORY_FIELD_NUMBER

public static final int PEAK_EXECUTION_MEMORY_FIELD_NUMBER

See Also:

• Constant Field Values

MEMORY_BYTES_SPILLED_FIELD_NUMBER

public static final int MEMORY_BYTES_SPILLED_FIELD_NUMBER

See Also:

• Constant Field Values

DISK_BYTES_SPILLED_FIELD_NUMBER

public static final int DISK_BYTES_SPILLED_FIELD_NUMBER

See Also:

• Constant Field Values

INPUT_METRICS_FIELD_NUMBER

public static final int INPUT_METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

OUTPUT_METRICS_FIELD_NUMBER

public static final int OUTPUT_METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_READ_METRICS_FIELD_NUMBER

public static final int SHUFFLE_READ_METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_METRICS_FIELD_NUMBER

public static final int SHUFFLE_WRITE_METRICS_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

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

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

getShuffleWriteMetricsOrBuilder

public StoreTypes.ShuffleWriteMetricDistributionsOrBuilder getShuffleWriteMetricsOrBuilder()

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

Specified by:

getShuffleWriteMetricsOrBuilder in interface StoreTypes.TaskMetricDistributionsOrBuilder

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage

writeTo

public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws IOException

Specified by:

writeTo in interface com.google.protobuf.MessageLite

Overrides:

writeTo in class com.google.protobuf.GeneratedMessage

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessage

equals

public boolean equals(Object obj)

Specified by:

equals in interface com.google.protobuf.Message

Overrides:

equals in class com.google.protobuf.AbstractMessage

hashCode

public int hashCode()

Specified by:

hashCode in interface com.google.protobuf.Message

Overrides:

hashCode in class com.google.protobuf.AbstractMessage

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(ByteBuffer data)
                                                    throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(ByteBuffer data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(com.google.protobuf.ByteString data)
                                                    throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(com.google.protobuf.ByteString data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(byte[] data)
                                                    throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(byte[] data,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(InputStream input)
                                                    throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.TaskMetricDistributions parseDelimitedFrom(InputStream input)
                                                             throws IOException

Throws:

IOException

parseDelimitedFrom

public static StoreTypes.TaskMetricDistributions parseDelimitedFrom(InputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                             throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(com.google.protobuf.CodedInputStream input)
                                                    throws IOException

Throws:

IOException

parseFrom

public static StoreTypes.TaskMetricDistributions parseFrom(com.google.protobuf.CodedInputStream input,
 com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws IOException

Throws:

IOException

newBuilderForType

public StoreTypes.TaskMetricDistributions.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.TaskMetricDistributions.Builder newBuilder()

newBuilder

public static StoreTypes.TaskMetricDistributions.Builder newBuilder(StoreTypes.TaskMetricDistributions prototype)

toBuilder

public StoreTypes.TaskMetricDistributions.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.TaskMetricDistributions getDefaultInstance()

parser

public static com.google.protobuf.Parser<StoreTypes.TaskMetricDistributions> parser()

getParserForType

public com.google.protobuf.Parser<StoreTypes.TaskMetricDistributions> getParserForType()

Specified by:

getParserForType in interface com.google.protobuf.Message

Specified by:

getParserForType in interface com.google.protobuf.MessageLite

Overrides:

getParserForType in class com.google.protobuf.GeneratedMessage

getDefaultInstanceForType

public StoreTypes.TaskMetricDistributions getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder