Package org.apache.spark.status.protobuf

Class StoreTypes.TaskDataWrapper.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskDataWrapper.Builder>

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

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, StoreTypes.TaskDataWrapperOrBuilder

Enclosing class:

StoreTypes.TaskDataWrapper

public static final class StoreTypes.TaskDataWrapper.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskDataWrapper.Builder>
implements StoreTypes.TaskDataWrapperOrBuilder

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

Method Summary

Modifier and Type	Method	Description
StoreTypes.TaskDataWrapper.Builder	addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	addAccumulatorUpdates(StoreTypes.AccumulableInfo value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.AccumulableInfo.Builder	addAccumulatorUpdatesBuilder()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.AccumulableInfo.Builder	addAccumulatorUpdatesBuilder(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper	build()
StoreTypes.TaskDataWrapper	buildPartial()
StoreTypes.TaskDataWrapper.Builder	clear()
StoreTypes.TaskDataWrapper.Builder	clearAccumulatorUpdates()	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	clearAttempt()	int32 attempt = 3;
StoreTypes.TaskDataWrapper.Builder	clearDiskBytesSpilled()	int64 disk_bytes_spilled = 24;
StoreTypes.TaskDataWrapper.Builder	clearDuration()	int64 duration = 7;
StoreTypes.TaskDataWrapper.Builder	clearErrorMessage()	optional string error_message = 14;
StoreTypes.TaskDataWrapper.Builder	clearExecutorCpuTime()	int64 executor_cpu_time = 19;
StoreTypes.TaskDataWrapper.Builder	clearExecutorDeserializeCpuTime()	int64 executor_deserialize_cpu_time = 17;
StoreTypes.TaskDataWrapper.Builder	clearExecutorDeserializeTime()	int64 executor_deserialize_time = 16;
StoreTypes.TaskDataWrapper.Builder	clearExecutorId()	optional string executor_id = 8;
StoreTypes.TaskDataWrapper.Builder	clearExecutorRunTime()	int64 executor_run_time = 18;
StoreTypes.TaskDataWrapper.Builder	clearHasMetrics()	bool has_metrics = 15;
StoreTypes.TaskDataWrapper.Builder	clearHost()	optional string host = 9;
StoreTypes.TaskDataWrapper.Builder	clearIndex()	int32 index = 2;
StoreTypes.TaskDataWrapper.Builder	clearInputBytesRead()	int64 input_bytes_read = 26;
StoreTypes.TaskDataWrapper.Builder	clearInputRecordsRead()	int64 input_records_read = 27;
StoreTypes.TaskDataWrapper.Builder	clearJvmGcTime()	int64 jvm_gc_time = 21;
StoreTypes.TaskDataWrapper.Builder	clearLaunchTime()	int64 launch_time = 5;
StoreTypes.TaskDataWrapper.Builder	clearMemoryBytesSpilled()	int64 memory_bytes_spilled = 23;
StoreTypes.TaskDataWrapper.Builder	clearOutputBytesWritten()	int64 output_bytes_written = 28;
StoreTypes.TaskDataWrapper.Builder	clearOutputRecordsWritten()	int64 output_records_written = 29;
StoreTypes.TaskDataWrapper.Builder	clearPartitionId()	int32 partition_id = 4;
StoreTypes.TaskDataWrapper.Builder	clearPeakExecutionMemory()	int64 peak_execution_memory = 25;
StoreTypes.TaskDataWrapper.Builder	clearResultFetchStart()	int64 result_fetch_start = 6;
StoreTypes.TaskDataWrapper.Builder	clearResultSerializationTime()	int64 result_serialization_time = 22;
StoreTypes.TaskDataWrapper.Builder	clearResultSize()	int64 result_size = 20;
StoreTypes.TaskDataWrapper.Builder	clearShuffleBytesWritten()	int64 shuffle_bytes_written = 37;
StoreTypes.TaskDataWrapper.Builder	clearShuffleCorruptMergedBlockChunks()	int64 shuffle_corrupt_merged_block_chunks = 42;
StoreTypes.TaskDataWrapper.Builder	clearShuffleFetchWaitTime()	int64 shuffle_fetch_wait_time = 32;
StoreTypes.TaskDataWrapper.Builder	clearShuffleLocalBlocksFetched()	int64 shuffle_local_blocks_fetched = 31;
StoreTypes.TaskDataWrapper.Builder	clearShuffleLocalBytesRead()	int64 shuffle_local_bytes_read = 35;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedFetchFallbackCount()	int64 shuffle_merged_fetch_fallback_count = 43;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedLocalBlocksFetched()	int64 shuffle_merged_local_blocks_fetched = 45;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedLocalBytesRead()	int64 shuffle_merged_local_bytes_read = 49;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedLocalChunksFetched()	int64 shuffle_merged_local_chunks_fetched = 47;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedRemoteBlocksFetched()	int64 shuffle_merged_remote_blocks_fetched = 44;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedRemoteBytesRead()	int64 shuffle_merged_remote_bytes_read = 48;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedRemoteChunksFetched()	int64 shuffle_merged_remote_chunks_fetched = 46;
StoreTypes.TaskDataWrapper.Builder	clearShuffleMergedRemoteReqDuration()	int64 shuffle_merged_remote_req_duration = 51;
StoreTypes.TaskDataWrapper.Builder	clearShuffleRecordsRead()	int64 shuffle_records_read = 36;
StoreTypes.TaskDataWrapper.Builder	clearShuffleRecordsWritten()	int64 shuffle_records_written = 39;
StoreTypes.TaskDataWrapper.Builder	clearShuffleRemoteBlocksFetched()	int64 shuffle_remote_blocks_fetched = 30;
StoreTypes.TaskDataWrapper.Builder	clearShuffleRemoteBytesRead()	int64 shuffle_remote_bytes_read = 33;
StoreTypes.TaskDataWrapper.Builder	clearShuffleRemoteBytesReadToDisk()	int64 shuffle_remote_bytes_read_to_disk = 34;
StoreTypes.TaskDataWrapper.Builder	clearShuffleRemoteReqsDuration()	int64 shuffle_remote_reqs_duration = 50;
StoreTypes.TaskDataWrapper.Builder	clearShuffleWriteTime()	int64 shuffle_write_time = 38;
StoreTypes.TaskDataWrapper.Builder	clearSpeculative()	bool speculative = 12;
StoreTypes.TaskDataWrapper.Builder	clearStageAttemptId()	int32 stage_attempt_id = 41;
StoreTypes.TaskDataWrapper.Builder	clearStageId()	int64 stage_id = 40;
StoreTypes.TaskDataWrapper.Builder	clearStatus()	optional string status = 10;
StoreTypes.TaskDataWrapper.Builder	clearTaskId()	int64 task_id = 1;
StoreTypes.TaskDataWrapper.Builder	clearTaskLocality()	optional string task_locality = 11;
StoreTypes.AccumulableInfo	getAccumulatorUpdates(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.AccumulableInfo.Builder	getAccumulatorUpdatesBuilder(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
List<StoreTypes.AccumulableInfo.Builder>	getAccumulatorUpdatesBuilderList()	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;
StoreTypes.TaskDataWrapper	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
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;
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;
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;
boolean	hasHost()	optional string host = 9;
boolean	hasStatus()	optional string status = 10;
boolean	hasTaskLocality()	optional string task_locality = 11;
final boolean	isInitialized()
StoreTypes.TaskDataWrapper.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.TaskDataWrapper.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.TaskDataWrapper.Builder	mergeFrom(StoreTypes.TaskDataWrapper other)
StoreTypes.TaskDataWrapper.Builder	removeAccumulatorUpdates(int index)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
StoreTypes.TaskDataWrapper.Builder	setAttempt(int value)	int32 attempt = 3;
StoreTypes.TaskDataWrapper.Builder	setDiskBytesSpilled(long value)	int64 disk_bytes_spilled = 24;
StoreTypes.TaskDataWrapper.Builder	setDuration(long value)	int64 duration = 7;
StoreTypes.TaskDataWrapper.Builder	setErrorMessage(String value)	optional string error_message = 14;
StoreTypes.TaskDataWrapper.Builder	setErrorMessageBytes(com.google.protobuf.ByteString value)	optional string error_message = 14;
StoreTypes.TaskDataWrapper.Builder	setExecutorCpuTime(long value)	int64 executor_cpu_time = 19;
StoreTypes.TaskDataWrapper.Builder	setExecutorDeserializeCpuTime(long value)	int64 executor_deserialize_cpu_time = 17;
StoreTypes.TaskDataWrapper.Builder	setExecutorDeserializeTime(long value)	int64 executor_deserialize_time = 16;
StoreTypes.TaskDataWrapper.Builder	setExecutorId(String value)	optional string executor_id = 8;
StoreTypes.TaskDataWrapper.Builder	setExecutorIdBytes(com.google.protobuf.ByteString value)	optional string executor_id = 8;
StoreTypes.TaskDataWrapper.Builder	setExecutorRunTime(long value)	int64 executor_run_time = 18;
StoreTypes.TaskDataWrapper.Builder	setHasMetrics(boolean value)	bool has_metrics = 15;
StoreTypes.TaskDataWrapper.Builder	setHost(String value)	optional string host = 9;
StoreTypes.TaskDataWrapper.Builder	setHostBytes(com.google.protobuf.ByteString value)	optional string host = 9;
StoreTypes.TaskDataWrapper.Builder	setIndex(int value)	int32 index = 2;
StoreTypes.TaskDataWrapper.Builder	setInputBytesRead(long value)	int64 input_bytes_read = 26;
StoreTypes.TaskDataWrapper.Builder	setInputRecordsRead(long value)	int64 input_records_read = 27;
StoreTypes.TaskDataWrapper.Builder	setJvmGcTime(long value)	int64 jvm_gc_time = 21;
StoreTypes.TaskDataWrapper.Builder	setLaunchTime(long value)	int64 launch_time = 5;
StoreTypes.TaskDataWrapper.Builder	setMemoryBytesSpilled(long value)	int64 memory_bytes_spilled = 23;
StoreTypes.TaskDataWrapper.Builder	setOutputBytesWritten(long value)	int64 output_bytes_written = 28;
StoreTypes.TaskDataWrapper.Builder	setOutputRecordsWritten(long value)	int64 output_records_written = 29;
StoreTypes.TaskDataWrapper.Builder	setPartitionId(int value)	int32 partition_id = 4;
StoreTypes.TaskDataWrapper.Builder	setPeakExecutionMemory(long value)	int64 peak_execution_memory = 25;
StoreTypes.TaskDataWrapper.Builder	setResultFetchStart(long value)	int64 result_fetch_start = 6;
StoreTypes.TaskDataWrapper.Builder	setResultSerializationTime(long value)	int64 result_serialization_time = 22;
StoreTypes.TaskDataWrapper.Builder	setResultSize(long value)	int64 result_size = 20;
StoreTypes.TaskDataWrapper.Builder	setShuffleBytesWritten(long value)	int64 shuffle_bytes_written = 37;
StoreTypes.TaskDataWrapper.Builder	setShuffleCorruptMergedBlockChunks(long value)	int64 shuffle_corrupt_merged_block_chunks = 42;
StoreTypes.TaskDataWrapper.Builder	setShuffleFetchWaitTime(long value)	int64 shuffle_fetch_wait_time = 32;
StoreTypes.TaskDataWrapper.Builder	setShuffleLocalBlocksFetched(long value)	int64 shuffle_local_blocks_fetched = 31;
StoreTypes.TaskDataWrapper.Builder	setShuffleLocalBytesRead(long value)	int64 shuffle_local_bytes_read = 35;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedFetchFallbackCount(long value)	int64 shuffle_merged_fetch_fallback_count = 43;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedLocalBlocksFetched(long value)	int64 shuffle_merged_local_blocks_fetched = 45;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedLocalBytesRead(long value)	int64 shuffle_merged_local_bytes_read = 49;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedLocalChunksFetched(long value)	int64 shuffle_merged_local_chunks_fetched = 47;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedRemoteBlocksFetched(long value)	int64 shuffle_merged_remote_blocks_fetched = 44;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedRemoteBytesRead(long value)	int64 shuffle_merged_remote_bytes_read = 48;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedRemoteChunksFetched(long value)	int64 shuffle_merged_remote_chunks_fetched = 46;
StoreTypes.TaskDataWrapper.Builder	setShuffleMergedRemoteReqDuration(long value)	int64 shuffle_merged_remote_req_duration = 51;
StoreTypes.TaskDataWrapper.Builder	setShuffleRecordsRead(long value)	int64 shuffle_records_read = 36;
StoreTypes.TaskDataWrapper.Builder	setShuffleRecordsWritten(long value)	int64 shuffle_records_written = 39;
StoreTypes.TaskDataWrapper.Builder	setShuffleRemoteBlocksFetched(long value)	int64 shuffle_remote_blocks_fetched = 30;
StoreTypes.TaskDataWrapper.Builder	setShuffleRemoteBytesRead(long value)	int64 shuffle_remote_bytes_read = 33;
StoreTypes.TaskDataWrapper.Builder	setShuffleRemoteBytesReadToDisk(long value)	int64 shuffle_remote_bytes_read_to_disk = 34;
StoreTypes.TaskDataWrapper.Builder	setShuffleRemoteReqsDuration(long value)	int64 shuffle_remote_reqs_duration = 50;
StoreTypes.TaskDataWrapper.Builder	setShuffleWriteTime(long value)	int64 shuffle_write_time = 38;
StoreTypes.TaskDataWrapper.Builder	setSpeculative(boolean value)	bool speculative = 12;
StoreTypes.TaskDataWrapper.Builder	setStageAttemptId(int value)	int32 stage_attempt_id = 41;
StoreTypes.TaskDataWrapper.Builder	setStageId(long value)	int64 stage_id = 40;
StoreTypes.TaskDataWrapper.Builder	setStatus(String value)	optional string status = 10;
StoreTypes.TaskDataWrapper.Builder	setStatusBytes(com.google.protobuf.ByteString value)	optional string status = 10;
StoreTypes.TaskDataWrapper.Builder	setTaskId(long value)	int64 task_id = 1;
StoreTypes.TaskDataWrapper.Builder	setTaskLocality(String value)	optional string task_locality = 11;
StoreTypes.TaskDataWrapper.Builder	setTaskLocalityBytes(com.google.protobuf.ByteString value)	optional string task_locality = 11;

Methods inherited from class com.google.protobuf.GeneratedMessage.Builder

addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, mergeUnknownFields, newBuilderForField, setField, setRepeatedField, setUnknownFields

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.Message.Builder

mergeDelimitedFrom, mergeDelimitedFrom

Methods inherited from interface com.google.protobuf.MessageLite.Builder

mergeFrom

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Method Details

getDescriptor

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

clear

public StoreTypes.TaskDataWrapper.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskDataWrapper.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskDataWrapper.Builder>

getDefaultInstanceForType

public StoreTypes.TaskDataWrapper getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.TaskDataWrapper build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public StoreTypes.TaskDataWrapper buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public StoreTypes.TaskDataWrapper.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskDataWrapper.Builder>

mergeFrom

public StoreTypes.TaskDataWrapper.Builder mergeFrom(StoreTypes.TaskDataWrapper other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskDataWrapper.Builder>

mergeFrom

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

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskDataWrapper.Builder>

Throws:

IOException

getTaskId

public long getTaskId()

int64 task_id = 1;

Specified by:

getTaskId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The taskId.

setTaskId

public StoreTypes.TaskDataWrapper.Builder setTaskId(long value)

int64 task_id = 1;

Parameters:

value - The taskId to set.

Returns:

This builder for chaining.

clearTaskId

public StoreTypes.TaskDataWrapper.Builder clearTaskId()

int64 task_id = 1;

Returns:

This builder for chaining.

getIndex

public int getIndex()

int32 index = 2;

Specified by:

getIndex in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The index.

setIndex

public StoreTypes.TaskDataWrapper.Builder setIndex(int value)

int32 index = 2;

Parameters:

value - The index to set.

Returns:

This builder for chaining.

clearIndex

public StoreTypes.TaskDataWrapper.Builder clearIndex()

int32 index = 2;

Returns:

This builder for chaining.

getAttempt

public int getAttempt()

int32 attempt = 3;

Specified by:

getAttempt in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The attempt.

setAttempt

public StoreTypes.TaskDataWrapper.Builder setAttempt(int value)

int32 attempt = 3;

Parameters:

value - The attempt to set.

Returns:

This builder for chaining.

clearAttempt

public StoreTypes.TaskDataWrapper.Builder clearAttempt()

int32 attempt = 3;

Returns:

This builder for chaining.

getPartitionId

public int getPartitionId()

int32 partition_id = 4;

Specified by:

getPartitionId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The partitionId.

setPartitionId

public StoreTypes.TaskDataWrapper.Builder setPartitionId(int value)

int32 partition_id = 4;

Parameters:

value - The partitionId to set.

Returns:

This builder for chaining.

clearPartitionId

public StoreTypes.TaskDataWrapper.Builder clearPartitionId()

int32 partition_id = 4;

Returns:

This builder for chaining.

getLaunchTime

public long getLaunchTime()

int64 launch_time = 5;

Specified by:

getLaunchTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The launchTime.

setLaunchTime

public StoreTypes.TaskDataWrapper.Builder setLaunchTime(long value)

int64 launch_time = 5;

Parameters:

value - The launchTime to set.

Returns:

This builder for chaining.

clearLaunchTime

public StoreTypes.TaskDataWrapper.Builder clearLaunchTime()

int64 launch_time = 5;

Returns:

This builder for chaining.

getResultFetchStart

public long getResultFetchStart()

int64 result_fetch_start = 6;

Specified by:

getResultFetchStart in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The resultFetchStart.

setResultFetchStart

public StoreTypes.TaskDataWrapper.Builder setResultFetchStart(long value)

int64 result_fetch_start = 6;

Parameters:

value - The resultFetchStart to set.

Returns:

This builder for chaining.

clearResultFetchStart

public StoreTypes.TaskDataWrapper.Builder clearResultFetchStart()

int64 result_fetch_start = 6;

Returns:

This builder for chaining.

getDuration

public long getDuration()

int64 duration = 7;

Specified by:

getDuration in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The duration.

setDuration

public StoreTypes.TaskDataWrapper.Builder setDuration(long value)

int64 duration = 7;

Parameters:

value - The duration to set.

Returns:

This builder for chaining.

clearDuration

public StoreTypes.TaskDataWrapper.Builder clearDuration()

int64 duration = 7;

Returns:

This builder for chaining.

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.

setExecutorId

public StoreTypes.TaskDataWrapper.Builder setExecutorId(String value)

optional string executor_id = 8;

Parameters:

value - The executorId to set.

Returns:

This builder for chaining.

clearExecutorId

public StoreTypes.TaskDataWrapper.Builder clearExecutorId()

optional string executor_id = 8;

Returns:

This builder for chaining.

setExecutorIdBytes

public StoreTypes.TaskDataWrapper.Builder setExecutorIdBytes(com.google.protobuf.ByteString value)

optional string executor_id = 8;

Parameters:

value - The bytes for executorId to set.

Returns:

This builder for chaining.

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.

setHost

public StoreTypes.TaskDataWrapper.Builder setHost(String value)

optional string host = 9;

Parameters:

value - The host to set.

Returns:

This builder for chaining.

clearHost

public StoreTypes.TaskDataWrapper.Builder clearHost()

optional string host = 9;

Returns:

This builder for chaining.

setHostBytes

public StoreTypes.TaskDataWrapper.Builder setHostBytes(com.google.protobuf.ByteString value)

optional string host = 9;

Parameters:

value - The bytes for host to set.

Returns:

This builder for chaining.

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.

setStatus

public StoreTypes.TaskDataWrapper.Builder setStatus(String value)

optional string status = 10;

Parameters:

value - The status to set.

Returns:

This builder for chaining.

clearStatus

public StoreTypes.TaskDataWrapper.Builder clearStatus()

optional string status = 10;

Returns:

This builder for chaining.

setStatusBytes

public StoreTypes.TaskDataWrapper.Builder setStatusBytes(com.google.protobuf.ByteString value)

optional string status = 10;

Parameters:

value - The bytes for status to set.

Returns:

This builder for chaining.

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.

setTaskLocality

public StoreTypes.TaskDataWrapper.Builder setTaskLocality(String value)

optional string task_locality = 11;

Parameters:

value - The taskLocality to set.

Returns:

This builder for chaining.

clearTaskLocality

public StoreTypes.TaskDataWrapper.Builder clearTaskLocality()

optional string task_locality = 11;

Returns:

This builder for chaining.

setTaskLocalityBytes

public StoreTypes.TaskDataWrapper.Builder setTaskLocalityBytes(com.google.protobuf.ByteString value)

optional string task_locality = 11;

Parameters:

value - The bytes for taskLocality to set.

Returns:

This builder for chaining.

getSpeculative

public boolean getSpeculative()

bool speculative = 12;

Specified by:

getSpeculative in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The speculative.

setSpeculative

public StoreTypes.TaskDataWrapper.Builder setSpeculative(boolean value)

bool speculative = 12;

Parameters:

value - The speculative to set.

Returns:

This builder for chaining.

clearSpeculative

public StoreTypes.TaskDataWrapper.Builder clearSpeculative()

bool speculative = 12;

Returns:

This builder for chaining.

getAccumulatorUpdatesList

public List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()

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

Specified by:

getAccumulatorUpdatesList 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

setAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder setAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo value)

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

setAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder setAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo.Builder builderForValue)

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

addAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo value)

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

addAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo value)

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

addAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)

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

addAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(int index,
 StoreTypes.AccumulableInfo.Builder builderForValue)

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

addAllAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)

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

clearAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder clearAccumulatorUpdates()

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

removeAccumulatorUpdates

public StoreTypes.TaskDataWrapper.Builder removeAccumulatorUpdates(int index)

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

getAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder getAccumulatorUpdatesBuilder(int index)

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

getAccumulatorUpdatesOrBuilder

public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)

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

Specified by:

getAccumulatorUpdatesOrBuilder 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

addAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder()

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

addAccumulatorUpdatesBuilder

public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder(int index)

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

getAccumulatorUpdatesBuilderList

public List<StoreTypes.AccumulableInfo.Builder> getAccumulatorUpdatesBuilderList()

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

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.

setErrorMessage

public StoreTypes.TaskDataWrapper.Builder setErrorMessage(String value)

optional string error_message = 14;

Parameters:

value - The errorMessage to set.

Returns:

This builder for chaining.

clearErrorMessage

public StoreTypes.TaskDataWrapper.Builder clearErrorMessage()

optional string error_message = 14;

Returns:

This builder for chaining.

setErrorMessageBytes

public StoreTypes.TaskDataWrapper.Builder setErrorMessageBytes(com.google.protobuf.ByteString value)

optional string error_message = 14;

