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, newBuilderForField
findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.TaskDataWrapper.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>
public StoreTypes.TaskDataWrapper getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public StoreTypes.TaskDataWrapper build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.TaskDataWrapper buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.TaskDataWrapper.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
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.Builder
setField
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.Builder
clearField
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.Builder
clearOneof
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.Builder
setRepeatedField
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.Builder
addRepeatedField
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.Builder
mergeFrom
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.MessageLiteOrBuilder
isInitialized
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.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskDataWrapper.Builder>
java.io.IOException
public long getTaskId()
int64 task_id = 1;
getTaskId
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public String getExecutorId()
optional string executor_id = 8;
getExecutorId
in interface StoreTypes.TaskDataWrapperOrBuilder
public com.google.protobuf.ByteString getExecutorIdBytes()
optional string executor_id = 8;
getExecutorIdBytes
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public String getHost()
optional string host = 9;
getHost
in interface StoreTypes.TaskDataWrapperOrBuilder
public com.google.protobuf.ByteString getHostBytes()
optional string host = 9;
getHostBytes
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public String getStatus()
optional string status = 10;
getStatus
in interface StoreTypes.TaskDataWrapperOrBuilder
public com.google.protobuf.ByteString getStatusBytes()
optional string status = 10;
getStatusBytes
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public String getTaskLocality()
optional string task_locality = 11;
getTaskLocality
in interface StoreTypes.TaskDataWrapperOrBuilder
public com.google.protobuf.ByteString getTaskLocalityBytes()
optional string task_locality = 11;
getTaskLocalityBytes
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public int getAccumulatorUpdatesCount()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesCount
in interface StoreTypes.TaskDataWrapperOrBuilder
public StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdates
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
getAccumulatorUpdatesOrBuilderList
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public String getErrorMessage()
optional string error_message = 14;
getErrorMessage
in interface StoreTypes.TaskDataWrapperOrBuilder
public com.google.protobuf.ByteString getErrorMessageBytes()
optional string error_message = 14;
getErrorMessageBytes
in interface StoreTypes.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.TaskDataWrapperOrBuilder
public 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.Builder
setUnknownFields
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.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.TaskDataWrapper.Builder>