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.Descriptorcom.google.protobuf.Descriptors.Descriptorlongint64 disk_bytes_spilled = 9;longint64 executor_cpu_time = 4;longint64 executor_deserialize_cpu_time = 2;longint64 executor_deserialize_time = 1;longint64 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;longint64 jvm_gc_time = 6;longint64 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;longint64 peak_execution_memory = 10;longint64 result_serialization_time = 7;longint64 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 booleanmergeFrom(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, setUnknownFieldsMethods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite.Builder
mergeDelimitedFrom, mergeDelimitedFrom, mergeFromMethods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.Message.Builder
mergeDelimitedFrom, mergeDelimitedFromMethods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFromMethods 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:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskMetrics.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessage.Builder<StoreTypes.TaskMetrics.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
mergeFrom
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskMetrics.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin 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:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<StoreTypes.TaskMetrics.Builder>- Throws:
IOException
-
getExecutorDeserializeTime
public long getExecutorDeserializeTime()int64 executor_deserialize_time = 1;- Specified by:
getExecutorDeserializeTimein 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:
getExecutorDeserializeCpuTimein 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:
getExecutorRunTimein 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:
getExecutorCpuTimein 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:
getResultSizein 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:
getJvmGcTimein 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:
getResultSerializationTimein 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:
getMemoryBytesSpilledin 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:
getDiskBytesSpilledin 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:
getPeakExecutionMemoryin 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:
hasInputMetricsin interfaceStoreTypes.TaskMetricsOrBuilder- Returns:
- Whether the inputMetrics field is set.
-
getInputMetrics
.org.apache.spark.status.protobuf.InputMetrics input_metrics = 11;- Specified by:
getInputMetricsin 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:
getInputMetricsOrBuilderin interfaceStoreTypes.TaskMetricsOrBuilder
-
hasOutputMetrics
public boolean hasOutputMetrics().org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;- Specified by:
hasOutputMetricsin interfaceStoreTypes.TaskMetricsOrBuilder- Returns:
- Whether the outputMetrics field is set.
-
getOutputMetrics
.org.apache.spark.status.protobuf.OutputMetrics output_metrics = 12;- Specified by:
getOutputMetricsin 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:
getOutputMetricsOrBuilderin interfaceStoreTypes.TaskMetricsOrBuilder
-
hasShuffleReadMetrics
public boolean hasShuffleReadMetrics().org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;- Specified by:
hasShuffleReadMetricsin interfaceStoreTypes.TaskMetricsOrBuilder- Returns:
- Whether the shuffleReadMetrics field is set.
-
getShuffleReadMetrics
.org.apache.spark.status.protobuf.ShuffleReadMetrics shuffle_read_metrics = 13;- Specified by:
getShuffleReadMetricsin 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:
getShuffleReadMetricsOrBuilderin interfaceStoreTypes.TaskMetricsOrBuilder
-
hasShuffleWriteMetrics
public boolean hasShuffleWriteMetrics().org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;- Specified by:
hasShuffleWriteMetricsin interfaceStoreTypes.TaskMetricsOrBuilder- Returns:
- Whether the shuffleWriteMetrics field is set.
-
getShuffleWriteMetrics
.org.apache.spark.status.protobuf.ShuffleWriteMetrics shuffle_write_metrics = 14;- Specified by:
getShuffleWriteMetricsin 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:
getShuffleWriteMetricsOrBuilderin interfaceStoreTypes.TaskMetricsOrBuilder
-