Package org.apache.spark.status.protobuf

Class StoreTypes.TaskDataWrapper

Object

com.google.protobuf.AbstractMessageLite

com.google.protobuf.AbstractMessage

com.google.protobuf.GeneratedMessageV3

org.apache.spark.status.protobuf.StoreTypes.TaskDataWrapper

All Implemented Interfaces:

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

Enclosing class:

StoreTypes

public static final class StoreTypes.TaskDataWrapper
extends com.google.protobuf.GeneratedMessageV3
implements StoreTypes.TaskDataWrapperOrBuilder

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

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

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	ACCUMULATOR_UPDATES_FIELD_NUMBER
static final int	ATTEMPT_FIELD_NUMBER
static final int	DISK_BYTES_SPILLED_FIELD_NUMBER
static final int	DURATION_FIELD_NUMBER
static final int	ERROR_MESSAGE_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_ID_FIELD_NUMBER
static final int	EXECUTOR_RUN_TIME_FIELD_NUMBER
static final int	HAS_METRICS_FIELD_NUMBER
static final int	HOST_FIELD_NUMBER
static final int	INDEX_FIELD_NUMBER
static final int	INPUT_BYTES_READ_FIELD_NUMBER
static final int	INPUT_RECORDS_READ_FIELD_NUMBER
static final int	JVM_GC_TIME_FIELD_NUMBER
static final int	LAUNCH_TIME_FIELD_NUMBER
static final int	MEMORY_BYTES_SPILLED_FIELD_NUMBER
static final int	OUTPUT_BYTES_WRITTEN_FIELD_NUMBER
static final int	OUTPUT_RECORDS_WRITTEN_FIELD_NUMBER
static final int	PARTITION_ID_FIELD_NUMBER
static final int	PEAK_EXECUTION_MEMORY_FIELD_NUMBER
static final int	RESULT_FETCH_START_FIELD_NUMBER
static final int	RESULT_SERIALIZATION_TIME_FIELD_NUMBER
static final int	RESULT_SIZE_FIELD_NUMBER
static final int	SHUFFLE_BYTES_WRITTEN_FIELD_NUMBER
static final int	SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER
static final int	SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER
static final int	SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_MERGED_REMOTE_REQ_DURATION_FIELD_NUMBER
static final int	SHUFFLE_RECORDS_READ_FIELD_NUMBER
static final int	SHUFFLE_RECORDS_WRITTEN_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER
static final int	SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER
static final int	SHUFFLE_WRITE_TIME_FIELD_NUMBER
static final int	SPECULATIVE_FIELD_NUMBER
static final int	STAGE_ATTEMPT_ID_FIELD_NUMBER
static final int	STAGE_ID_FIELD_NUMBER
static final int	STATUS_FIELD_NUMBER
static final int	TASK_ID_FIELD_NUMBER
static final int	TASK_LOCALITY_FIELD_NUMBER

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
StoreTypes.AccumulableInfo	getAccumulatorUpdates(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
int	getAccumulatorUpdatesCount()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
List<StoreTypes.AccumulableInfo>	getAccumulatorUpdatesList()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.AccumulableInfoOrBuilder	getAccumulatorUpdatesOrBuilder(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
List<? extends StoreTypes.AccumulableInfoOrBuilder>	getAccumulatorUpdatesOrBuilderList()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
int	getAttempt()	int32 attempt = 3;
static StoreTypes.TaskDataWrapper	getDefaultInstance()
StoreTypes.TaskDataWrapper	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
long	getDiskBytesSpilled()	int64 disk_bytes_spilled = 24;
long	getDuration()	int64 duration = 7;
String	getErrorMessage()	optional string error_message = 14;
com.google.protobuf.ByteString	getErrorMessageBytes()	optional string error_message = 14;
long	getExecutorCpuTime()	int64 executor_cpu_time = 19;
long	getExecutorDeserializeCpuTime()	int64 executor_deserialize_cpu_time = 17;
long	getExecutorDeserializeTime()	int64 executor_deserialize_time = 16;
String	getExecutorId()	optional string executor_id = 8;
com.google.protobuf.ByteString	getExecutorIdBytes()	optional string executor_id = 8;
long	getExecutorRunTime()	int64 executor_run_time = 18;
boolean	getHasMetrics()	bool has_metrics = 15;
String	getHost()	optional string host = 9;
com.google.protobuf.ByteString	getHostBytes()	optional string host = 9;
int	getIndex()	int32 index = 2;
long	getInputBytesRead()	int64 input_bytes_read = 26;
long	getInputRecordsRead()	int64 input_records_read = 27;
long	getJvmGcTime()	int64 jvm_gc_time = 21;
long	getLaunchTime()	int64 launch_time = 5;
long	getMemoryBytesSpilled()	int64 memory_bytes_spilled = 23;
long	getOutputBytesWritten()	int64 output_bytes_written = 28;
long	getOutputRecordsWritten()	int64 output_records_written = 29;
com.google.protobuf.Parser<StoreTypes.TaskDataWrapper>	getParserForType()
int	getPartitionId()	int32 partition_id = 4;
long	getPeakExecutionMemory()	int64 peak_execution_memory = 25;
long	getResultFetchStart()	int64 result_fetch_start = 6;
long	getResultSerializationTime()	int64 result_serialization_time = 22;
long	getResultSize()	int64 result_size = 20;
int	getSerializedSize()
long	getShuffleBytesWritten()	int64 shuffle_bytes_written = 37;
long	getShuffleCorruptMergedBlockChunks()	int64 shuffle_corrupt_merged_block_chunks = 42;
long	getShuffleFetchWaitTime()	int64 shuffle_fetch_wait_time = 32;
long	getShuffleLocalBlocksFetched()	int64 shuffle_local_blocks_fetched = 31;
long	getShuffleLocalBytesRead()	int64 shuffle_local_bytes_read = 35;
long	getShuffleMergedFetchFallbackCount()	int64 shuffle_merged_fetch_fallback_count = 43;
long	getShuffleMergedLocalBlocksFetched()	int64 shuffle_merged_local_blocks_fetched = 45;
long	getShuffleMergedLocalBytesRead()	int64 shuffle_merged_local_bytes_read = 49;
long	getShuffleMergedLocalChunksFetched()	int64 shuffle_merged_local_chunks_fetched = 47;
long	getShuffleMergedRemoteBlocksFetched()	int64 shuffle_merged_remote_blocks_fetched = 44;
long	getShuffleMergedRemoteBytesRead()	int64 shuffle_merged_remote_bytes_read = 48;
long	getShuffleMergedRemoteChunksFetched()	int64 shuffle_merged_remote_chunks_fetched = 46;
long	getShuffleMergedRemoteReqDuration()	int64 shuffle_merged_remote_req_duration = 51;
long	getShuffleRecordsRead()	int64 shuffle_records_read = 36;
long	getShuffleRecordsWritten()	int64 shuffle_records_written = 39;
long	getShuffleRemoteBlocksFetched()	int64 shuffle_remote_blocks_fetched = 30;
long	getShuffleRemoteBytesRead()	int64 shuffle_remote_bytes_read = 33;
long	getShuffleRemoteBytesReadToDisk()	int64 shuffle_remote_bytes_read_to_disk = 34;
long	getShuffleRemoteReqsDuration()	int64 shuffle_remote_reqs_duration = 50;
long	getShuffleWriteTime()	int64 shuffle_write_time = 38;
boolean	getSpeculative()	bool speculative = 12;
int	getStageAttemptId()	int32 stage_attempt_id = 41;
long	getStageId()	int64 stage_id = 40;
String	getStatus()	optional string status = 10;
com.google.protobuf.ByteString	getStatusBytes()	optional string status = 10;
long	getTaskId()	int64 task_id = 1;
String	getTaskLocality()	optional string task_locality = 11;
com.google.protobuf.ByteString	getTaskLocalityBytes()	optional string task_locality = 11;
boolean	hasErrorMessage()	optional string error_message = 14;
boolean	hasExecutorId()	optional string executor_id = 8;
int	hashCode()
boolean	hasHost()	optional string host = 9;
boolean	hasStatus()	optional string status = 10;
boolean	hasTaskLocality()	optional string task_locality = 11;
final boolean	isInitialized()
static StoreTypes.TaskDataWrapper.Builder	newBuilder()
static StoreTypes.TaskDataWrapper.Builder	newBuilder(StoreTypes.TaskDataWrapper prototype)
StoreTypes.TaskDataWrapper.Builder	newBuilderForType()
static StoreTypes.TaskDataWrapper	parseDelimitedFrom(InputStream input)
static StoreTypes.TaskDataWrapper	parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskDataWrapper	parseFrom(byte[] data)
static StoreTypes.TaskDataWrapper	parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskDataWrapper	parseFrom(com.google.protobuf.ByteString data)
static StoreTypes.TaskDataWrapper	parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskDataWrapper	parseFrom(com.google.protobuf.CodedInputStream input)
static StoreTypes.TaskDataWrapper	parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskDataWrapper	parseFrom(InputStream input)
static StoreTypes.TaskDataWrapper	parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static StoreTypes.TaskDataWrapper	parseFrom(ByteBuffer data)
static StoreTypes.TaskDataWrapper	parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<StoreTypes.TaskDataWrapper>	parser()
StoreTypes.TaskDataWrapper.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

TASK_ID_FIELD_NUMBER

public static final int TASK_ID_FIELD_NUMBER

See Also:

• Constant Field Values

INDEX_FIELD_NUMBER

public static final int INDEX_FIELD_NUMBER

See Also:

• Constant Field Values

ATTEMPT_FIELD_NUMBER

public static final int ATTEMPT_FIELD_NUMBER

See Also:

• Constant Field Values

PARTITION_ID_FIELD_NUMBER

public static final int PARTITION_ID_FIELD_NUMBER

See Also:

• Constant Field Values

LAUNCH_TIME_FIELD_NUMBER

public static final int LAUNCH_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

RESULT_FETCH_START_FIELD_NUMBER

public static final int RESULT_FETCH_START_FIELD_NUMBER

See Also:

• Constant Field Values

DURATION_FIELD_NUMBER

public static final int DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

EXECUTOR_ID_FIELD_NUMBER

public static final int EXECUTOR_ID_FIELD_NUMBER

See Also:

• Constant Field Values

HOST_FIELD_NUMBER

public static final int HOST_FIELD_NUMBER

See Also:

• Constant Field Values

STATUS_FIELD_NUMBER

public static final int STATUS_FIELD_NUMBER

See Also:

• Constant Field Values

TASK_LOCALITY_FIELD_NUMBER

public static final int TASK_LOCALITY_FIELD_NUMBER

See Also:

• Constant Field Values

SPECULATIVE_FIELD_NUMBER

public static final int SPECULATIVE_FIELD_NUMBER

See Also:

• Constant Field Values

ACCUMULATOR_UPDATES_FIELD_NUMBER

public static final int ACCUMULATOR_UPDATES_FIELD_NUMBER

See Also:

• Constant Field Values

ERROR_MESSAGE_FIELD_NUMBER

public static final int ERROR_MESSAGE_FIELD_NUMBER

See Also:

• Constant Field Values

HAS_METRICS_FIELD_NUMBER

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

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_BYTES_READ_FIELD_NUMBER

public static final int INPUT_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

INPUT_RECORDS_READ_FIELD_NUMBER

public static final int INPUT_RECORDS_READ_FIELD_NUMBER

See Also:

• Constant Field Values

OUTPUT_BYTES_WRITTEN_FIELD_NUMBER

public static final int OUTPUT_BYTES_WRITTEN_FIELD_NUMBER

See Also:

• Constant Field Values

OUTPUT_RECORDS_WRITTEN_FIELD_NUMBER

public static final int OUTPUT_RECORDS_WRITTEN_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

public static final int SHUFFLE_FETCH_WAIT_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_BYTES_READ_TO_DISK_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_LOCAL_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_RECORDS_READ_FIELD_NUMBER

public static final int SHUFFLE_RECORDS_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_BYTES_WRITTEN_FIELD_NUMBER

public static final int SHUFFLE_BYTES_WRITTEN_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_WRITE_TIME_FIELD_NUMBER

public static final int SHUFFLE_WRITE_TIME_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_RECORDS_WRITTEN_FIELD_NUMBER

public static final int SHUFFLE_RECORDS_WRITTEN_FIELD_NUMBER

See Also:

• Constant Field Values

STAGE_ID_FIELD_NUMBER

public static final int STAGE_ID_FIELD_NUMBER

See Also:

• Constant Field Values

STAGE_ATTEMPT_ID_FIELD_NUMBER

public static final int STAGE_ATTEMPT_ID_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

public static final int SHUFFLE_CORRUPT_MERGED_BLOCK_CHUNKS_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

public static final int SHUFFLE_MERGED_FETCH_FALLBACK_COUNT_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_BLOCKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_CHUNKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_CHUNKS_FETCHED_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

public static final int SHUFFLE_MERGED_LOCAL_BYTES_READ_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

public static final int SHUFFLE_REMOTE_REQS_DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

SHUFFLE_MERGED_REMOTE_REQ_DURATION_FIELD_NUMBER

public static final int SHUFFLE_MERGED_REMOTE_REQ_DURATION_FIELD_NUMBER

See Also:

• Constant Field Values

Method Details

getDescriptor

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

getTaskId

public long getTaskId()

int64 task_id = 1;

Specified by:

getTaskId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The taskId.

getIndex

public int getIndex()

int32 index = 2;

Specified by:

getIndex in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The index.

getAttempt

public int getAttempt()

int32 attempt = 3;

Specified by:

getAttempt in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The attempt.

getPartitionId

public int getPartitionId()

int32 partition_id = 4;

Specified by:

getPartitionId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The partitionId.

getLaunchTime

public long getLaunchTime()

int64 launch_time = 5;

Specified by:

getLaunchTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The launchTime.

getResultFetchStart

public long getResultFetchStart()

int64 result_fetch_start = 6;

Specified by:

getResultFetchStart in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The resultFetchStart.

getDuration

public long getDuration()

int64 duration = 7;

Specified by:

getDuration in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The duration.

hasExecutorId

public boolean hasExecutorId()

optional string executor_id = 8;

Specified by:

hasExecutorId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

Whether the executorId field is set.

getExecutorId

public String getExecutorId()

optional string executor_id = 8;

Specified by:

getExecutorId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorId.

getExecutorIdBytes

public com.google.protobuf.ByteString getExecutorIdBytes()

optional string executor_id = 8;

Specified by:

getExecutorIdBytes in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The bytes for executorId.

hasHost

public boolean hasHost()

optional string host = 9;

Specified by:

hasHost in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

Whether the host field is set.

getHost

public String getHost()

optional string host = 9;

Specified by:

getHost in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The host.

getHostBytes

public com.google.protobuf.ByteString getHostBytes()

optional string host = 9;

Specified by:

getHostBytes in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The bytes for host.

hasStatus

public boolean hasStatus()

optional string status = 10;

Specified by:

hasStatus in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

Whether the status field is set.

getStatus

public String getStatus()

optional string status = 10;

Specified by:

getStatus in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The status.

getStatusBytes

public com.google.protobuf.ByteString getStatusBytes()

optional string status = 10;

Specified by:

getStatusBytes in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The bytes for status.

hasTaskLocality

public boolean hasTaskLocality()

optional string task_locality = 11;

Specified by:

hasTaskLocality in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

Whether the taskLocality field is set.

getTaskLocality

public String getTaskLocality()

optional string task_locality = 11;

Specified by:

getTaskLocality in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The taskLocality.

getTaskLocalityBytes

public com.google.protobuf.ByteString getTaskLocalityBytes()

optional string task_locality = 11;

Specified by:

getTaskLocalityBytes in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The bytes for taskLocality.

getSpeculative

public boolean getSpeculative()

bool speculative = 12;

Specified by:

getSpeculative in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The speculative.

getAccumulatorUpdatesList

public List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesList in interface StoreTypes.TaskDataWrapperOrBuilder

getAccumulatorUpdatesOrBuilderList

public List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesOrBuilderList in interface StoreTypes.TaskDataWrapperOrBuilder

getAccumulatorUpdatesCount

public int getAccumulatorUpdatesCount()

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesCount in interface StoreTypes.TaskDataWrapperOrBuilder

getAccumulatorUpdates

public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdates in interface StoreTypes.TaskDataWrapperOrBuilder

getAccumulatorUpdatesOrBuilder

public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)

repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

Specified by:

getAccumulatorUpdatesOrBuilder in interface StoreTypes.TaskDataWrapperOrBuilder

hasErrorMessage

public boolean hasErrorMessage()

optional string error_message = 14;

Specified by:

hasErrorMessage in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

Whether the errorMessage field is set.

getErrorMessage

public String getErrorMessage()

optional string error_message = 14;

Specified by:

getErrorMessage in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The errorMessage.

getErrorMessageBytes

public com.google.protobuf.ByteString getErrorMessageBytes()

optional string error_message = 14;

Specified by:

getErrorMessageBytes in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The bytes for errorMessage.

getHasMetrics

public boolean getHasMetrics()

bool has_metrics = 15;

Specified by:

getHasMetrics in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The hasMetrics.

getExecutorDeserializeTime

public long getExecutorDeserializeTime()

int64 executor_deserialize_time = 16;

Specified by:

getExecutorDeserializeTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorDeserializeTime.

getExecutorDeserializeCpuTime

public long getExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 17;

Specified by:

getExecutorDeserializeCpuTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorDeserializeCpuTime.

getExecutorRunTime

public long getExecutorRunTime()

int64 executor_run_time = 18;

Specified by:

getExecutorRunTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorRunTime.

getExecutorCpuTime

public long getExecutorCpuTime()

int64 executor_cpu_time = 19;

Specified by:

getExecutorCpuTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorCpuTime.

getResultSize

public long getResultSize()

int64 result_size = 20;

Specified by:

getResultSize in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The resultSize.

getJvmGcTime

public long getJvmGcTime()

int64 jvm_gc_time = 21;

Specified by:

getJvmGcTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The jvmGcTime.

getResultSerializationTime

public long getResultSerializationTime()

int64 result_serialization_time = 22;

Specified by:

getResultSerializationTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The resultSerializationTime.

getMemoryBytesSpilled

public long getMemoryBytesSpilled()

int64 memory_bytes_spilled = 23;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The memoryBytesSpilled.

getDiskBytesSpilled

public long getDiskBytesSpilled()

int64 disk_bytes_spilled = 24;

Specified by:

getDiskBytesSpilled in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The diskBytesSpilled.

getPeakExecutionMemory

public long getPeakExecutionMemory()

int64 peak_execution_memory = 25;

Specified by:

getPeakExecutionMemory in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The peakExecutionMemory.

getInputBytesRead

public long getInputBytesRead()

int64 input_bytes_read = 26;

Specified by:

getInputBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The inputBytesRead.

getInputRecordsRead

public long getInputRecordsRead()

int64 input_records_read = 27;

Specified by:

getInputRecordsRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The inputRecordsRead.

getOutputBytesWritten

public long getOutputBytesWritten()

int64 output_bytes_written = 28;

Specified by:

getOutputBytesWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The outputBytesWritten.

getOutputRecordsWritten

public long getOutputRecordsWritten()

int64 output_records_written = 29;

Specified by:

getOutputRecordsWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The outputRecordsWritten.

getShuffleRemoteBlocksFetched

public long getShuffleRemoteBlocksFetched()

int64 shuffle_remote_blocks_fetched = 30;

Specified by:

getShuffleRemoteBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteBlocksFetched.

getShuffleLocalBlocksFetched

public long getShuffleLocalBlocksFetched()

int64 shuffle_local_blocks_fetched = 31;

Specified by:

getShuffleLocalBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleLocalBlocksFetched.

getShuffleFetchWaitTime

public long getShuffleFetchWaitTime()

int64 shuffle_fetch_wait_time = 32;

Specified by:

getShuffleFetchWaitTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleFetchWaitTime.

getShuffleRemoteBytesRead

public long getShuffleRemoteBytesRead()

int64 shuffle_remote_bytes_read = 33;

Specified by:

getShuffleRemoteBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteBytesRead.

getShuffleRemoteBytesReadToDisk

public long getShuffleRemoteBytesReadToDisk()

int64 shuffle_remote_bytes_read_to_disk = 34;

Specified by:

getShuffleRemoteBytesReadToDisk in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteBytesReadToDisk.

getShuffleLocalBytesRead

public long getShuffleLocalBytesRead()

int64 shuffle_local_bytes_read = 35;

Specified by:

getShuffleLocalBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleLocalBytesRead.

getShuffleRecordsRead

public long getShuffleRecordsRead()

int64 shuffle_records_read = 36;

Specified by:

getShuffleRecordsRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRecordsRead.

getShuffleBytesWritten

public long getShuffleBytesWritten()

int64 shuffle_bytes_written = 37;

Specified by:

getShuffleBytesWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleBytesWritten.

getShuffleWriteTime

public long getShuffleWriteTime()

int64 shuffle_write_time = 38;

Specified by:

getShuffleWriteTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleWriteTime.

getShuffleRecordsWritten

public long getShuffleRecordsWritten()

int64 shuffle_records_written = 39;

Specified by:

getShuffleRecordsWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRecordsWritten.

getStageId

public long getStageId()

int64 stage_id = 40;

Specified by:

getStageId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The stageId.

getStageAttemptId

public int getStageAttemptId()

int32 stage_attempt_id = 41;

Specified by:

getStageAttemptId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The stageAttemptId.

getShuffleCorruptMergedBlockChunks

public long getShuffleCorruptMergedBlockChunks()

int64 shuffle_corrupt_merged_block_chunks = 42;

Specified by:

getShuffleCorruptMergedBlockChunks in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleCorruptMergedBlockChunks.

getShuffleMergedFetchFallbackCount

public long getShuffleMergedFetchFallbackCount()

int64 shuffle_merged_fetch_fallback_count = 43;

Specified by:

getShuffleMergedFetchFallbackCount in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedFetchFallbackCount.

getShuffleMergedRemoteBlocksFetched

public long getShuffleMergedRemoteBlocksFetched()

int64 shuffle_merged_remote_blocks_fetched = 44;

Specified by:

getShuffleMergedRemoteBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteBlocksFetched.

getShuffleMergedLocalBlocksFetched

public long getShuffleMergedLocalBlocksFetched()

int64 shuffle_merged_local_blocks_fetched = 45;

Specified by:

getShuffleMergedLocalBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedLocalBlocksFetched.

getShuffleMergedRemoteChunksFetched

public long getShuffleMergedRemoteChunksFetched()

int64 shuffle_merged_remote_chunks_fetched = 46;

Specified by:

getShuffleMergedRemoteChunksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteChunksFetched.

getShuffleMergedLocalChunksFetched

public long getShuffleMergedLocalChunksFetched()

int64 shuffle_merged_local_chunks_fetched = 47;

Specified by:

getShuffleMergedLocalChunksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedLocalChunksFetched.

getShuffleMergedRemoteBytesRead

public long getShuffleMergedRemoteBytesRead()

int64 shuffle_merged_remote_bytes_read = 48;

Specified by:

getShuffleMergedRemoteBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteBytesRead.

getShuffleMergedLocalBytesRead

public long getShuffleMergedLocalBytesRead()

int64 shuffle_merged_local_bytes_read = 49;

Specified by:

getShuffleMergedLocalBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedLocalBytesRead.

getShuffleRemoteReqsDuration

public long getShuffleRemoteReqsDuration()

int64 shuffle_remote_reqs_duration = 50;

Specified by:

getShuffleRemoteReqsDuration in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteReqsDuration.

getShuffleMergedRemoteReqDuration

public long getShuffleMergedRemoteReqDuration()

int64 shuffle_merged_remote_req_duration = 51;

Specified by:

getShuffleMergedRemoteReqDuration in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteReqDuration.

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

com.google.protobuf.InvalidProtocolBufferException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseDelimitedFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

parseFrom

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

Throws:

IOException

newBuilderForType

public StoreTypes.TaskDataWrapper.Builder newBuilderForType()

Specified by:

newBuilderForType in interface com.google.protobuf.Message

Specified by:

newBuilderForType in interface com.google.protobuf.MessageLite

newBuilder

public static StoreTypes.TaskDataWrapper.Builder newBuilder()

newBuilder

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

toBuilder

public StoreTypes.TaskDataWrapper.Builder toBuilder()

Specified by:

toBuilder in interface com.google.protobuf.Message

Specified by:

toBuilder in interface com.google.protobuf.MessageLite

getDefaultInstance

public static StoreTypes.TaskDataWrapper getDefaultInstance()

parser

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

getParserForType

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

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder