public static final class StoreTypes.TaskDataWrapper.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder> implements StoreTypes.TaskDataWrapperOrBuilder
org.apache.spark.status.protobuf.TaskDataWrapper| Modifier and Type | Method and Description |
|---|---|
StoreTypes.TaskDataWrapper.Builder |
addAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
StoreTypes.TaskDataWrapper.Builder |
addAccumulatorUpdates(int index,
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.TaskDataWrapper.Builder |
addAccumulatorUpdates(StoreTypes.AccumulableInfo value)
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.Builder |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
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 |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
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 |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
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.TaskDataWrapper.Builder |
clone() |
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; |
java.util.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; |
java.util.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; |
java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> |
getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13; |
int |
getAttempt()
int32 attempt = 3; |
StoreTypes.TaskDataWrapper |
getDefaultInstanceForType() |
static 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; |
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 |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
StoreTypes.TaskDataWrapper.Builder |
removeAccumulatorUpdates(int index)
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 |
setAccumulatorUpdates(int index,
StoreTypes.AccumulableInfo value)
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 |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
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 |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
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; |
StoreTypes.TaskDataWrapper.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForFieldfindInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toStringpublic static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.TaskDataWrapper.Builder clear()
clear in interface com.google.protobuf.Message.Builderclear in interface com.google.protobuf.MessageLite.Builderclear in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType in interface com.google.protobuf.Message.BuildergetDescriptorForType in interface com.google.protobuf.MessageOrBuildergetDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderpublic StoreTypes.TaskDataWrapper build()
build in interface com.google.protobuf.Message.Builderbuild in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.TaskDataWrapper buildPartial()
buildPartial in interface com.google.protobuf.Message.BuilderbuildPartial in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.TaskDataWrapper.Builder clone()
clone in interface com.google.protobuf.Message.Builderclone in interface com.google.protobuf.MessageLite.Builderclone in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField in interface com.google.protobuf.Message.BuildersetField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField in interface com.google.protobuf.Message.BuilderclearField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof in interface com.google.protobuf.Message.BuilderclearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField in interface com.google.protobuf.Message.BuildersetRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField in interface com.google.protobuf.Message.BuilderaddRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder mergeFrom(StoreTypes.TaskDataWrapper other)
public final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public StoreTypes.TaskDataWrapper.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in interface com.google.protobuf.MessageLite.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskDataWrapper.Builder>java.io.IOExceptionpublic long getTaskId()
int64 task_id = 1;getTaskId in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setTaskId(long value)
int64 task_id = 1;value - The taskId to set.public StoreTypes.TaskDataWrapper.Builder clearTaskId()
int64 task_id = 1;public int getIndex()
int32 index = 2;getIndex in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setIndex(int value)
int32 index = 2;value - The index to set.public StoreTypes.TaskDataWrapper.Builder clearIndex()
int32 index = 2;public int getAttempt()
int32 attempt = 3;getAttempt in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setAttempt(int value)
int32 attempt = 3;value - The attempt to set.public StoreTypes.TaskDataWrapper.Builder clearAttempt()
int32 attempt = 3;public int getPartitionId()
int32 partition_id = 4;getPartitionId in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setPartitionId(int value)
int32 partition_id = 4;value - The partitionId to set.public StoreTypes.TaskDataWrapper.Builder clearPartitionId()
int32 partition_id = 4;public long getLaunchTime()
int64 launch_time = 5;getLaunchTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setLaunchTime(long value)
int64 launch_time = 5;value - The launchTime to set.public StoreTypes.TaskDataWrapper.Builder clearLaunchTime()
int64 launch_time = 5;public long getResultFetchStart()
int64 result_fetch_start = 6;getResultFetchStart in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setResultFetchStart(long value)
int64 result_fetch_start = 6;value - The resultFetchStart to set.public StoreTypes.TaskDataWrapper.Builder clearResultFetchStart()
int64 result_fetch_start = 6;public long getDuration()
int64 duration = 7;getDuration in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setDuration(long value)
int64 duration = 7;value - The duration to set.public StoreTypes.TaskDataWrapper.Builder clearDuration()
int64 duration = 7;public boolean hasExecutorId()
optional string executor_id = 8;hasExecutorId in interface StoreTypes.TaskDataWrapperOrBuilderpublic String getExecutorId()
optional string executor_id = 8;getExecutorId in interface StoreTypes.TaskDataWrapperOrBuilderpublic com.google.protobuf.ByteString getExecutorIdBytes()
optional string executor_id = 8;getExecutorIdBytes in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setExecutorId(String value)
optional string executor_id = 8;value - The executorId to set.public StoreTypes.TaskDataWrapper.Builder clearExecutorId()
optional string executor_id = 8;public StoreTypes.TaskDataWrapper.Builder setExecutorIdBytes(com.google.protobuf.ByteString value)
optional string executor_id = 8;value - The bytes for executorId to set.public boolean hasHost()
optional string host = 9;hasHost in interface StoreTypes.TaskDataWrapperOrBuilderpublic String getHost()
optional string host = 9;getHost in interface StoreTypes.TaskDataWrapperOrBuilderpublic com.google.protobuf.ByteString getHostBytes()
optional string host = 9;getHostBytes in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setHost(String value)
optional string host = 9;value - The host to set.public StoreTypes.TaskDataWrapper.Builder clearHost()
optional string host = 9;public StoreTypes.TaskDataWrapper.Builder setHostBytes(com.google.protobuf.ByteString value)
optional string host = 9;value - The bytes for host to set.public boolean hasStatus()
optional string status = 10;hasStatus in interface StoreTypes.TaskDataWrapperOrBuilderpublic String getStatus()
optional string status = 10;getStatus in interface StoreTypes.TaskDataWrapperOrBuilderpublic com.google.protobuf.ByteString getStatusBytes()
optional string status = 10;getStatusBytes in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setStatus(String value)
optional string status = 10;value - The status to set.public StoreTypes.TaskDataWrapper.Builder clearStatus()
optional string status = 10;public StoreTypes.TaskDataWrapper.Builder setStatusBytes(com.google.protobuf.ByteString value)
optional string status = 10;value - The bytes for status to set.public boolean hasTaskLocality()
optional string task_locality = 11;hasTaskLocality in interface StoreTypes.TaskDataWrapperOrBuilderpublic String getTaskLocality()
optional string task_locality = 11;getTaskLocality in interface StoreTypes.TaskDataWrapperOrBuilderpublic com.google.protobuf.ByteString getTaskLocalityBytes()
optional string task_locality = 11;getTaskLocalityBytes in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setTaskLocality(String value)
optional string task_locality = 11;value - The taskLocality to set.public StoreTypes.TaskDataWrapper.Builder clearTaskLocality()
optional string task_locality = 11;public StoreTypes.TaskDataWrapper.Builder setTaskLocalityBytes(com.google.protobuf.ByteString value)
optional string task_locality = 11;value - The bytes for taskLocality to set.public boolean getSpeculative()
bool speculative = 12;getSpeculative in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setSpeculative(boolean value)
bool speculative = 12;value - The speculative to set.public StoreTypes.TaskDataWrapper.Builder clearSpeculative()
bool speculative = 12;public java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesList in interface StoreTypes.TaskDataWrapperOrBuilderpublic int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesCount in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdates in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder setAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo value)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder addAccumulatorUpdates(int index, StoreTypes.AccumulableInfo.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder addAllAccumulatorUpdates(Iterable<? extends StoreTypes.AccumulableInfo> values)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder clearAccumulatorUpdates()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.TaskDataWrapper.Builder removeAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.AccumulableInfo.Builder getAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesOrBuilder in interface StoreTypes.TaskDataWrapperOrBuilderpublic java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;getAccumulatorUpdatesOrBuilderList in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public StoreTypes.AccumulableInfo.Builder addAccumulatorUpdatesBuilder(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public java.util.List<StoreTypes.AccumulableInfo.Builder> getAccumulatorUpdatesBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;public boolean hasErrorMessage()
optional string error_message = 14;hasErrorMessage in interface StoreTypes.TaskDataWrapperOrBuilderpublic String getErrorMessage()
optional string error_message = 14;getErrorMessage in interface StoreTypes.TaskDataWrapperOrBuilderpublic com.google.protobuf.ByteString getErrorMessageBytes()
optional string error_message = 14;getErrorMessageBytes in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setErrorMessage(String value)
optional string error_message = 14;value - The errorMessage to set.public StoreTypes.TaskDataWrapper.Builder clearErrorMessage()
optional string error_message = 14;public StoreTypes.TaskDataWrapper.Builder setErrorMessageBytes(com.google.protobuf.ByteString value)
optional string error_message = 14;value - The bytes for errorMessage to set.public boolean getHasMetrics()
bool has_metrics = 15;getHasMetrics in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setHasMetrics(boolean value)
bool has_metrics = 15;value - The hasMetrics to set.public StoreTypes.TaskDataWrapper.Builder clearHasMetrics()
bool has_metrics = 15;public long getExecutorDeserializeTime()
int64 executor_deserialize_time = 16;getExecutorDeserializeTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setExecutorDeserializeTime(long value)
int64 executor_deserialize_time = 16;value - The executorDeserializeTime to set.public StoreTypes.TaskDataWrapper.Builder clearExecutorDeserializeTime()
int64 executor_deserialize_time = 16;public long getExecutorDeserializeCpuTime()
int64 executor_deserialize_cpu_time = 17;getExecutorDeserializeCpuTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setExecutorDeserializeCpuTime(long value)
int64 executor_deserialize_cpu_time = 17;value - The executorDeserializeCpuTime to set.public StoreTypes.TaskDataWrapper.Builder clearExecutorDeserializeCpuTime()
int64 executor_deserialize_cpu_time = 17;public long getExecutorRunTime()
int64 executor_run_time = 18;getExecutorRunTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setExecutorRunTime(long value)
int64 executor_run_time = 18;value - The executorRunTime to set.public StoreTypes.TaskDataWrapper.Builder clearExecutorRunTime()
int64 executor_run_time = 18;public long getExecutorCpuTime()
int64 executor_cpu_time = 19;getExecutorCpuTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setExecutorCpuTime(long value)
int64 executor_cpu_time = 19;value - The executorCpuTime to set.public StoreTypes.TaskDataWrapper.Builder clearExecutorCpuTime()
int64 executor_cpu_time = 19;public long getResultSize()
int64 result_size = 20;getResultSize in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setResultSize(long value)
int64 result_size = 20;value - The resultSize to set.public StoreTypes.TaskDataWrapper.Builder clearResultSize()
int64 result_size = 20;public long getJvmGcTime()
int64 jvm_gc_time = 21;getJvmGcTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setJvmGcTime(long value)
int64 jvm_gc_time = 21;value - The jvmGcTime to set.public StoreTypes.TaskDataWrapper.Builder clearJvmGcTime()
int64 jvm_gc_time = 21;public long getResultSerializationTime()
int64 result_serialization_time = 22;getResultSerializationTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setResultSerializationTime(long value)
int64 result_serialization_time = 22;value - The resultSerializationTime to set.public StoreTypes.TaskDataWrapper.Builder clearResultSerializationTime()
int64 result_serialization_time = 22;public long getMemoryBytesSpilled()
int64 memory_bytes_spilled = 23;getMemoryBytesSpilled in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setMemoryBytesSpilled(long value)
int64 memory_bytes_spilled = 23;value - The memoryBytesSpilled to set.public StoreTypes.TaskDataWrapper.Builder clearMemoryBytesSpilled()
int64 memory_bytes_spilled = 23;public long getDiskBytesSpilled()
int64 disk_bytes_spilled = 24;getDiskBytesSpilled in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setDiskBytesSpilled(long value)
int64 disk_bytes_spilled = 24;value - The diskBytesSpilled to set.public StoreTypes.TaskDataWrapper.Builder clearDiskBytesSpilled()
int64 disk_bytes_spilled = 24;public long getPeakExecutionMemory()
int64 peak_execution_memory = 25;getPeakExecutionMemory in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setPeakExecutionMemory(long value)
int64 peak_execution_memory = 25;value - The peakExecutionMemory to set.public StoreTypes.TaskDataWrapper.Builder clearPeakExecutionMemory()
int64 peak_execution_memory = 25;public long getInputBytesRead()
int64 input_bytes_read = 26;getInputBytesRead in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setInputBytesRead(long value)
int64 input_bytes_read = 26;value - The inputBytesRead to set.public StoreTypes.TaskDataWrapper.Builder clearInputBytesRead()
int64 input_bytes_read = 26;public long getInputRecordsRead()
int64 input_records_read = 27;getInputRecordsRead in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setInputRecordsRead(long value)
int64 input_records_read = 27;value - The inputRecordsRead to set.public StoreTypes.TaskDataWrapper.Builder clearInputRecordsRead()
int64 input_records_read = 27;public long getOutputBytesWritten()
int64 output_bytes_written = 28;getOutputBytesWritten in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setOutputBytesWritten(long value)
int64 output_bytes_written = 28;value - The outputBytesWritten to set.public StoreTypes.TaskDataWrapper.Builder clearOutputBytesWritten()
int64 output_bytes_written = 28;public long getOutputRecordsWritten()
int64 output_records_written = 29;getOutputRecordsWritten in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setOutputRecordsWritten(long value)
int64 output_records_written = 29;value - The outputRecordsWritten to set.public StoreTypes.TaskDataWrapper.Builder clearOutputRecordsWritten()
int64 output_records_written = 29;public long getShuffleRemoteBlocksFetched()
int64 shuffle_remote_blocks_fetched = 30;getShuffleRemoteBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleRemoteBlocksFetched(long value)
int64 shuffle_remote_blocks_fetched = 30;value - The shuffleRemoteBlocksFetched to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteBlocksFetched()
int64 shuffle_remote_blocks_fetched = 30;public long getShuffleLocalBlocksFetched()
int64 shuffle_local_blocks_fetched = 31;getShuffleLocalBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleLocalBlocksFetched(long value)
int64 shuffle_local_blocks_fetched = 31;value - The shuffleLocalBlocksFetched to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleLocalBlocksFetched()
int64 shuffle_local_blocks_fetched = 31;public long getShuffleFetchWaitTime()
int64 shuffle_fetch_wait_time = 32;getShuffleFetchWaitTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleFetchWaitTime(long value)
int64 shuffle_fetch_wait_time = 32;value - The shuffleFetchWaitTime to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleFetchWaitTime()
int64 shuffle_fetch_wait_time = 32;public long getShuffleRemoteBytesRead()
int64 shuffle_remote_bytes_read = 33;getShuffleRemoteBytesRead in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleRemoteBytesRead(long value)
int64 shuffle_remote_bytes_read = 33;value - The shuffleRemoteBytesRead to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteBytesRead()
int64 shuffle_remote_bytes_read = 33;public long getShuffleRemoteBytesReadToDisk()
int64 shuffle_remote_bytes_read_to_disk = 34;getShuffleRemoteBytesReadToDisk in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleRemoteBytesReadToDisk(long value)
int64 shuffle_remote_bytes_read_to_disk = 34;value - The shuffleRemoteBytesReadToDisk to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteBytesReadToDisk()
int64 shuffle_remote_bytes_read_to_disk = 34;public long getShuffleLocalBytesRead()
int64 shuffle_local_bytes_read = 35;getShuffleLocalBytesRead in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleLocalBytesRead(long value)
int64 shuffle_local_bytes_read = 35;value - The shuffleLocalBytesRead to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleLocalBytesRead()
int64 shuffle_local_bytes_read = 35;public long getShuffleRecordsRead()
int64 shuffle_records_read = 36;getShuffleRecordsRead in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleRecordsRead(long value)
int64 shuffle_records_read = 36;value - The shuffleRecordsRead to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleRecordsRead()
int64 shuffle_records_read = 36;public long getShuffleBytesWritten()
int64 shuffle_bytes_written = 37;getShuffleBytesWritten in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleBytesWritten(long value)
int64 shuffle_bytes_written = 37;value - The shuffleBytesWritten to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleBytesWritten()
int64 shuffle_bytes_written = 37;public long getShuffleWriteTime()
int64 shuffle_write_time = 38;getShuffleWriteTime in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleWriteTime(long value)
int64 shuffle_write_time = 38;value - The shuffleWriteTime to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleWriteTime()
int64 shuffle_write_time = 38;public long getShuffleRecordsWritten()
int64 shuffle_records_written = 39;getShuffleRecordsWritten in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleRecordsWritten(long value)
int64 shuffle_records_written = 39;value - The shuffleRecordsWritten to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleRecordsWritten()
int64 shuffle_records_written = 39;public long getStageId()
int64 stage_id = 40;getStageId in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setStageId(long value)
int64 stage_id = 40;value - The stageId to set.public StoreTypes.TaskDataWrapper.Builder clearStageId()
int64 stage_id = 40;public int getStageAttemptId()
int32 stage_attempt_id = 41;getStageAttemptId in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setStageAttemptId(int value)
int32 stage_attempt_id = 41;value - The stageAttemptId to set.public StoreTypes.TaskDataWrapper.Builder clearStageAttemptId()
int32 stage_attempt_id = 41;public long getShuffleCorruptMergedBlockChunks()
int64 shuffle_corrupt_merged_block_chunks = 42;getShuffleCorruptMergedBlockChunks in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleCorruptMergedBlockChunks(long value)
int64 shuffle_corrupt_merged_block_chunks = 42;value - The shuffleCorruptMergedBlockChunks to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleCorruptMergedBlockChunks()
int64 shuffle_corrupt_merged_block_chunks = 42;public long getShuffleMergedFetchFallbackCount()
int64 shuffle_merged_fetch_fallback_count = 43;getShuffleMergedFetchFallbackCount in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedFetchFallbackCount(long value)
int64 shuffle_merged_fetch_fallback_count = 43;value - The shuffleMergedFetchFallbackCount to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedFetchFallbackCount()
int64 shuffle_merged_fetch_fallback_count = 43;public long getShuffleMergedRemoteBlocksFetched()
int64 shuffle_merged_remote_blocks_fetched = 44;getShuffleMergedRemoteBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteBlocksFetched(long value)
int64 shuffle_merged_remote_blocks_fetched = 44;value - The shuffleMergedRemoteBlocksFetched to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteBlocksFetched()
int64 shuffle_merged_remote_blocks_fetched = 44;public long getShuffleMergedLocalBlocksFetched()
int64 shuffle_merged_local_blocks_fetched = 45;getShuffleMergedLocalBlocksFetched in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedLocalBlocksFetched(long value)
int64 shuffle_merged_local_blocks_fetched = 45;value - The shuffleMergedLocalBlocksFetched to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedLocalBlocksFetched()
int64 shuffle_merged_local_blocks_fetched = 45;public long getShuffleMergedRemoteChunksFetched()
int64 shuffle_merged_remote_chunks_fetched = 46;getShuffleMergedRemoteChunksFetched in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteChunksFetched(long value)
int64 shuffle_merged_remote_chunks_fetched = 46;value - The shuffleMergedRemoteChunksFetched to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteChunksFetched()
int64 shuffle_merged_remote_chunks_fetched = 46;public long getShuffleMergedLocalChunksFetched()
int64 shuffle_merged_local_chunks_fetched = 47;getShuffleMergedLocalChunksFetched in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedLocalChunksFetched(long value)
int64 shuffle_merged_local_chunks_fetched = 47;value - The shuffleMergedLocalChunksFetched to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedLocalChunksFetched()
int64 shuffle_merged_local_chunks_fetched = 47;public long getShuffleMergedRemoteBytesRead()
int64 shuffle_merged_remote_bytes_read = 48;getShuffleMergedRemoteBytesRead in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteBytesRead(long value)
int64 shuffle_merged_remote_bytes_read = 48;value - The shuffleMergedRemoteBytesRead to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteBytesRead()
int64 shuffle_merged_remote_bytes_read = 48;public long getShuffleMergedLocalBytesRead()
int64 shuffle_merged_local_bytes_read = 49;getShuffleMergedLocalBytesRead in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedLocalBytesRead(long value)
int64 shuffle_merged_local_bytes_read = 49;value - The shuffleMergedLocalBytesRead to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedLocalBytesRead()
int64 shuffle_merged_local_bytes_read = 49;public long getShuffleRemoteReqsDuration()
int64 shuffle_remote_reqs_duration = 50;getShuffleRemoteReqsDuration in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleRemoteReqsDuration(long value)
int64 shuffle_remote_reqs_duration = 50;value - The shuffleRemoteReqsDuration to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleRemoteReqsDuration()
int64 shuffle_remote_reqs_duration = 50;public long getShuffleMergedRemoteReqDuration()
int64 shuffle_merged_remote_req_duration = 51;getShuffleMergedRemoteReqDuration in interface StoreTypes.TaskDataWrapperOrBuilderpublic StoreTypes.TaskDataWrapper.Builder setShuffleMergedRemoteReqDuration(long value)
int64 shuffle_merged_remote_req_duration = 51;value - The shuffleMergedRemoteReqDuration to set.public StoreTypes.TaskDataWrapper.Builder clearShuffleMergedRemoteReqDuration()
int64 shuffle_merged_remote_req_duration = 51;public final StoreTypes.TaskDataWrapper.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields in interface com.google.protobuf.Message.BuildersetUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>public final StoreTypes.TaskDataWrapper.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields in interface com.google.protobuf.Message.BuildermergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>