Parameters:

value - The bytes for errorMessage to set.

Returns:

This builder for chaining.

getHasMetrics

public boolean getHasMetrics()

bool has_metrics = 15;

Specified by:

getHasMetrics in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The hasMetrics.

setHasMetrics

public StoreTypes.TaskDataWrapper.Builder setHasMetrics(boolean value)

bool has_metrics = 15;

Parameters:

value - The hasMetrics to set.

Returns:

This builder for chaining.

clearHasMetrics

public StoreTypes.TaskDataWrapper.Builder clearHasMetrics()

bool has_metrics = 15;

Returns:

This builder for chaining.

getExecutorDeserializeTime

public long getExecutorDeserializeTime()

int64 executor_deserialize_time = 16;

Specified by:

getExecutorDeserializeTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorDeserializeTime.

setExecutorDeserializeTime

public StoreTypes.TaskDataWrapper.Builder setExecutorDeserializeTime(long value)

int64 executor_deserialize_time = 16;

Parameters:

value - The executorDeserializeTime to set.

Returns:

This builder for chaining.

clearExecutorDeserializeTime

public StoreTypes.TaskDataWrapper.Builder clearExecutorDeserializeTime()

int64 executor_deserialize_time = 16;

Returns:

This builder for chaining.

getExecutorDeserializeCpuTime

public long getExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 17;

Specified by:

getExecutorDeserializeCpuTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorDeserializeCpuTime.

setExecutorDeserializeCpuTime

public StoreTypes.TaskDataWrapper.Builder setExecutorDeserializeCpuTime(long value)

int64 executor_deserialize_cpu_time = 17;

Parameters:

value - The executorDeserializeCpuTime to set.

Returns:

This builder for chaining.

clearExecutorDeserializeCpuTime

public StoreTypes.TaskDataWrapper.Builder clearExecutorDeserializeCpuTime()

int64 executor_deserialize_cpu_time = 17;

Returns:

This builder for chaining.

getExecutorRunTime

public long getExecutorRunTime()

int64 executor_run_time = 18;

Specified by:

getExecutorRunTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorRunTime.

setExecutorRunTime

public StoreTypes.TaskDataWrapper.Builder setExecutorRunTime(long value)

int64 executor_run_time = 18;

Parameters:

value - The executorRunTime to set.

Returns:

This builder for chaining.

clearExecutorRunTime

public StoreTypes.TaskDataWrapper.Builder clearExecutorRunTime()

int64 executor_run_time = 18;

Returns:

This builder for chaining.

getExecutorCpuTime

public long getExecutorCpuTime()

int64 executor_cpu_time = 19;

Specified by:

getExecutorCpuTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The executorCpuTime.

setExecutorCpuTime

public StoreTypes.TaskDataWrapper.Builder setExecutorCpuTime(long value)

int64 executor_cpu_time = 19;

Parameters:

value - The executorCpuTime to set.

Returns:

This builder for chaining.

clearExecutorCpuTime

public StoreTypes.TaskDataWrapper.Builder clearExecutorCpuTime()

int64 executor_cpu_time = 19;

Returns:

This builder for chaining.

getResultSize

public long getResultSize()

int64 result_size = 20;

Specified by:

getResultSize in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The resultSize.

setResultSize

public StoreTypes.TaskDataWrapper.Builder setResultSize(long value)

int64 result_size = 20;

Parameters:

value - The resultSize to set.

Returns:

This builder for chaining.

clearResultSize

public StoreTypes.TaskDataWrapper.Builder clearResultSize()

int64 result_size = 20;

Returns:

This builder for chaining.

getJvmGcTime

public long getJvmGcTime()

int64 jvm_gc_time = 21;

Specified by:

getJvmGcTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The jvmGcTime.

setJvmGcTime

public StoreTypes.TaskDataWrapper.Builder setJvmGcTime(long value)

int64 jvm_gc_time = 21;

Parameters:

value - The jvmGcTime to set.

Returns:

This builder for chaining.

clearJvmGcTime

public StoreTypes.TaskDataWrapper.Builder clearJvmGcTime()

int64 jvm_gc_time = 21;

Returns:

This builder for chaining.

getResultSerializationTime

public long getResultSerializationTime()

int64 result_serialization_time = 22;

Specified by:

getResultSerializationTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The resultSerializationTime.

setResultSerializationTime

public StoreTypes.TaskDataWrapper.Builder setResultSerializationTime(long value)

int64 result_serialization_time = 22;

Parameters:

value - The resultSerializationTime to set.

Returns:

This builder for chaining.

clearResultSerializationTime

public StoreTypes.TaskDataWrapper.Builder clearResultSerializationTime()

int64 result_serialization_time = 22;

Returns:

This builder for chaining.

getMemoryBytesSpilled

public long getMemoryBytesSpilled()

int64 memory_bytes_spilled = 23;

Specified by:

getMemoryBytesSpilled in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The memoryBytesSpilled.

setMemoryBytesSpilled

public StoreTypes.TaskDataWrapper.Builder setMemoryBytesSpilled(long value)

int64 memory_bytes_spilled = 23;

Parameters:

value - The memoryBytesSpilled to set.

Returns:

This builder for chaining.

clearMemoryBytesSpilled

public StoreTypes.TaskDataWrapper.Builder clearMemoryBytesSpilled()

int64 memory_bytes_spilled = 23;

Returns:

This builder for chaining.

getDiskBytesSpilled

public long getDiskBytesSpilled()

int64 disk_bytes_spilled = 24;

Specified by:

getDiskBytesSpilled in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The diskBytesSpilled.

setDiskBytesSpilled

public StoreTypes.TaskDataWrapper.Builder setDiskBytesSpilled(long value)

int64 disk_bytes_spilled = 24;

Parameters:

value - The diskBytesSpilled to set.

Returns:

This builder for chaining.

clearDiskBytesSpilled

public StoreTypes.TaskDataWrapper.Builder clearDiskBytesSpilled()

int64 disk_bytes_spilled = 24;

Returns:

This builder for chaining.

getPeakExecutionMemory

public long getPeakExecutionMemory()

int64 peak_execution_memory = 25;

Specified by:

getPeakExecutionMemory in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The peakExecutionMemory.

setPeakExecutionMemory

public StoreTypes.TaskDataWrapper.Builder setPeakExecutionMemory(long value)

int64 peak_execution_memory = 25;

Parameters:

value - The peakExecutionMemory to set.

Returns:

This builder for chaining.

clearPeakExecutionMemory

public StoreTypes.TaskDataWrapper.Builder clearPeakExecutionMemory()

int64 peak_execution_memory = 25;

Returns:

This builder for chaining.

getInputBytesRead

public long getInputBytesRead()

int64 input_bytes_read = 26;

Specified by:

getInputBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The inputBytesRead.

setInputBytesRead

public StoreTypes.TaskDataWrapper.Builder setInputBytesRead(long value)

int64 input_bytes_read = 26;

Parameters:

value - The inputBytesRead to set.

Returns:

This builder for chaining.

clearInputBytesRead

public StoreTypes.TaskDataWrapper.Builder clearInputBytesRead()

int64 input_bytes_read = 26;

Returns:

This builder for chaining.

getInputRecordsRead

public long getInputRecordsRead()

int64 input_records_read = 27;

Specified by:

getInputRecordsRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The inputRecordsRead.

setInputRecordsRead

public StoreTypes.TaskDataWrapper.Builder setInputRecordsRead(long value)

int64 input_records_read = 27;

Parameters:

value - The inputRecordsRead to set.

Returns:

This builder for chaining.

clearInputRecordsRead

public StoreTypes.TaskDataWrapper.Builder clearInputRecordsRead()

int64 input_records_read = 27;

Returns:

This builder for chaining.

getOutputBytesWritten

public long getOutputBytesWritten()

int64 output_bytes_written = 28;

Specified by:

getOutputBytesWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The outputBytesWritten.

setOutputBytesWritten

public StoreTypes.TaskDataWrapper.Builder setOutputBytesWritten(long value)

int64 output_bytes_written = 28;

Parameters:

value - The outputBytesWritten to set.

Returns:

This builder for chaining.

clearOutputBytesWritten

public StoreTypes.TaskDataWrapper.Builder clearOutputBytesWritten()

int64 output_bytes_written = 28;

Returns:

This builder for chaining.

getOutputRecordsWritten

public long getOutputRecordsWritten()

int64 output_records_written = 29;

Specified by:

getOutputRecordsWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The outputRecordsWritten.

setOutputRecordsWritten

public StoreTypes.TaskDataWrapper.Builder setOutputRecordsWritten(long value)

int64 output_records_written = 29;

Parameters:

value - The outputRecordsWritten to set.

Returns:

This builder for chaining.

clearOutputRecordsWritten

public StoreTypes.TaskDataWrapper.Builder clearOutputRecordsWritten()

int64 output_records_written = 29;

Returns:

This builder for chaining.

getShuffleRemoteBlocksFetched

public long getShuffleRemoteBlocksFetched()

int64 shuffle_remote_blocks_fetched = 30;

Specified by:

getShuffleRemoteBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteBlocksFetched.

setShuffleRemoteBlocksFetched

public StoreTypes.TaskDataWrapper.Builder setShuffleRemoteBlocksFetched(long value)

int64 shuffle_remote_blocks_fetched = 30;

Parameters:

value - The shuffleRemoteBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleRemoteBlocksFetched

public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteBlocksFetched()

int64 shuffle_remote_blocks_fetched = 30;

Returns:

This builder for chaining.

getShuffleLocalBlocksFetched

public long getShuffleLocalBlocksFetched()

int64 shuffle_local_blocks_fetched = 31;

Specified by:

getShuffleLocalBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleLocalBlocksFetched.

setShuffleLocalBlocksFetched

public StoreTypes.TaskDataWrapper.Builder setShuffleLocalBlocksFetched(long value)

int64 shuffle_local_blocks_fetched = 31;

Parameters:

value - The shuffleLocalBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleLocalBlocksFetched

public StoreTypes.TaskDataWrapper.Builder clearShuffleLocalBlocksFetched()

int64 shuffle_local_blocks_fetched = 31;

Returns:

This builder for chaining.

getShuffleFetchWaitTime

public long getShuffleFetchWaitTime()

int64 shuffle_fetch_wait_time = 32;

Specified by:

getShuffleFetchWaitTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleFetchWaitTime.

setShuffleFetchWaitTime

public StoreTypes.TaskDataWrapper.Builder setShuffleFetchWaitTime(long value)

int64 shuffle_fetch_wait_time = 32;

Parameters:

value - The shuffleFetchWaitTime to set.

Returns:

This builder for chaining.

clearShuffleFetchWaitTime

public StoreTypes.TaskDataWrapper.Builder clearShuffleFetchWaitTime()

int64 shuffle_fetch_wait_time = 32;

Returns:

This builder for chaining.

getShuffleRemoteBytesRead

public long getShuffleRemoteBytesRead()

int64 shuffle_remote_bytes_read = 33;

Specified by:

getShuffleRemoteBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteBytesRead.

setShuffleRemoteBytesRead

public StoreTypes.TaskDataWrapper.Builder setShuffleRemoteBytesRead(long value)

int64 shuffle_remote_bytes_read = 33;

Parameters:

value - The shuffleRemoteBytesRead to set.

Returns:

This builder for chaining.

clearShuffleRemoteBytesRead

public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteBytesRead()

int64 shuffle_remote_bytes_read = 33;

Returns:

This builder for chaining.

getShuffleRemoteBytesReadToDisk

