Package org.apache.spark.status.protobuf

Class StoreTypes.ExecutorMetricsDistributions

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessageV3

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

All Implemented Interfaces:

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

Enclosing class:

StoreTypes

public static final class StoreTypes.ExecutorMetricsDistributions
extends com.google.protobuf.GeneratedMessageV3
implements StoreTypes.ExecutorMetricsDistributionsOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

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

com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DISK_BYTES_SPILLED_FIELD_NUMBER
static final int	FAILED_TASKS_FIELD_NUMBER
static final int	INPUT_BYTES_FIELD_NUMBER
static final int	INPUT_RECORDS_FIELD_NUMBER
static final int	KILLED_TASKS_FIELD_NUMBER
static final int	MEMORY_BYTES_SPILLED_FIELD_NUMBER
static final int	OUTPUT_BYTES_FIELD_NUMBER
static final int	OUTPUT_RECORDS_FIELD_NUMBER
static final int	PEAK_MEMORY_METRICS_FIELD_NUMBER
static final int	QUANTILES_FIELD_NUMBER
static final int	SHUFFLE_READ_FIELD_NUMBER
static final int	SHUFFLE_READ_RECORDS_FIELD_NUMBER
static final int	SHUFFLE_WRITE_FIELD_NUMBER
static final int	SHUFFLE_WRITE_RECORDS_FIELD_NUMBER
static final int	SUCCEEDED_TASKS_FIELD_NUMBER
static final int	TASK_TIME_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
static StoreTypes.ExecutorMetricsDistributions	getDefaultInstance()
StoreTypes.ExecutorMetricsDistributions	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
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;
com.google.protobuf.Parser<StoreTypes.ExecutorMetricsDistributions>	getParserForType()
StoreTypes.ExecutorPeakMetricsDistributions	getPeakMemoryMetrics()	.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;
int	getSerializedSize()
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;
int	hashCode()
boolean	hasPeakMemoryMetrics()	.org.apache.spark.status.protobuf.ExecutorPeakMetricsDistributions peak_memory_metrics = 16;
final boolean	isInitialized()
static StoreTypes.ExecutorMetricsDistributions.Builder	newBuilder()
static StoreTypes.ExecutorMetricsDistributions.Builder	newBuilder(StoreTypes.ExecutorMetricsDistributions prototype)
StoreTypes.ExecutorMetricsDistributions.Builder	newBuilderForType()
static StoreTypes.ExecutorMetricsDistributions	parseDelimitedFrom(InputStream input)
static StoreTypes.ExecutorMetricsDistributions	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(byte[] data)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(InputStream input)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(ByteBuffer data)
static StoreTypes.ExecutorMetricsDistributions	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.ExecutorMetricsDistributions>	parser()
StoreTypes.ExecutorMetricsDistributions.Builder	toBuilder()
void	writeTo(com.google.protobuf.CodedOutputStream output)

Methods inherited from class com.google.protobuf.GeneratedMessageV3

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

Methods inherited from class com.google.protobuf.AbstractMessage

findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite

toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from 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

TASK_TIME_FIELD_NUMBER

public static final int TASK_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

FAILED_TASKS_FIELD_NUMBER

public static final int FAILED_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

SUCCEEDED_TASKS_FIELD_NUMBER

public static final int SUCCEEDED_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

KILLED_TASKS_FIELD_NUMBER

public static final int KILLED_TASKS_FIELD_NUMBER

See Also:

• Constant Field Values

INPUT_BYTES_FIELD_NUMBER

public static final int INPUT_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

INPUT_RECORDS_FIELD_NUMBER

public static final int INPUT_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

OUTPUT_BYTES_FIELD_NUMBER

public static final int OUTPUT_BYTES_FIELD_NUMBER

See Also:

• Constant Field Values

OUTPUT_RECORDS_FIELD_NUMBER

public static final int OUTPUT_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_READ_FIELD_NUMBER

public static final int SHUFFLE_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_READ_RECORDS_FIELD_NUMBER

public static final int SHUFFLE_READ_RECORDS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_FIELD_NUMBER

public static final int SHUFFLE_WRITE_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_RECORDS_FIELD_NUMBER

public static final int SHUFFLE_WRITE_RECORDS_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

PEAK_MEMORY_METRICS_FIELD_NUMBER

public static final int PEAK_MEMORY_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.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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

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.

getPeakMemoryMetricsOrBuilder

public StoreTypes.ExecutorPeakMetricsDistributionsOrBuilder getPeakMemoryMetricsOrBuilder()

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

Specified by:

getPeakMemoryMetricsOrBuilder in interface StoreTypes.ExecutorMetricsDistributionsOrBuilder

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessageV3

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.GeneratedMessageV3

Throws:

IOException

getSerializedSize

public int getSerializedSize()

Specified by:

getSerializedSize in interface com.google.protobuf.MessageLite

Overrides:

getSerializedSize in class com.google.protobuf.GeneratedMessageV3

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.ExecutorMetricsDistributions parseFrom(ByteBuffer data)
                                                         throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

public static StoreTypes.ExecutorMetricsDistributions 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.ExecutorMetricsDistributions parseFrom(byte[] data)
                                                         throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

newBuilderForType

public StoreTypes.ExecutorMetricsDistributions.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.ExecutorMetricsDistributions.Builder newBuilder()

newBuilder

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

toBuilder

public StoreTypes.ExecutorMetricsDistributions.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.ExecutorMetricsDistributions getDefaultInstance()

parser

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

getParserForType

public com.google.protobuf.Parser<StoreTypes.ExecutorMetricsDistributions> 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.GeneratedMessageV3

getDefaultInstanceForType

public StoreTypes.ExecutorMetricsDistributions getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder