Package org.apache.spark.status.protobuf
Class StoreTypes.TaskMetrics.Builder
Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskMetrics.Builder>
org.apache.spark.status.protobuf.StoreTypes.TaskMetrics.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder
,com.google.protobuf.MessageLite.Builder
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Cloneable
,StoreTypes.TaskMetricsOrBuilder
- Enclosing class:
- StoreTypes.TaskMetrics
public static final class StoreTypes.TaskMetrics.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskMetrics.Builder>
implements StoreTypes.TaskMetricsOrBuilder
Protobuf type
org.apache.spark.status.protobuf.TaskMetrics
-
Method Summary
Modifier and TypeMethodDescriptionbuild()
clear()
int64 disk_bytes_spilled = 9;
int64 executor_cpu_time = 4;
int64 executor_deserialize_cpu_time = 2;
int64 executor_deserialize_time = 1;
int64 executor_run_time = 3;
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
int64 jvm_gc_time = 6;
int64 memory_bytes_spilled = 8;
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
int64 peak_execution_memory = 10;
int64 result_serialization_time = 7;
int64 result_size = 5;
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
static final com.google.protobuf.Descriptors.Descriptor
com.google.protobuf.Descriptors.Descriptor
long
int64 disk_bytes_spilled = 9;
long
int64 executor_cpu_time = 4;
long
int64 executor_deserialize_cpu_time = 2;
long
int64 executor_deserialize_time = 1;
long
int64 executor_run_time = 3;
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
long
int64 jvm_gc_time = 6;
long
int64 memory_bytes_spilled = 8;
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
long
int64 peak_execution_memory = 10;
long
int64 result_serialization_time = 7;
long
int64 result_size = 5;
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
boolean
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
boolean
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
boolean
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
boolean
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
final boolean
mergeFrom
(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom
(com.google.protobuf.Message other) mergeFrom
(StoreTypes.TaskMetrics other) .org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
setDiskBytesSpilled
(long value) int64 disk_bytes_spilled = 9;
setExecutorCpuTime
(long value) int64 executor_cpu_time = 4;
setExecutorDeserializeCpuTime
(long value) int64 executor_deserialize_cpu_time = 2;
setExecutorDeserializeTime
(long value) int64 executor_deserialize_time = 1;
setExecutorRunTime
(long value) int64 executor_run_time = 3;
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
setInputMetrics
(StoreTypes.InputMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
setJvmGcTime
(long value) int64 jvm_gc_time = 6;
setMemoryBytesSpilled
(long value) int64 memory_bytes_spilled = 8;
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
setOutputMetrics
(StoreTypes.OutputMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
setPeakExecutionMemory
(long value) int64 peak_execution_memory = 10;
setResultSerializationTime
(long value) int64 result_serialization_time = 7;
setResultSize
(long value) int64 result_size = 5;
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
setShuffleReadMetrics
(StoreTypes.ShuffleReadMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
setShuffleWriteMetrics
(StoreTypes.ShuffleWriteMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
Methods inherited from class com.google.protobuf.GeneratedMessage.Builder
addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, mergeUnknownFields, newBuilderForField, setField, setRepeatedField, setUnknownFields
Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface com.google.protobuf.Message.Builder
mergeDelimitedFrom, mergeDelimitedFrom
Methods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFrom
Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
clear
- Specified by:
clear
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clear
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clear
in classcom.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskMetrics.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.Message.Builder
- Specified by:
getDescriptorForType
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getDescriptorForType
in classcom.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskMetrics.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
build
in interfacecom.google.protobuf.Message.Builder
- Specified by:
build
in interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartial
in interfacecom.google.protobuf.Message.Builder
- Specified by:
buildPartial
in interfacecom.google.protobuf.MessageLite.Builder
-
mergeFrom
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskMetrics.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskMetrics.Builder>
-
mergeFrom
public StoreTypes.TaskMetrics.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Specified by:
mergeFrom
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskMetrics.Builder>
- Throws:
IOException
-
getExecutorDeserializeTime
public long getExecutorDeserializeTime()int64 executor_deserialize_time = 1;
- Specified by:
getExecutorDeserializeTime
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The executorDeserializeTime.
-
setExecutorDeserializeTime
int64 executor_deserialize_time = 1;
- Parameters:
value
- The executorDeserializeTime to set.- Returns:
- This builder for chaining.
-
clearExecutorDeserializeTime
int64 executor_deserialize_time = 1;
- Returns:
- This builder for chaining.
-
getExecutorDeserializeCpuTime
public long getExecutorDeserializeCpuTime()int64 executor_deserialize_cpu_time = 2;
- Specified by:
getExecutorDeserializeCpuTime
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The executorDeserializeCpuTime.
-
setExecutorDeserializeCpuTime
int64 executor_deserialize_cpu_time = 2;
- Parameters:
value
- The executorDeserializeCpuTime to set.- Returns:
- This builder for chaining.
-
clearExecutorDeserializeCpuTime
int64 executor_deserialize_cpu_time = 2;
- Returns:
- This builder for chaining.
-
getExecutorRunTime
public long getExecutorRunTime()int64 executor_run_time = 3;
- Specified by:
getExecutorRunTime
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The executorRunTime.
-
setExecutorRunTime
int64 executor_run_time = 3;
- Parameters:
value
- The executorRunTime to set.- Returns:
- This builder for chaining.
-
clearExecutorRunTime
int64 executor_run_time = 3;
- Returns:
- This builder for chaining.
-
getExecutorCpuTime
public long getExecutorCpuTime()int64 executor_cpu_time = 4;
- Specified by:
getExecutorCpuTime
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The executorCpuTime.
-
setExecutorCpuTime
int64 executor_cpu_time = 4;
- Parameters:
value
- The executorCpuTime to set.- Returns:
- This builder for chaining.
-
clearExecutorCpuTime
int64 executor_cpu_time = 4;
- Returns:
- This builder for chaining.
-
getResultSize
public long getResultSize()int64 result_size = 5;
- Specified by:
getResultSize
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The resultSize.
-
setResultSize
int64 result_size = 5;
- Parameters:
value
- The resultSize to set.- Returns:
- This builder for chaining.
-
clearResultSize
int64 result_size = 5;
- Returns:
- This builder for chaining.
-
getJvmGcTime
public long getJvmGcTime()int64 jvm_gc_time = 6;
- Specified by:
getJvmGcTime
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The jvmGcTime.
-
setJvmGcTime
int64 jvm_gc_time = 6;
- Parameters:
value
- The jvmGcTime to set.- Returns:
- This builder for chaining.
-
clearJvmGcTime
int64 jvm_gc_time = 6;
- Returns:
- This builder for chaining.
-
getResultSerializationTime
public long getResultSerializationTime()int64 result_serialization_time = 7;
- Specified by:
getResultSerializationTime
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The resultSerializationTime.
-
setResultSerializationTime
int64 result_serialization_time = 7;
- Parameters:
value
- The resultSerializationTime to set.- Returns:
- This builder for chaining.
-
clearResultSerializationTime
int64 result_serialization_time = 7;
- Returns:
- This builder for chaining.
-
getMemoryBytesSpilled
public long getMemoryBytesSpilled()int64 memory_bytes_spilled = 8;
- Specified by:
getMemoryBytesSpilled
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The memoryBytesSpilled.
-
setMemoryBytesSpilled
int64 memory_bytes_spilled = 8;
- Parameters:
value
- The memoryBytesSpilled to set.- Returns:
- This builder for chaining.
-
clearMemoryBytesSpilled
int64 memory_bytes_spilled = 8;
- Returns:
- This builder for chaining.
-
getDiskBytesSpilled
public long getDiskBytesSpilled()int64 disk_bytes_spilled = 9;
- Specified by:
getDiskBytesSpilled
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The diskBytesSpilled.
-
setDiskBytesSpilled
int64 disk_bytes_spilled = 9;
- Parameters:
value
- The diskBytesSpilled to set.- Returns:
- This builder for chaining.
-
clearDiskBytesSpilled
int64 disk_bytes_spilled = 9;
- Returns:
- This builder for chaining.
-
getPeakExecutionMemory
public long getPeakExecutionMemory()int64 peak_execution_memory = 10;
- Specified by:
getPeakExecutionMemory
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The peakExecutionMemory.
-
setPeakExecutionMemory
int64 peak_execution_memory = 10;
- Parameters:
value
- The peakExecutionMemory to set.- Returns:
- This builder for chaining.
-
clearPeakExecutionMemory
int64 peak_execution_memory = 10;
- Returns:
- This builder for chaining.
-
hasInputMetrics
public boolean hasInputMetrics().org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
- Specified by:
hasInputMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- Whether the inputMetrics field is set.
-
getInputMetrics
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
- Specified by:
getInputMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The inputMetrics.
-
setInputMetrics
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
-
setInputMetrics
public StoreTypes.TaskMetrics.Builder setInputMetrics(StoreTypes.InputMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
-
mergeInputMetrics
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
-
clearInputMetrics
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
-
getInputMetricsBuilder
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
-
getInputMetricsOrBuilder
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;
- Specified by:
getInputMetricsOrBuilder
in interfaceStoreTypes.TaskMetricsOrBuilder
-
hasOutputMetrics
public boolean hasOutputMetrics().org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
- Specified by:
hasOutputMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- Whether the outputMetrics field is set.
-
getOutputMetrics
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
- Specified by:
getOutputMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The outputMetrics.
-
setOutputMetrics
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
-
setOutputMetrics
public StoreTypes.TaskMetrics.Builder setOutputMetrics(StoreTypes.OutputMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
-
mergeOutputMetrics
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
-
clearOutputMetrics
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
-
getOutputMetricsBuilder
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
-
getOutputMetricsOrBuilder
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;
- Specified by:
getOutputMetricsOrBuilder
in interfaceStoreTypes.TaskMetricsOrBuilder
-
hasShuffleReadMetrics
public boolean hasShuffleReadMetrics().org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
- Specified by:
hasShuffleReadMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- Whether the shuffleReadMetrics field is set.
-
getShuffleReadMetrics
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
- Specified by:
getShuffleReadMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The shuffleReadMetrics.
-
setShuffleReadMetrics
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
-
setShuffleReadMetrics
public StoreTypes.TaskMetrics.Builder setShuffleReadMetrics(StoreTypes.ShuffleReadMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
-
mergeShuffleReadMetrics
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
-
clearShuffleReadMetrics
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
-
getShuffleReadMetricsBuilder
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
-
getShuffleReadMetricsOrBuilder
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;
- Specified by:
getShuffleReadMetricsOrBuilder
in interfaceStoreTypes.TaskMetricsOrBuilder
-
hasShuffleWriteMetrics
public boolean hasShuffleWriteMetrics().org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
- Specified by:
hasShuffleWriteMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- Whether the shuffleWriteMetrics field is set.
-
getShuffleWriteMetrics
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
- Specified by:
getShuffleWriteMetrics
in interfaceStoreTypes.TaskMetricsOrBuilder
- Returns:
- The shuffleWriteMetrics.
-
setShuffleWriteMetrics
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
-
setShuffleWriteMetrics
public StoreTypes.TaskMetrics.Builder setShuffleWriteMetrics(StoreTypes.ShuffleWriteMetrics.Builder builderForValue) .org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
-
mergeShuffleWriteMetrics
public StoreTypes.TaskMetrics.Builder mergeShuffleWriteMetrics(StoreTypes.ShuffleWriteMetrics value) .org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
-
clearShuffleWriteMetrics
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
-
getShuffleWriteMetricsBuilder
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
-
getShuffleWriteMetricsOrBuilder
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;
- Specified by:
getShuffleWriteMetricsOrBuilder
in interfaceStoreTypes.TaskMetricsOrBuilder
-