Package org.apache.spark.status.protobuf

Class StoreTypes.TaskMetrics

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

org.apache.spark.status.protobuf.StoreTypes.TaskMetrics

All Implemented Interfaces:

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

Enclosing class:

StoreTypes

public static final class StoreTypes.TaskMetrics
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.TaskMetricsOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

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	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	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	RESULT_SERIALIZATION_TIME_FIELD_NUMBER
static final int	RESULT_SIZE_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.TaskMetrics	getDefaultInstance()
StoreTypes.TaskMetrics	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
long	getDiskBytesSpilled()	int64 disk_bytes_spilled = 9;
long	getExecutorCpuTime()	int64 executor_cpu_time = 4;
long	getExecutorDeserializeCpuTime()	int64 executor_deserialize_cpu_time = 2;
long	getExecutorDeserializeTime()	int64 executor_deserialize_time = 1;
long	getExecutorRunTime()	int64 executor_run_time = 3;
StoreTypes.InputMetrics	getInputMetrics()	.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
StoreTypes.InputMetricsOrBuilder	getInputMetricsOrBuilder()	.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
long	getJvmGcTime()	int64 jvm_gc_time = 6;
long	getMemoryBytesSpilled()	int64 memory_bytes_spilled = 8;
StoreTypes.OutputMetrics	getOutputMetrics()	.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
StoreTypes.OutputMetricsOrBuilder	getOutputMetricsOrBuilder()	.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
com.google.protobuf.Parser<StoreTypes.TaskMetrics>	getParserForType()
long	getPeakExecutionMemory()	int64 peak_execution_memory = 10;
long	getResultSerializationTime()	int64 result_serialization_time = 7;
long	getResultSize()	int64 result_size = 5;
int	getSerializedSize()
StoreTypes.ShuffleReadMetrics	getShuffleReadMetrics()	.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
StoreTypes.ShuffleReadMetricsOrBuilder	getShuffleReadMetricsOrBuilder()	.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
StoreTypes.ShuffleWriteMetrics	getShuffleWriteMetrics()	.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
StoreTypes.ShuffleWriteMetricsOrBuilder	getShuffleWriteMetricsOrBuilder()	.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
int	hashCode()
boolean	hasInputMetrics()	.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
boolean	hasOutputMetrics()	.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
boolean	hasShuffleReadMetrics()	.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
boolean	hasShuffleWriteMetrics()	.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
final boolean	isInitialized()
static StoreTypes.TaskMetrics.Builder	newBuilder()
static StoreTypes.TaskMetrics.Builder	newBuilder(StoreTypes.TaskMetrics prototype)
StoreTypes.TaskMetrics.Builder	newBuilderForType()
static StoreTypes.TaskMetrics	parseDelimitedFrom(InputStream input)
static StoreTypes.TaskMetrics	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetrics	parseFrom(byte[] data)
static StoreTypes.TaskMetrics	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetrics	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.TaskMetrics	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetrics	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.TaskMetrics	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetrics	parseFrom(InputStream input)
static StoreTypes.TaskMetrics	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskMetrics	parseFrom(ByteBuffer data)
static StoreTypes.TaskMetrics	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.TaskMetrics>	parser()
StoreTypes.TaskMetrics.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

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

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_EXECUTION_MEMORY_FIELD_NUMBER

public static final int PEAK_EXECUTION_MEMORY_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()

getExecutorDeserializeTime

public long getExecutorDeserializeTime()

int64 executor_deserialize_time = 1;

Specified by:

getExecutorDeserializeTime in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The executorDeserializeTime.

getExecutorDeserializeCpuTime

public long getExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 2;

Specified by:

getExecutorDeserializeCpuTime in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The executorDeserializeCpuTime.

getExecutorRunTime

public long getExecutorRunTime()

int64 executor_run_time = 3;

Specified by:

getExecutorRunTime in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The executorRunTime.

getExecutorCpuTime

public long getExecutorCpuTime()

int64 executor_cpu_time = 4;

Specified by:

getExecutorCpuTime in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The executorCpuTime.

getResultSize

public long getResultSize()

int64 result_size = 5;

Specified by:

getResultSize in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The resultSize.

getJvmGcTime

public long getJvmGcTime()

int64 jvm_gc_time = 6;

Specified by:

getJvmGcTime in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The jvmGcTime.

getResultSerializationTime

public long getResultSerializationTime()

int64 result_serialization_time = 7;

Specified by:

getResultSerializationTime in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The resultSerializationTime.

getMemoryBytesSpilled

public long getMemoryBytesSpilled()

int64 memory_bytes_spilled = 8;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The memoryBytesSpilled.

getDiskBytesSpilled

public long getDiskBytesSpilled()

int64 disk_bytes_spilled = 9;

Specified by:

getDiskBytesSpilled in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The diskBytesSpilled.

getPeakExecutionMemory

public long getPeakExecutionMemory()

int64 peak_execution_memory = 10;

Specified by:

getPeakExecutionMemory in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The peakExecutionMemory.

hasInputMetrics

public boolean hasInputMetrics()

.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;

Specified by:

hasInputMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

Whether the inputMetrics field is set.

getInputMetrics

public StoreTypes.InputMetrics getInputMetrics()

.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;

Specified by:

getInputMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The inputMetrics.

getInputMetricsOrBuilder

public StoreTypes.InputMetricsOrBuilder getInputMetricsOrBuilder()

.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;

Specified by:

getInputMetricsOrBuilder in interface StoreTypes.TaskMetricsOrBuilder

hasOutputMetrics

public boolean hasOutputMetrics()

.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;

Specified by:

hasOutputMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

Whether the outputMetrics field is set.

getOutputMetrics

public StoreTypes.OutputMetrics getOutputMetrics()

.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;

Specified by:

getOutputMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The outputMetrics.

getOutputMetricsOrBuilder

public StoreTypes.OutputMetricsOrBuilder getOutputMetricsOrBuilder()

.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;

Specified by:

getOutputMetricsOrBuilder in interface StoreTypes.TaskMetricsOrBuilder

hasShuffleReadMetrics

public boolean hasShuffleReadMetrics()

.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;

Specified by:

hasShuffleReadMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

Whether the shuffleReadMetrics field is set.

getShuffleReadMetrics

public StoreTypes.ShuffleReadMetrics getShuffleReadMetrics()

.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;

Specified by:

getShuffleReadMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The shuffleReadMetrics.

getShuffleReadMetricsOrBuilder

public StoreTypes.ShuffleReadMetricsOrBuilder getShuffleReadMetricsOrBuilder()

.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;

Specified by:

getShuffleReadMetricsOrBuilder in interface StoreTypes.TaskMetricsOrBuilder

hasShuffleWriteMetrics

public boolean hasShuffleWriteMetrics()

.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;

Specified by:

hasShuffleWriteMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

Whether the shuffleWriteMetrics field is set.

getShuffleWriteMetrics

public StoreTypes.ShuffleWriteMetrics getShuffleWriteMetrics()

.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;

Specified by:

getShuffleWriteMetrics in interface StoreTypes.TaskMetricsOrBuilder

Returns:

The shuffleWriteMetrics.

getShuffleWriteMetricsOrBuilder

public StoreTypes.ShuffleWriteMetricsOrBuilder getShuffleWriteMetricsOrBuilder()

.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;

Specified by:

getShuffleWriteMetricsOrBuilder in interface StoreTypes.TaskMetricsOrBuilder

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

newBuilderForType

public StoreTypes.TaskMetrics.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.TaskMetrics.Builder newBuilder()

newBuilder

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

toBuilder

public StoreTypes.TaskMetrics.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.TaskMetrics getDefaultInstance()

parser

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

getParserForType

public com.google.protobuf.Parser<StoreTypes.TaskMetrics> 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.TaskMetrics getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder