Package org.apache.spark.status.protobuf
Class StoreTypes.StateOperatorProgress.Builder
Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderType>
com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
org.apache.spark.status.protobuf.StoreTypes.StateOperatorProgress.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder
,com.google.protobuf.MessageLite.Builder
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,Cloneable
,StoreTypes.StateOperatorProgressOrBuilder
- Enclosing class:
- StoreTypes.StateOperatorProgress
public static final class StoreTypes.StateOperatorProgress.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
implements StoreTypes.StateOperatorProgressOrBuilder
Protobuf type
org.apache.spark.status.protobuf.StateOperatorProgress
-
Method Summary
Modifier and TypeMethodDescriptionaddRepeatedField
(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) build()
clear()
int64 all_removals_time_ms = 6;
int64 all_updates_time_ms = 4;
int64 commit_time_ms = 7;
clearField
(com.google.protobuf.Descriptors.FieldDescriptor field) int64 memory_used_bytes = 8;
int64 num_rows_dropped_by_watermark = 9;
int64 num_rows_removed = 5;
int64 num_rows_total = 2;
int64 num_rows_updated = 3;
int64 num_shuffle_partitions = 10;
int64 num_state_store_instances = 11;
clearOneof
(com.google.protobuf.Descriptors.OneofDescriptor oneof) optional string operator_name = 1;
clone()
boolean
map<string, int64> custom_metrics = 12;
long
int64 all_removals_time_ms = 6;
long
int64 all_updates_time_ms = 4;
long
int64 commit_time_ms = 7;
Deprecated.int
map<string, int64> custom_metrics = 12;
map<string, int64> custom_metrics = 12;
long
getCustomMetricsOrDefault
(String key, long defaultValue) map<string, int64> custom_metrics = 12;
long
map<string, int64> custom_metrics = 12;
static final com.google.protobuf.Descriptors.Descriptor
com.google.protobuf.Descriptors.Descriptor
long
int64 memory_used_bytes = 8;
Deprecated.long
int64 num_rows_dropped_by_watermark = 9;
long
int64 num_rows_removed = 5;
long
int64 num_rows_total = 2;
long
int64 num_rows_updated = 3;
long
int64 num_shuffle_partitions = 10;
long
int64 num_state_store_instances = 11;
optional string operator_name = 1;
com.google.protobuf.ByteString
optional string operator_name = 1;
boolean
optional string operator_name = 1;
final boolean
mergeFrom
(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom
(com.google.protobuf.Message other) mergeUnknownFields
(com.google.protobuf.UnknownFieldSet unknownFields) putAllCustomMetrics
(Map<String, Long> values) map<string, int64> custom_metrics = 12;
putCustomMetrics
(String key, long value) map<string, int64> custom_metrics = 12;
map<string, int64> custom_metrics = 12;
setAllRemovalsTimeMs
(long value) int64 all_removals_time_ms = 6;
setAllUpdatesTimeMs
(long value) int64 all_updates_time_ms = 4;
setCommitTimeMs
(long value) int64 commit_time_ms = 7;
setMemoryUsedBytes
(long value) int64 memory_used_bytes = 8;
setNumRowsDroppedByWatermark
(long value) int64 num_rows_dropped_by_watermark = 9;
setNumRowsRemoved
(long value) int64 num_rows_removed = 5;
setNumRowsTotal
(long value) int64 num_rows_total = 2;
setNumRowsUpdated
(long value) int64 num_rows_updated = 3;
setNumShufflePartitions
(long value) int64 num_shuffle_partitions = 10;
setNumStateStoreInstances
(long value) int64 num_state_store_instances = 11;
setOperatorName
(String value) optional string operator_name = 1;
setOperatorNameBytes
(com.google.protobuf.ByteString value) optional string operator_name = 1;
setRepeatedField
(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) setUnknownFields
(com.google.protobuf.UnknownFieldSet unknownFields) Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForField
Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder
mergeFrom
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
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.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.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.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.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
-
clone
- Specified by:
clone
in interfacecom.google.protobuf.Message.Builder
- Specified by:
clone
in interfacecom.google.protobuf.MessageLite.Builder
- Overrides:
clone
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
setField
public StoreTypes.StateOperatorProgress.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
setField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
clearField
public StoreTypes.StateOperatorProgress.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) - Specified by:
clearField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
clearOneof
public StoreTypes.StateOperatorProgress.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) - Specified by:
clearOneof
in interfacecom.google.protobuf.Message.Builder
- Overrides:
clearOneof
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
setRepeatedField
public StoreTypes.StateOperatorProgress.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) - Specified by:
setRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
addRepeatedField
public StoreTypes.StateOperatorProgress.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
addRepeatedField
in interfacecom.google.protobuf.Message.Builder
- Overrides:
addRepeatedField
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
mergeFrom
- Specified by:
mergeFrom
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeFrom
in classcom.google.protobuf.AbstractMessage.Builder<StoreTypes.StateOperatorProgress.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
mergeFrom
public StoreTypes.StateOperatorProgress.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.StateOperatorProgress.Builder>
- Throws:
IOException
-
hasOperatorName
public boolean hasOperatorName()optional string operator_name = 1;
- Specified by:
hasOperatorName
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- Whether the operatorName field is set.
-
getOperatorName
optional string operator_name = 1;
- Specified by:
getOperatorName
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The operatorName.
-
getOperatorNameBytes
public com.google.protobuf.ByteString getOperatorNameBytes()optional string operator_name = 1;
- Specified by:
getOperatorNameBytes
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The bytes for operatorName.
-
setOperatorName
optional string operator_name = 1;
- Parameters:
value
- The operatorName to set.- Returns:
- This builder for chaining.
-
clearOperatorName
optional string operator_name = 1;
- Returns:
- This builder for chaining.
-
setOperatorNameBytes
public StoreTypes.StateOperatorProgress.Builder setOperatorNameBytes(com.google.protobuf.ByteString value) optional string operator_name = 1;
- Parameters:
value
- The bytes for operatorName to set.- Returns:
- This builder for chaining.
-
getNumRowsTotal
public long getNumRowsTotal()int64 num_rows_total = 2;
- Specified by:
getNumRowsTotal
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The numRowsTotal.
-
setNumRowsTotal
int64 num_rows_total = 2;
- Parameters:
value
- The numRowsTotal to set.- Returns:
- This builder for chaining.
-
clearNumRowsTotal
int64 num_rows_total = 2;
- Returns:
- This builder for chaining.
-
getNumRowsUpdated
public long getNumRowsUpdated()int64 num_rows_updated = 3;
- Specified by:
getNumRowsUpdated
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The numRowsUpdated.
-
setNumRowsUpdated
int64 num_rows_updated = 3;
- Parameters:
value
- The numRowsUpdated to set.- Returns:
- This builder for chaining.
-
clearNumRowsUpdated
int64 num_rows_updated = 3;
- Returns:
- This builder for chaining.
-
getAllUpdatesTimeMs
public long getAllUpdatesTimeMs()int64 all_updates_time_ms = 4;
- Specified by:
getAllUpdatesTimeMs
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The allUpdatesTimeMs.
-
setAllUpdatesTimeMs
int64 all_updates_time_ms = 4;
- Parameters:
value
- The allUpdatesTimeMs to set.- Returns:
- This builder for chaining.
-
clearAllUpdatesTimeMs
int64 all_updates_time_ms = 4;
- Returns:
- This builder for chaining.
-
getNumRowsRemoved
public long getNumRowsRemoved()int64 num_rows_removed = 5;
- Specified by:
getNumRowsRemoved
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The numRowsRemoved.
-
setNumRowsRemoved
int64 num_rows_removed = 5;
- Parameters:
value
- The numRowsRemoved to set.- Returns:
- This builder for chaining.
-
clearNumRowsRemoved
int64 num_rows_removed = 5;
- Returns:
- This builder for chaining.
-
getAllRemovalsTimeMs
public long getAllRemovalsTimeMs()int64 all_removals_time_ms = 6;
- Specified by:
getAllRemovalsTimeMs
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The allRemovalsTimeMs.
-
setAllRemovalsTimeMs
int64 all_removals_time_ms = 6;
- Parameters:
value
- The allRemovalsTimeMs to set.- Returns:
- This builder for chaining.
-
clearAllRemovalsTimeMs
int64 all_removals_time_ms = 6;
- Returns:
- This builder for chaining.
-
getCommitTimeMs
public long getCommitTimeMs()int64 commit_time_ms = 7;
- Specified by:
getCommitTimeMs
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The commitTimeMs.
-
setCommitTimeMs
int64 commit_time_ms = 7;
- Parameters:
value
- The commitTimeMs to set.- Returns:
- This builder for chaining.
-
clearCommitTimeMs
int64 commit_time_ms = 7;
- Returns:
- This builder for chaining.
-
getMemoryUsedBytes
public long getMemoryUsedBytes()int64 memory_used_bytes = 8;
- Specified by:
getMemoryUsedBytes
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The memoryUsedBytes.
-
setMemoryUsedBytes
int64 memory_used_bytes = 8;
- Parameters:
value
- The memoryUsedBytes to set.- Returns:
- This builder for chaining.
-
clearMemoryUsedBytes
int64 memory_used_bytes = 8;
- Returns:
- This builder for chaining.
-
getNumRowsDroppedByWatermark
public long getNumRowsDroppedByWatermark()int64 num_rows_dropped_by_watermark = 9;
- Specified by:
getNumRowsDroppedByWatermark
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The numRowsDroppedByWatermark.
-
setNumRowsDroppedByWatermark
int64 num_rows_dropped_by_watermark = 9;
- Parameters:
value
- The numRowsDroppedByWatermark to set.- Returns:
- This builder for chaining.
-
clearNumRowsDroppedByWatermark
int64 num_rows_dropped_by_watermark = 9;
- Returns:
- This builder for chaining.
-
getNumShufflePartitions
public long getNumShufflePartitions()int64 num_shuffle_partitions = 10;
- Specified by:
getNumShufflePartitions
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The numShufflePartitions.
-
setNumShufflePartitions
int64 num_shuffle_partitions = 10;
- Parameters:
value
- The numShufflePartitions to set.- Returns:
- This builder for chaining.
-
clearNumShufflePartitions
int64 num_shuffle_partitions = 10;
- Returns:
- This builder for chaining.
-
getNumStateStoreInstances
public long getNumStateStoreInstances()int64 num_state_store_instances = 11;
- Specified by:
getNumStateStoreInstances
in interfaceStoreTypes.StateOperatorProgressOrBuilder
- Returns:
- The numStateStoreInstances.
-
setNumStateStoreInstances
int64 num_state_store_instances = 11;
- Parameters:
value
- The numStateStoreInstances to set.- Returns:
- This builder for chaining.
-
clearNumStateStoreInstances
int64 num_state_store_instances = 11;
- Returns:
- This builder for chaining.
-
getCustomMetricsCount
public int getCustomMetricsCount()Description copied from interface:StoreTypes.StateOperatorProgressOrBuilder
map<string, int64> custom_metrics = 12;
- Specified by:
getCustomMetricsCount
in interfaceStoreTypes.StateOperatorProgressOrBuilder
-
containsCustomMetrics
map<string, int64> custom_metrics = 12;
- Specified by:
containsCustomMetrics
in interfaceStoreTypes.StateOperatorProgressOrBuilder
-
getCustomMetrics
Deprecated.UsegetCustomMetricsMap()
instead.- Specified by:
getCustomMetrics
in interfaceStoreTypes.StateOperatorProgressOrBuilder
-
getCustomMetricsMap
map<string, int64> custom_metrics = 12;
- Specified by:
getCustomMetricsMap
in interfaceStoreTypes.StateOperatorProgressOrBuilder
-
getCustomMetricsOrDefault
map<string, int64> custom_metrics = 12;
- Specified by:
getCustomMetricsOrDefault
in interfaceStoreTypes.StateOperatorProgressOrBuilder
-
getCustomMetricsOrThrow
map<string, int64> custom_metrics = 12;
- Specified by:
getCustomMetricsOrThrow
in interfaceStoreTypes.StateOperatorProgressOrBuilder
-
clearCustomMetrics
-
removeCustomMetrics
map<string, int64> custom_metrics = 12;
-
getMutableCustomMetrics
Deprecated.Use alternate mutation accessors instead. -
putCustomMetrics
map<string, int64> custom_metrics = 12;
-
putAllCustomMetrics
map<string, int64> custom_metrics = 12;
-
setUnknownFields
public final StoreTypes.StateOperatorProgress.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
setUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
setUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-
mergeUnknownFields
public final StoreTypes.StateOperatorProgress.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
mergeUnknownFields
in interfacecom.google.protobuf.Message.Builder
- Overrides:
mergeUnknownFields
in classcom.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StateOperatorProgress.Builder>
-