public long getShuffleRemoteBytesReadToDisk()

int64 shuffle_remote_bytes_read_to_disk = 34;

Specified by:

getShuffleRemoteBytesReadToDisk in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteBytesReadToDisk.

setShuffleRemoteBytesReadToDisk

public StoreTypes.TaskDataWrapper.Builder setShuffleRemoteBytesReadToDisk(long value)

int64 shuffle_remote_bytes_read_to_disk = 34;

Parameters:

value - The shuffleRemoteBytesReadToDisk to set.

Returns:

This builder for chaining.

clearShuffleRemoteBytesReadToDisk

public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteBytesReadToDisk()

int64 shuffle_remote_bytes_read_to_disk = 34;

Returns:

This builder for chaining.

getShuffleLocalBytesRead

public long getShuffleLocalBytesRead()

int64 shuffle_local_bytes_read = 35;

Specified by:

getShuffleLocalBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleLocalBytesRead.

setShuffleLocalBytesRead

public StoreTypes.TaskDataWrapper.Builder setShuffleLocalBytesRead(long value)

int64 shuffle_local_bytes_read = 35;

Parameters:

value - The shuffleLocalBytesRead to set.

Returns:

This builder for chaining.

clearShuffleLocalBytesRead

public StoreTypes.TaskDataWrapper.Builder clearShuffleLocalBytesRead()

int64 shuffle_local_bytes_read = 35;

Returns:

This builder for chaining.

getShuffleRecordsRead

public long getShuffleRecordsRead()

int64 shuffle_records_read = 36;

Specified by:

getShuffleRecordsRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRecordsRead.

setShuffleRecordsRead

public StoreTypes.TaskDataWrapper.Builder setShuffleRecordsRead(long value)

int64 shuffle_records_read = 36;

Parameters:

value - The shuffleRecordsRead to set.

Returns:

This builder for chaining.

clearShuffleRecordsRead

public StoreTypes.TaskDataWrapper.Builder clearShuffleRecordsRead()

int64 shuffle_records_read = 36;

Returns:

This builder for chaining.

getShuffleBytesWritten

public long getShuffleBytesWritten()

int64 shuffle_bytes_written = 37;

Specified by:

getShuffleBytesWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleBytesWritten.

setShuffleBytesWritten

public StoreTypes.TaskDataWrapper.Builder setShuffleBytesWritten(long value)

int64 shuffle_bytes_written = 37;

Parameters:

value - The shuffleBytesWritten to set.

Returns:

This builder for chaining.

clearShuffleBytesWritten

public StoreTypes.TaskDataWrapper.Builder clearShuffleBytesWritten()

int64 shuffle_bytes_written = 37;

Returns:

This builder for chaining.

getShuffleWriteTime

public long getShuffleWriteTime()

int64 shuffle_write_time = 38;

Specified by:

getShuffleWriteTime in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleWriteTime.

setShuffleWriteTime

public StoreTypes.TaskDataWrapper.Builder setShuffleWriteTime(long value)

int64 shuffle_write_time = 38;

Parameters:

value - The shuffleWriteTime to set.

Returns:

This builder for chaining.

clearShuffleWriteTime

public StoreTypes.TaskDataWrapper.Builder clearShuffleWriteTime()

int64 shuffle_write_time = 38;

Returns:

This builder for chaining.

getShuffleRecordsWritten

public long getShuffleRecordsWritten()

int64 shuffle_records_written = 39;

Specified by:

getShuffleRecordsWritten in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRecordsWritten.

setShuffleRecordsWritten

public StoreTypes.TaskDataWrapper.Builder setShuffleRecordsWritten(long value)

int64 shuffle_records_written = 39;

Parameters:

value - The shuffleRecordsWritten to set.

Returns:

This builder for chaining.

clearShuffleRecordsWritten

public StoreTypes.TaskDataWrapper.Builder clearShuffleRecordsWritten()

int64 shuffle_records_written = 39;

Returns:

This builder for chaining.

getStageId

public long getStageId()

int64 stage_id = 40;

Specified by:

getStageId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The stageId.

setStageId

public StoreTypes.TaskDataWrapper.Builder setStageId(long value)

int64 stage_id = 40;

Parameters:

value - The stageId to set.

Returns:

This builder for chaining.

clearStageId

public StoreTypes.TaskDataWrapper.Builder clearStageId()

int64 stage_id = 40;

Returns:

This builder for chaining.

getStageAttemptId

public int getStageAttemptId()

int32 stage_attempt_id = 41;

Specified by:

getStageAttemptId in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The stageAttemptId.

setStageAttemptId

public StoreTypes.TaskDataWrapper.Builder setStageAttemptId(int value)

int32 stage_attempt_id = 41;

Parameters:

value - The stageAttemptId to set.

Returns:

This builder for chaining.

clearStageAttemptId

public StoreTypes.TaskDataWrapper.Builder clearStageAttemptId()

int32 stage_attempt_id = 41;

Returns:

This builder for chaining.

getShuffleCorruptMergedBlockChunks

public long getShuffleCorruptMergedBlockChunks()

int64 shuffle_corrupt_merged_block_chunks = 42;

Specified by:

getShuffleCorruptMergedBlockChunks in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleCorruptMergedBlockChunks.

setShuffleCorruptMergedBlockChunks

public StoreTypes.TaskDataWrapper.Builder setShuffleCorruptMergedBlockChunks(long value)

int64 shuffle_corrupt_merged_block_chunks = 42;

Parameters:

value - The shuffleCorruptMergedBlockChunks to set.

Returns:

This builder for chaining.

clearShuffleCorruptMergedBlockChunks

public StoreTypes.TaskDataWrapper.Builder clearShuffleCorruptMergedBlockChunks()

int64 shuffle_corrupt_merged_block_chunks = 42;

Returns:

This builder for chaining.

