Package org.apache.spark.status.protobuf

Class StoreTypes.ExecutorStageSummary

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessage

org.apache.spark.status.protobuf.StoreTypes.ExecutorStageSummary

All Implemented Interfaces:

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

Enclosing class:

StoreTypes

public static final class StoreTypes.ExecutorStageSummary
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.ExecutorStageSummaryOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

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	FAILED_TASKS_FIELD_NUMBER
static final int	INPUT_BYTES_FIELD_NUMBER
static final int	INPUT_RECORDS_FIELD_NUMBER
static final int	IS_BLACKLISTED_FOR_STAGE_FIELD_NUMBER
static final int	IS_EXCLUDED_FOR_STAGE_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	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.ExecutorStageSummary	getDefaultInstance()
StoreTypes.ExecutorStageSummary	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
long	getDiskBytesSpilled()	int64 disk_bytes_spilled = 14;
int	getFailedTasks()	int32 failed_tasks = 2;
long	getInputBytes()	int64 input_bytes = 5;
long	getInputRecords()	int64 input_records = 6;
boolean	getIsBlacklistedForStage()	bool is_blacklisted_for_stage = 15;
boolean	getIsExcludedForStage()	bool is_excluded_for_stage = 17;
int	getKilledTasks()	int32 killed_tasks = 4;
long	getMemoryBytesSpilled()	int64 memory_bytes_spilled = 13;
long	getOutputBytes()	int64 output_bytes = 7;
long	getOutputRecords()	int64 output_records = 8;
com.google.protobuf.Parser<StoreTypes.ExecutorStageSummary>	getParserForType()
StoreTypes.ExecutorMetrics	getPeakMemoryMetrics()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
StoreTypes.ExecutorMetricsOrBuilder	getPeakMemoryMetricsOrBuilder()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
int	getSerializedSize()
long	getShuffleRead()	int64 shuffle_read = 9;
long	getShuffleReadRecords()	int64 shuffle_read_records = 10;
long	getShuffleWrite()	int64 shuffle_write = 11;
long	getShuffleWriteRecords()	int64 shuffle_write_records = 12;
int	getSucceededTasks()	int32 succeeded_tasks = 3;
long	getTaskTime()	int64 task_time = 1;
int	hashCode()
boolean	hasPeakMemoryMetrics()	optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
final boolean	isInitialized()
static StoreTypes.ExecutorStageSummary.Builder	newBuilder()
static StoreTypes.ExecutorStageSummary.Builder	newBuilder(StoreTypes.ExecutorStageSummary prototype)
StoreTypes.ExecutorStageSummary.Builder	newBuilderForType()
static StoreTypes.ExecutorStageSummary	parseDelimitedFrom(InputStream input)
static StoreTypes.ExecutorStageSummary	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorStageSummary	parseFrom(byte[] data)
static StoreTypes.ExecutorStageSummary	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorStageSummary	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.ExecutorStageSummary	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorStageSummary	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.ExecutorStageSummary	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorStageSummary	parseFrom(InputStream input)
static StoreTypes.ExecutorStageSummary	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.ExecutorStageSummary	parseFrom(ByteBuffer data)
static StoreTypes.ExecutorStageSummary	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.ExecutorStageSummary>	parser()
StoreTypes.ExecutorStageSummary.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

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

IS_BLACKLISTED_FOR_STAGE_FIELD_NUMBER

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

IS_EXCLUDED_FOR_STAGE_FIELD_NUMBER

public static final int IS_EXCLUDED_FOR_STAGE_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

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

getTaskTime

public long getTaskTime()

int64 task_time = 1;

Specified by:

getTaskTime in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The taskTime.

getFailedTasks

public int getFailedTasks()

int32 failed_tasks = 2;

Specified by:

getFailedTasks in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The failedTasks.

getSucceededTasks

public int getSucceededTasks()

int32 succeeded_tasks = 3;

Specified by:

getSucceededTasks in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The succeededTasks.

getKilledTasks

public int getKilledTasks()

int32 killed_tasks = 4;

Specified by:

getKilledTasks in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The killedTasks.

getInputBytes

public long getInputBytes()

int64 input_bytes = 5;

Specified by:

getInputBytes in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The inputBytes.

getInputRecords

public long getInputRecords()

int64 input_records = 6;

Specified by:

getInputRecords in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The inputRecords.

getOutputBytes

public long getOutputBytes()

int64 output_bytes = 7;

Specified by:

getOutputBytes in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The outputBytes.

getOutputRecords

public long getOutputRecords()

int64 output_records = 8;

Specified by:

getOutputRecords in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The outputRecords.

getShuffleRead

public long getShuffleRead()

int64 shuffle_read = 9;

Specified by:

getShuffleRead in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The shuffleRead.

getShuffleReadRecords

public long getShuffleReadRecords()

int64 shuffle_read_records = 10;

Specified by:

getShuffleReadRecords in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The shuffleReadRecords.

getShuffleWrite

public long getShuffleWrite()

int64 shuffle_write = 11;

Specified by:

getShuffleWrite in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The shuffleWrite.

getShuffleWriteRecords

public long getShuffleWriteRecords()

int64 shuffle_write_records = 12;

Specified by:

getShuffleWriteRecords in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The shuffleWriteRecords.

getMemoryBytesSpilled

public long getMemoryBytesSpilled()

int64 memory_bytes_spilled = 13;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The memoryBytesSpilled.

getDiskBytesSpilled

public long getDiskBytesSpilled()

int64 disk_bytes_spilled = 14;

Specified by:

getDiskBytesSpilled in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The diskBytesSpilled.

getIsBlacklistedForStage

public boolean getIsBlacklistedForStage()

bool is_blacklisted_for_stage = 15;

Specified by:

getIsBlacklistedForStage in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The isBlacklistedForStage.

hasPeakMemoryMetrics

public boolean hasPeakMemoryMetrics()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;

Specified by:

hasPeakMemoryMetrics in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

Whether the peakMemoryMetrics field is set.

getPeakMemoryMetrics

public StoreTypes.ExecutorMetrics getPeakMemoryMetrics()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;

Specified by:

getPeakMemoryMetrics in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The peakMemoryMetrics.

getPeakMemoryMetricsOrBuilder

public StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()

optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;

Specified by:

getPeakMemoryMetricsOrBuilder in interface StoreTypes.ExecutorStageSummaryOrBuilder

getIsExcludedForStage

public boolean getIsExcludedForStage()

bool is_excluded_for_stage = 17;

Specified by:

getIsExcludedForStage in interface StoreTypes.ExecutorStageSummaryOrBuilder

Returns:

The isExcludedForStage.

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

newBuilderForType

public StoreTypes.ExecutorStageSummary.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.ExecutorStageSummary.Builder newBuilder()

newBuilder

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

toBuilder

public StoreTypes.ExecutorStageSummary.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.ExecutorStageSummary getDefaultInstance()

parser

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

getParserForType

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

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder