Package org.apache.spark.status.protobuf
Class StoreTypes.ExecutorStageSummary.Builder
Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ExecutorStageSummary.Builder>
org.apache.spark.status.protobuf.StoreTypes.ExecutorStageSummary.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Cloneable,StoreTypes.ExecutorStageSummaryOrBuilder
- Enclosing class:
- StoreTypes.ExecutorStageSummary
public static final class StoreTypes.ExecutorStageSummary.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.ExecutorStageSummary.Builder>
implements StoreTypes.ExecutorStageSummaryOrBuilder
Protobuf type
org.apache.spark.status.protobuf.ExecutorStageSummary-
Method Summary
Modifier and TypeMethodDescriptionbuild()clear()int64 disk_bytes_spilled = 14;int32 failed_tasks = 2;int64 input_bytes = 5;int64 input_records = 6;bool is_blacklisted_for_stage = 15;bool is_excluded_for_stage = 17;int32 killed_tasks = 4;int64 memory_bytes_spilled = 13;int64 output_bytes = 7;int64 output_records = 8;optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;int64 shuffle_read = 9;int64 shuffle_read_records = 10;int64 shuffle_write = 11;int64 shuffle_write_records = 12;int32 succeeded_tasks = 3;int64 task_time = 1;static final com.google.protobuf.Descriptors.Descriptorcom.google.protobuf.Descriptors.Descriptorlongint64 disk_bytes_spilled = 14;intint32 failed_tasks = 2;longint64 input_bytes = 5;longint64 input_records = 6;booleanbool is_blacklisted_for_stage = 15;booleanbool is_excluded_for_stage = 17;intint32 killed_tasks = 4;longint64 memory_bytes_spilled = 13;longint64 output_bytes = 7;longint64 output_records = 8;optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;longint64 shuffle_read = 9;longint64 shuffle_read_records = 10;longint64 shuffle_write = 11;longint64 shuffle_write_records = 12;intint32 succeeded_tasks = 3;longint64 task_time = 1;booleanoptional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;final booleanmergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom(com.google.protobuf.Message other) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;setDiskBytesSpilled(long value) int64 disk_bytes_spilled = 14;setFailedTasks(int value) int32 failed_tasks = 2;setInputBytes(long value) int64 input_bytes = 5;setInputRecords(long value) int64 input_records = 6;setIsBlacklistedForStage(boolean value) bool is_blacklisted_for_stage = 15;setIsExcludedForStage(boolean value) bool is_excluded_for_stage = 17;setKilledTasks(int value) int32 killed_tasks = 4;setMemoryBytesSpilled(long value) int64 memory_bytes_spilled = 13;setOutputBytes(long value) int64 output_bytes = 7;setOutputRecords(long value) int64 output_records = 8;optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;setPeakMemoryMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;setShuffleRead(long value) int64 shuffle_read = 9;setShuffleReadRecords(long value) int64 shuffle_read_records = 10;setShuffleWrite(long value) int64 shuffle_write = 11;setShuffleWriteRecords(long value) int64 shuffle_write_records = 12;setSucceededTasks(int value) int32 succeeded_tasks = 3;setTaskTime(long value) int64 task_time = 1;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.ExecutorStageSummary.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.ExecutorStageSummary.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.ExecutorStageSummary.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage.Builder<StoreTypes.ExecutorStageSummary.Builder>
-
mergeFrom
public StoreTypes.ExecutorStageSummary.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.ExecutorStageSummary.Builder>- Throws:
IOException
-
getTaskTime
public long getTaskTime()int64 task_time = 1;- Specified by:
getTaskTimein interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The taskTime.
-
setTaskTime
int64 task_time = 1;- Parameters:
value- The taskTime to set.- Returns:
- This builder for chaining.
-
clearTaskTime
int64 task_time = 1;- Returns:
- This builder for chaining.
-
getFailedTasks
public int getFailedTasks()int32 failed_tasks = 2;- Specified by:
getFailedTasksin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The failedTasks.
-
setFailedTasks
int32 failed_tasks = 2;- Parameters:
value- The failedTasks to set.- Returns:
- This builder for chaining.
-
clearFailedTasks
int32 failed_tasks = 2;- Returns:
- This builder for chaining.
-
getSucceededTasks
public int getSucceededTasks()int32 succeeded_tasks = 3;- Specified by:
getSucceededTasksin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The succeededTasks.
-
setSucceededTasks
int32 succeeded_tasks = 3;- Parameters:
value- The succeededTasks to set.- Returns:
- This builder for chaining.
-
clearSucceededTasks
int32 succeeded_tasks = 3;- Returns:
- This builder for chaining.
-
getKilledTasks
public int getKilledTasks()int32 killed_tasks = 4;- Specified by:
getKilledTasksin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The killedTasks.
-
setKilledTasks
int32 killed_tasks = 4;- Parameters:
value- The killedTasks to set.- Returns:
- This builder for chaining.
-
clearKilledTasks
int32 killed_tasks = 4;- Returns:
- This builder for chaining.
-
getInputBytes
public long getInputBytes()int64 input_bytes = 5;- Specified by:
getInputBytesin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The inputBytes.
-
setInputBytes
int64 input_bytes = 5;- Parameters:
value- The inputBytes to set.- Returns:
- This builder for chaining.
-
clearInputBytes
int64 input_bytes = 5;- Returns:
- This builder for chaining.
-
getInputRecords
public long getInputRecords()int64 input_records = 6;- Specified by:
getInputRecordsin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The inputRecords.
-
setInputRecords
int64 input_records = 6;- Parameters:
value- The inputRecords to set.- Returns:
- This builder for chaining.
-
clearInputRecords
int64 input_records = 6;- Returns:
- This builder for chaining.
-
getOutputBytes
public long getOutputBytes()int64 output_bytes = 7;- Specified by:
getOutputBytesin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The outputBytes.
-
setOutputBytes
int64 output_bytes = 7;- Parameters:
value- The outputBytes to set.- Returns:
- This builder for chaining.
-
clearOutputBytes
int64 output_bytes = 7;- Returns:
- This builder for chaining.
-
getOutputRecords
public long getOutputRecords()int64 output_records = 8;- Specified by:
getOutputRecordsin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The outputRecords.
-
setOutputRecords
int64 output_records = 8;- Parameters:
value- The outputRecords to set.- Returns:
- This builder for chaining.
-
clearOutputRecords
int64 output_records = 8;- Returns:
- This builder for chaining.
-
getShuffleRead
public long getShuffleRead()int64 shuffle_read = 9;- Specified by:
getShuffleReadin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The shuffleRead.
-
setShuffleRead
int64 shuffle_read = 9;- Parameters:
value- The shuffleRead to set.- Returns:
- This builder for chaining.
-
clearShuffleRead
int64 shuffle_read = 9;- Returns:
- This builder for chaining.
-
getShuffleReadRecords
public long getShuffleReadRecords()int64 shuffle_read_records = 10;- Specified by:
getShuffleReadRecordsin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The shuffleReadRecords.
-
setShuffleReadRecords
int64 shuffle_read_records = 10;- Parameters:
value- The shuffleReadRecords to set.- Returns:
- This builder for chaining.
-
clearShuffleReadRecords
int64 shuffle_read_records = 10;- Returns:
- This builder for chaining.
-
getShuffleWrite
public long getShuffleWrite()int64 shuffle_write = 11;- Specified by:
getShuffleWritein interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The shuffleWrite.
-
setShuffleWrite
int64 shuffle_write = 11;- Parameters:
value- The shuffleWrite to set.- Returns:
- This builder for chaining.
-
clearShuffleWrite
int64 shuffle_write = 11;- Returns:
- This builder for chaining.
-
getShuffleWriteRecords
public long getShuffleWriteRecords()int64 shuffle_write_records = 12;- Specified by:
getShuffleWriteRecordsin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The shuffleWriteRecords.
-
setShuffleWriteRecords
int64 shuffle_write_records = 12;- Parameters:
value- The shuffleWriteRecords to set.- Returns:
- This builder for chaining.
-
clearShuffleWriteRecords
int64 shuffle_write_records = 12;- Returns:
- This builder for chaining.
-
getMemoryBytesSpilled
public long getMemoryBytesSpilled()int64 memory_bytes_spilled = 13;- Specified by:
getMemoryBytesSpilledin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The memoryBytesSpilled.
-
setMemoryBytesSpilled
int64 memory_bytes_spilled = 13;- Parameters:
value- The memoryBytesSpilled to set.- Returns:
- This builder for chaining.
-
clearMemoryBytesSpilled
int64 memory_bytes_spilled = 13;- Returns:
- This builder for chaining.
-
getDiskBytesSpilled
public long getDiskBytesSpilled()int64 disk_bytes_spilled = 14;- Specified by:
getDiskBytesSpilledin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The diskBytesSpilled.
-
setDiskBytesSpilled
int64 disk_bytes_spilled = 14;- Parameters:
value- The diskBytesSpilled to set.- Returns:
- This builder for chaining.
-
clearDiskBytesSpilled
int64 disk_bytes_spilled = 14;- Returns:
- This builder for chaining.
-
getIsBlacklistedForStage
public boolean getIsBlacklistedForStage()bool is_blacklisted_for_stage = 15;- Specified by:
getIsBlacklistedForStagein interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The isBlacklistedForStage.
-
setIsBlacklistedForStage
bool is_blacklisted_for_stage = 15;- Parameters:
value- The isBlacklistedForStage to set.- Returns:
- This builder for chaining.
-
clearIsBlacklistedForStage
bool is_blacklisted_for_stage = 15;- Returns:
- This builder for chaining.
-
hasPeakMemoryMetrics
public boolean hasPeakMemoryMetrics()optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;- Specified by:
hasPeakMemoryMetricsin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- Whether the peakMemoryMetrics field is set.
-
getPeakMemoryMetrics
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;- Specified by:
getPeakMemoryMetricsin interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The peakMemoryMetrics.
-
setPeakMemoryMetrics
public StoreTypes.ExecutorStageSummary.Builder setPeakMemoryMetrics(StoreTypes.ExecutorMetrics value) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; -
setPeakMemoryMetrics
public StoreTypes.ExecutorStageSummary.Builder setPeakMemoryMetrics(StoreTypes.ExecutorMetrics.Builder builderForValue) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; -
mergePeakMemoryMetrics
public StoreTypes.ExecutorStageSummary.Builder mergePeakMemoryMetrics(StoreTypes.ExecutorMetrics value) optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; -
clearPeakMemoryMetrics
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; -
getPeakMemoryMetricsBuilder
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16; -
getPeakMemoryMetricsOrBuilder
optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;- Specified by:
getPeakMemoryMetricsOrBuilderin interfaceStoreTypes.ExecutorStageSummaryOrBuilder
-
getIsExcludedForStage
public boolean getIsExcludedForStage()bool is_excluded_for_stage = 17;- Specified by:
getIsExcludedForStagein interfaceStoreTypes.ExecutorStageSummaryOrBuilder- Returns:
- The isExcludedForStage.
-
setIsExcludedForStage
bool is_excluded_for_stage = 17;- Parameters:
value- The isExcludedForStage to set.- Returns:
- This builder for chaining.
-
clearIsExcludedForStage
bool is_excluded_for_stage = 17;- Returns:
- This builder for chaining.
-