getShuffleMergedFetchFallbackCount

public long getShuffleMergedFetchFallbackCount()

int64 shuffle_merged_fetch_fallback_count = 43;

Specified by:

getShuffleMergedFetchFallbackCount in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedFetchFallbackCount.

setShuffleMergedFetchFallbackCount

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedFetchFallbackCount(long value)

int64 shuffle_merged_fetch_fallback_count = 43;

Parameters:

value - The shuffleMergedFetchFallbackCount to set.

Returns:

This builder for chaining.

clearShuffleMergedFetchFallbackCount

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedFetchFallbackCount()

int64 shuffle_merged_fetch_fallback_count = 43;

Returns:

This builder for chaining.

getShuffleMergedRemoteBlocksFetched

public long getShuffleMergedRemoteBlocksFetched()

int64 shuffle_merged_remote_blocks_fetched = 44;

Specified by:

getShuffleMergedRemoteBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteBlocksFetched.

setShuffleMergedRemoteBlocksFetched

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteBlocksFetched(long value)

int64 shuffle_merged_remote_blocks_fetched = 44;

Parameters:

value - The shuffleMergedRemoteBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteBlocksFetched

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteBlocksFetched()

int64 shuffle_merged_remote_blocks_fetched = 44;

Returns:

This builder for chaining.

getShuffleMergedLocalBlocksFetched

public long getShuffleMergedLocalBlocksFetched()

int64 shuffle_merged_local_blocks_fetched = 45;

Specified by:

getShuffleMergedLocalBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedLocalBlocksFetched.

setShuffleMergedLocalBlocksFetched

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedLocalBlocksFetched(long value)

int64 shuffle_merged_local_blocks_fetched = 45;

Parameters:

value - The shuffleMergedLocalBlocksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedLocalBlocksFetched

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedLocalBlocksFetched()

int64 shuffle_merged_local_blocks_fetched = 45;

Returns:

This builder for chaining.

getShuffleMergedRemoteChunksFetched

public long getShuffleMergedRemoteChunksFetched()

int64 shuffle_merged_remote_chunks_fetched = 46;

Specified by:

getShuffleMergedRemoteChunksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteChunksFetched.

setShuffleMergedRemoteChunksFetched

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteChunksFetched(long value)

int64 shuffle_merged_remote_chunks_fetched = 46;

Parameters:

value - The shuffleMergedRemoteChunksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteChunksFetched

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteChunksFetched()

int64 shuffle_merged_remote_chunks_fetched = 46;

Returns:

This builder for chaining.

getShuffleMergedLocalChunksFetched

public long getShuffleMergedLocalChunksFetched()

int64 shuffle_merged_local_chunks_fetched = 47;

Specified by:

getShuffleMergedLocalChunksFetched in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedLocalChunksFetched.

setShuffleMergedLocalChunksFetched

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedLocalChunksFetched(long value)

int64 shuffle_merged_local_chunks_fetched = 47;

Parameters:

value - The shuffleMergedLocalChunksFetched to set.

Returns:

This builder for chaining.

clearShuffleMergedLocalChunksFetched

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedLocalChunksFetched()

int64 shuffle_merged_local_chunks_fetched = 47;

Returns:

This builder for chaining.

getShuffleMergedRemoteBytesRead

public long getShuffleMergedRemoteBytesRead()

int64 shuffle_merged_remote_bytes_read = 48;

Specified by:

getShuffleMergedRemoteBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteBytesRead.

setShuffleMergedRemoteBytesRead

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteBytesRead(long value)

int64 shuffle_merged_remote_bytes_read = 48;

Parameters:

value - The shuffleMergedRemoteBytesRead to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteBytesRead

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteBytesRead()

int64 shuffle_merged_remote_bytes_read = 48;

Returns:

This builder for chaining.

getShuffleMergedLocalBytesRead

public long getShuffleMergedLocalBytesRead()

int64 shuffle_merged_local_bytes_read = 49;

Specified by:

getShuffleMergedLocalBytesRead in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedLocalBytesRead.

setShuffleMergedLocalBytesRead

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedLocalBytesRead(long value)

int64 shuffle_merged_local_bytes_read = 49;

Parameters:

value - The shuffleMergedLocalBytesRead to set.

Returns:

This builder for chaining.

clearShuffleMergedLocalBytesRead

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedLocalBytesRead()

int64 shuffle_merged_local_bytes_read = 49;

Returns:

This builder for chaining.

getShuffleRemoteReqsDuration

public long getShuffleRemoteReqsDuration()

int64 shuffle_remote_reqs_duration = 50;

Specified by:

getShuffleRemoteReqsDuration in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleRemoteReqsDuration.

setShuffleRemoteReqsDuration

public StoreTypes.TaskDataWrapper.Builder setShuffleRemoteReqsDuration(long value)

int64 shuffle_remote_reqs_duration = 50;

Parameters:

value - The shuffleRemoteReqsDuration to set.

Returns:

This builder for chaining.

clearShuffleRemoteReqsDuration

public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteReqsDuration()

int64 shuffle_remote_reqs_duration = 50;

Returns:

This builder for chaining.

getShuffleMergedRemoteReqDuration

public long getShuffleMergedRemoteReqDuration()

int64 shuffle_merged_remote_req_duration = 51;

Specified by:

getShuffleMergedRemoteReqDuration in interface StoreTypes.TaskDataWrapperOrBuilder

Returns:

The shuffleMergedRemoteReqDuration.

setShuffleMergedRemoteReqDuration

public StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteReqDuration(long value)

int64 shuffle_merged_remote_req_duration = 51;

Parameters:

value - The shuffleMergedRemoteReqDuration to set.

Returns:

This builder for chaining.

clearShuffleMergedRemoteReqDuration

public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteReqDuration()

int64 shuffle_merged_remote_req_duration = 51;

Returns:

This builder for chaining.