StoreTypes.TaskDataWrapperOrBuilder (Spark 3.4.2 JavaDoc)

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

StoreTypes.TaskDataWrapper, StoreTypes.TaskDataWrapper.Builder

Enclosing class:

StoreTypes
```
public static interface StoreTypes.TaskDataWrapperOrBuilder
extends com.google.protobuf.MessageOrBuilder
```

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`StoreTypes.AccumulableInfo`	`getAccumulatorUpdates(int index)` `repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;`
`int`	`getAccumulatorUpdatesCount()` `repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;`
`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;`
`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;`

Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder
isInitialized

- Method Detail
  - getTaskId
```
long getTaskId()
```
    int64 task_id = 1;
    
    Returns:
    
    The taskId.
  - getIndex
```
int getIndex()
```
    int32 index = 2;
    
    Returns:
    
    The index.
  - getAttempt
```
int getAttempt()
```
    int32 attempt = 3;
    
    Returns:
    
    The attempt.
  - getPartitionId
```
int getPartitionId()
```
    int32 partition_id = 4;
    
    Returns:
    
    The partitionId.
  - getLaunchTime
```
long getLaunchTime()
```
    int64 launch_time = 5;
    
    Returns:
    
    The launchTime.
  - getResultFetchStart
```
long getResultFetchStart()
```
    int64 result_fetch_start = 6;
    
    Returns:
    
    The resultFetchStart.
  - getDuration
```
long getDuration()
```
    int64 duration = 7;
    
    Returns:
    
    The duration.
  - hasExecutorId
```
boolean hasExecutorId()
```
    optional string executor_id = 8;
    
    Returns:
    
    Whether the executorId field is set.
  - getExecutorId
```
String getExecutorId()
```
    optional string executor_id = 8;
    
    Returns:
    
    The executorId.
  - getExecutorIdBytes
```
com.google.protobuf.ByteString getExecutorIdBytes()
```
    optional string executor_id = 8;
    
    Returns:
    
    The bytes for executorId.
  - hasHost
```
boolean hasHost()
```
    optional string host = 9;
    
    Returns:
    
    Whether the host field is set.
  - getHost
```
String getHost()
```
    optional string host = 9;
    
    Returns:
    
    The host.
  - getHostBytes
```
com.google.protobuf.ByteString getHostBytes()
```
    optional string host = 9;
    
    Returns:
    
    The bytes for host.
  - hasStatus
```
boolean hasStatus()
```
    optional string status = 10;
    
    Returns:
    
    Whether the status field is set.
  - getStatus
```
String getStatus()
```
    optional string status = 10;
    
    Returns:
    
    The status.
  - getStatusBytes
```
com.google.protobuf.ByteString getStatusBytes()
```
    optional string status = 10;
    
    Returns:
    
    The bytes for status.
  - hasTaskLocality
```
boolean hasTaskLocality()
```
    optional string task_locality = 11;
    
    Returns:
    
    Whether the taskLocality field is set.
  - getTaskLocality
```
String getTaskLocality()
```
    optional string task_locality = 11;
    
    Returns:
    
    The taskLocality.
  - getTaskLocalityBytes
```
com.google.protobuf.ByteString getTaskLocalityBytes()
```
    optional string task_locality = 11;
    
    Returns:
    
    The bytes for taskLocality.
  - getSpeculative
```
boolean getSpeculative()
```
    bool speculative = 12;
    
    Returns:
    
    The speculative.
  - getAccumulatorUpdatesList
```
java.util.List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
```
    repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
  - getAccumulatorUpdates
```
StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
```
    repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
  - getAccumulatorUpdatesCount
```
int getAccumulatorUpdatesCount()
```
    repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
  - getAccumulatorUpdatesOrBuilderList
```
java.util.List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
```
    repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
  - getAccumulatorUpdatesOrBuilder
```
StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
```
    repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;
  - hasErrorMessage
```
boolean hasErrorMessage()
```
    optional string error_message = 14;
    
    Returns:
    
    Whether the errorMessage field is set.
  - getErrorMessage
```
String getErrorMessage()
```
    optional string error_message = 14;
    
    Returns:
    
    The errorMessage.
  - getErrorMessageBytes
```
com.google.protobuf.ByteString getErrorMessageBytes()
```
    optional string error_message = 14;
    
    Returns:
    
    The bytes for errorMessage.
  - getHasMetrics
```
boolean getHasMetrics()
```
    bool has_metrics = 15;
    
    Returns:
    
    The hasMetrics.
  - getExecutorDeserializeTime
```
long getExecutorDeserializeTime()
```
    int64 executor_deserialize_time = 16;
    
    Returns:
    
    The executorDeserializeTime.
  - getExecutorDeserializeCpuTime
```
long getExecutorDeserializeCpuTime()
```
    int64 executor_deserialize_cpu_time = 17;
    
    Returns:
    
    The executorDeserializeCpuTime.
  - getExecutorRunTime
```
long getExecutorRunTime()
```
    int64 executor_run_time = 18;
    
    Returns:
    
    The executorRunTime.
  - getExecutorCpuTime
```
long getExecutorCpuTime()
```
    int64 executor_cpu_time = 19;
    
    Returns:
    
    The executorCpuTime.
  - getResultSize
```
long getResultSize()
```
    int64 result_size = 20;
    
    Returns:
    
    The resultSize.
  - getJvmGcTime
```
long getJvmGcTime()
```
    int64 jvm_gc_time = 21;
    
    Returns:
    
    The jvmGcTime.
  - getResultSerializationTime
```
long getResultSerializationTime()
```
    int64 result_serialization_time = 22;
    
    Returns:
    
    The resultSerializationTime.
  - getMemoryBytesSpilled
```
long getMemoryBytesSpilled()
```
    int64 memory_bytes_spilled = 23;
    
    Returns:
    
    The memoryBytesSpilled.
  - getDiskBytesSpilled
```
long getDiskBytesSpilled()
```
    int64 disk_bytes_spilled = 24;
    
    Returns:
    
    The diskBytesSpilled.
  - getPeakExecutionMemory
```
long getPeakExecutionMemory()
```
    int64 peak_execution_memory = 25;
    
    Returns:
    
    The peakExecutionMemory.
  - getInputBytesRead
```
long getInputBytesRead()
```
    int64 input_bytes_read = 26;
    
    Returns:
    
    The inputBytesRead.
  - getInputRecordsRead
```
long getInputRecordsRead()
```
    int64 input_records_read = 27;
    
    Returns:
    
    The inputRecordsRead.
  - getOutputBytesWritten
```
long getOutputBytesWritten()
```
    int64 output_bytes_written = 28;
    
    Returns:
    
    The outputBytesWritten.
  - getOutputRecordsWritten
```
long getOutputRecordsWritten()
```
    int64 output_records_written = 29;
    
    Returns:
    
    The outputRecordsWritten.
  - getShuffleRemoteBlocksFetched
```
long getShuffleRemoteBlocksFetched()
```
    int64 shuffle_remote_blocks_fetched = 30;
    
    Returns:
    
    The shuffleRemoteBlocksFetched.
  - getShuffleLocalBlocksFetched
```
long getShuffleLocalBlocksFetched()
```
    int64 shuffle_local_blocks_fetched = 31;
    
    Returns:
    
    The shuffleLocalBlocksFetched.
  - getShuffleFetchWaitTime
```
long getShuffleFetchWaitTime()
```
    int64 shuffle_fetch_wait_time = 32;
    
    Returns:
    
    The shuffleFetchWaitTime.
  - getShuffleRemoteBytesRead
```
long getShuffleRemoteBytesRead()
```
    int64 shuffle_remote_bytes_read = 33;
    
    Returns:
    
    The shuffleRemoteBytesRead.
  - getShuffleRemoteBytesReadToDisk
```
long getShuffleRemoteBytesReadToDisk()
```
    int64 shuffle_remote_bytes_read_to_disk = 34;
    
    Returns:
    
    The shuffleRemoteBytesReadToDisk.
  - getShuffleLocalBytesRead
```
long getShuffleLocalBytesRead()
```
    int64 shuffle_local_bytes_read = 35;
    
    Returns:
    
    The shuffleLocalBytesRead.
  - getShuffleRecordsRead
```
long getShuffleRecordsRead()
```
    int64 shuffle_records_read = 36;
    
    Returns:
    
    The shuffleRecordsRead.
  - getShuffleBytesWritten
```
long getShuffleBytesWritten()
```
    int64 shuffle_bytes_written = 37;
    
    Returns:
    
    The shuffleBytesWritten.
  - getShuffleWriteTime
```
long getShuffleWriteTime()
```
    int64 shuffle_write_time = 38;
    
    Returns:
    
    The shuffleWriteTime.
  - getShuffleRecordsWritten
```
long getShuffleRecordsWritten()
```
    int64 shuffle_records_written = 39;
    
    Returns:
    
    The shuffleRecordsWritten.
  - getStageId
```
long getStageId()
```
    int64 stage_id = 40;
    
    Returns:
    
    The stageId.
  - getStageAttemptId
```
int getStageAttemptId()
```
    int32 stage_attempt_id = 41;
    
    Returns:
    
    The stageAttemptId.
  - getShuffleCorruptMergedBlockChunks
```
long getShuffleCorruptMergedBlockChunks()
```
    int64 shuffle_corrupt_merged_block_chunks = 42;
    
    Returns:
    
    The shuffleCorruptMergedBlockChunks.
  - getShuffleMergedFetchFallbackCount
```
long getShuffleMergedFetchFallbackCount()
```
    int64 shuffle_merged_fetch_fallback_count = 43;
    
    Returns:
    
    The shuffleMergedFetchFallbackCount.
  - getShuffleMergedRemoteBlocksFetched
```
long getShuffleMergedRemoteBlocksFetched()
```
    int64 shuffle_merged_remote_blocks_fetched = 44;
    
    Returns:
    
    The shuffleMergedRemoteBlocksFetched.
  - getShuffleMergedLocalBlocksFetched
```
long getShuffleMergedLocalBlocksFetched()
```
    int64 shuffle_merged_local_blocks_fetched = 45;
    
    Returns:
    
    The shuffleMergedLocalBlocksFetched.
  - getShuffleMergedRemoteChunksFetched
```
long getShuffleMergedRemoteChunksFetched()
```
    int64 shuffle_merged_remote_chunks_fetched = 46;
    
    Returns:
    
    The shuffleMergedRemoteChunksFetched.
  - getShuffleMergedLocalChunksFetched
```
long getShuffleMergedLocalChunksFetched()
```
    int64 shuffle_merged_local_chunks_fetched = 47;
    
    Returns:
    
    The shuffleMergedLocalChunksFetched.
  - getShuffleMergedRemoteBytesRead
```
long getShuffleMergedRemoteBytesRead()
```
    int64 shuffle_merged_remote_bytes_read = 48;
    
    Returns:
    
    The shuffleMergedRemoteBytesRead.
  - getShuffleMergedLocalBytesRead
```
long getShuffleMergedLocalBytesRead()
```
    int64 shuffle_merged_local_bytes_read = 49;
    
    Returns:
    
    The shuffleMergedLocalBytesRead.
  - getShuffleRemoteReqsDuration
```
long getShuffleRemoteReqsDuration()
```
    int64 shuffle_remote_reqs_duration = 50;
    
    Returns:
    
    The shuffleRemoteReqsDuration.
  - getShuffleMergedRemoteReqDuration
```
long getShuffleMergedRemoteReqDuration()
```
    int64 shuffle_merged_remote_req_duration = 51;
    
    Returns:
    
    The shuffleMergedRemoteReqDuration.

Interface StoreTypes.TaskDataWrapperOrBuilder

Method Summary

Methods inherited from interface com.google.protobuf.MessageOrBuilder

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

Method Detail

getTaskId

getIndex

getAttempt

getPartitionId

getLaunchTime

getResultFetchStart

getDuration

hasExecutorId

getExecutorId

getExecutorIdBytes

hasHost

getHost

getHostBytes

hasStatus

getStatus

getStatusBytes

hasTaskLocality

getTaskLocality

getTaskLocalityBytes

getSpeculative

getAccumulatorUpdatesList

getAccumulatorUpdates

getAccumulatorUpdatesCount

getAccumulatorUpdatesOrBuilderList

getAccumulatorUpdatesOrBuilder

hasErrorMessage

getErrorMessage

getErrorMessageBytes

getHasMetrics

getExecutorDeserializeTime

getExecutorDeserializeCpuTime

getExecutorRunTime

getExecutorCpuTime

getResultSize

getJvmGcTime

getResultSerializationTime

getMemoryBytesSpilled

getDiskBytesSpilled

getPeakExecutionMemory

getInputBytesRead

getInputRecordsRead

getOutputBytesWritten

getOutputRecordsWritten

getShuffleRemoteBlocksFetched

getShuffleLocalBlocksFetched

getShuffleFetchWaitTime

getShuffleRemoteBytesRead

getShuffleRemoteBytesReadToDisk

getShuffleLocalBytesRead

getShuffleRecordsRead

getShuffleBytesWritten

getShuffleWriteTime

getShuffleRecordsWritten

getStageId

getStageAttemptId

getShuffleCorruptMergedBlockChunks

getShuffleMergedFetchFallbackCount

getShuffleMergedRemoteBlocksFetched

getShuffleMergedLocalBlocksFetched

getShuffleMergedRemoteChunksFetched

getShuffleMergedLocalChunksFetched

getShuffleMergedRemoteBytesRead

getShuffleMergedLocalBytesRead

getShuffleRemoteReqsDuration

getShuffleMergedRemoteReqDuration