Package org.apache.spark.status.protobuf

Class StoreTypes.StateOperatorProgress.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderT>

com.google.protobuf.GeneratedMessage.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.GeneratedMessage.Builder<StoreTypes.StateOperatorProgress.Builder>
implements StoreTypes.StateOperatorProgressOrBuilder

Protobuf type org.apache.spark.status.protobuf.StateOperatorProgress

Method Summary

Modifier and Type	Method	Description
StoreTypes.StateOperatorProgress	build()
StoreTypes.StateOperatorProgress	buildPartial()
StoreTypes.StateOperatorProgress.Builder	clear()
StoreTypes.StateOperatorProgress.Builder	clearAllRemovalsTimeMs()	int64 all_removals_time_ms = 6;
StoreTypes.StateOperatorProgress.Builder	clearAllUpdatesTimeMs()	int64 all_updates_time_ms = 4;
StoreTypes.StateOperatorProgress.Builder	clearCommitTimeMs()	int64 commit_time_ms = 7;
StoreTypes.StateOperatorProgress.Builder	clearCustomMetrics()
StoreTypes.StateOperatorProgress.Builder	clearMemoryUsedBytes()	int64 memory_used_bytes = 8;
StoreTypes.StateOperatorProgress.Builder	clearNumRowsDroppedByWatermark()	int64 num_rows_dropped_by_watermark = 9;
StoreTypes.StateOperatorProgress.Builder	clearNumRowsRemoved()	int64 num_rows_removed = 5;
StoreTypes.StateOperatorProgress.Builder	clearNumRowsTotal()	int64 num_rows_total = 2;
StoreTypes.StateOperatorProgress.Builder	clearNumRowsUpdated()	int64 num_rows_updated = 3;
StoreTypes.StateOperatorProgress.Builder	clearNumShufflePartitions()	int64 num_shuffle_partitions = 10;
StoreTypes.StateOperatorProgress.Builder	clearNumStateStoreInstances()	int64 num_state_store_instances = 11;
StoreTypes.StateOperatorProgress.Builder	clearOperatorName()	optional string operator_name = 1;
boolean	containsCustomMetrics(String key)	map<string, int64> custom_metrics = 12;
long	getAllRemovalsTimeMs()	int64 all_removals_time_ms = 6;
long	getAllUpdatesTimeMs()	int64 all_updates_time_ms = 4;
long	getCommitTimeMs()	int64 commit_time_ms = 7;
Map<String,Long>	getCustomMetrics()	Deprecated.
int	getCustomMetricsCount()	map<string, int64> custom_metrics = 12;
Map<String,Long>	getCustomMetricsMap()	map<string, int64> custom_metrics = 12;
long	getCustomMetricsOrDefault(String key, long defaultValue)	map<string, int64> custom_metrics = 12;
long	getCustomMetricsOrThrow(String key)	map<string, int64> custom_metrics = 12;
StoreTypes.StateOperatorProgress	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
long	getMemoryUsedBytes()	int64 memory_used_bytes = 8;
Map<String,Long>	getMutableCustomMetrics()	Deprecated.
long	getNumRowsDroppedByWatermark()	int64 num_rows_dropped_by_watermark = 9;
long	getNumRowsRemoved()	int64 num_rows_removed = 5;
long	getNumRowsTotal()	int64 num_rows_total = 2;
long	getNumRowsUpdated()	int64 num_rows_updated = 3;
long	getNumShufflePartitions()	int64 num_shuffle_partitions = 10;
long	getNumStateStoreInstances()	int64 num_state_store_instances = 11;
String	getOperatorName()	optional string operator_name = 1;
com.google.protobuf.ByteString	getOperatorNameBytes()	optional string operator_name = 1;
boolean	hasOperatorName()	optional string operator_name = 1;
final boolean	isInitialized()
StoreTypes.StateOperatorProgress.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.StateOperatorProgress.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.StateOperatorProgress.Builder	mergeFrom(StoreTypes.StateOperatorProgress other)
StoreTypes.StateOperatorProgress.Builder	putAllCustomMetrics(Map<String,Long> values)	map<string, int64> custom_metrics = 12;
StoreTypes.StateOperatorProgress.Builder	putCustomMetrics(String key, long value)	map<string, int64> custom_metrics = 12;
StoreTypes.StateOperatorProgress.Builder	removeCustomMetrics(String key)	map<string, int64> custom_metrics = 12;
StoreTypes.StateOperatorProgress.Builder	setAllRemovalsTimeMs(long value)	int64 all_removals_time_ms = 6;
StoreTypes.StateOperatorProgress.Builder	setAllUpdatesTimeMs(long value)	int64 all_updates_time_ms = 4;
StoreTypes.StateOperatorProgress.Builder	setCommitTimeMs(long value)	int64 commit_time_ms = 7;
StoreTypes.StateOperatorProgress.Builder	setMemoryUsedBytes(long value)	int64 memory_used_bytes = 8;
StoreTypes.StateOperatorProgress.Builder	setNumRowsDroppedByWatermark(long value)	int64 num_rows_dropped_by_watermark = 9;
StoreTypes.StateOperatorProgress.Builder	setNumRowsRemoved(long value)	int64 num_rows_removed = 5;
StoreTypes.StateOperatorProgress.Builder	setNumRowsTotal(long value)	int64 num_rows_total = 2;
StoreTypes.StateOperatorProgress.Builder	setNumRowsUpdated(long value)	int64 num_rows_updated = 3;
StoreTypes.StateOperatorProgress.Builder	setNumShufflePartitions(long value)	int64 num_shuffle_partitions = 10;
StoreTypes.StateOperatorProgress.Builder	setNumStateStoreInstances(long value)	int64 num_state_store_instances = 11;
StoreTypes.StateOperatorProgress.Builder	setOperatorName(String value)	optional string operator_name = 1;
StoreTypes.StateOperatorProgress.Builder	setOperatorNameBytes(com.google.protobuf.ByteString value)	optional string operator_name = 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, 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

public StoreTypes.StateOperatorProgress.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.StateOperatorProgress.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<StoreTypes.StateOperatorProgress.Builder>

getDefaultInstanceForType

public StoreTypes.StateOperatorProgress getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.StateOperatorProgress build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public StoreTypes.StateOperatorProgress buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

mergeFrom

public StoreTypes.StateOperatorProgress.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StateOperatorProgress.Builder>

mergeFrom

public StoreTypes.StateOperatorProgress.Builder mergeFrom(StoreTypes.StateOperatorProgress other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessage.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 interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StateOperatorProgress.Builder>

Throws:

IOException

hasOperatorName

public boolean hasOperatorName()

optional string operator_name = 1;

Specified by:

hasOperatorName in interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

Whether the operatorName field is set.

getOperatorName

public String getOperatorName()

optional string operator_name = 1;

Specified by:

getOperatorName in interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The operatorName.

getOperatorNameBytes

public com.google.protobuf.ByteString getOperatorNameBytes()

optional string operator_name = 1;

Specified by:

getOperatorNameBytes in interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The bytes for operatorName.

setOperatorName

public StoreTypes.StateOperatorProgress.Builder setOperatorName(String value)

optional string operator_name = 1;

Parameters:

value - The operatorName to set.

Returns:

This builder for chaining.

clearOperatorName

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The numRowsTotal.

setNumRowsTotal

public StoreTypes.StateOperatorProgress.Builder setNumRowsTotal(long value)

int64 num_rows_total = 2;

Parameters:

value - The numRowsTotal to set.

Returns:

This builder for chaining.

clearNumRowsTotal

public StoreTypes.StateOperatorProgress.Builder clearNumRowsTotal()

int64 num_rows_total = 2;

Returns:

This builder for chaining.

getNumRowsUpdated

public long getNumRowsUpdated()

int64 num_rows_updated = 3;

Specified by:

getNumRowsUpdated in interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The numRowsUpdated.

setNumRowsUpdated

public StoreTypes.StateOperatorProgress.Builder setNumRowsUpdated(long value)

int64 num_rows_updated = 3;

Parameters:

value - The numRowsUpdated to set.

Returns:

This builder for chaining.

clearNumRowsUpdated

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The allUpdatesTimeMs.

setAllUpdatesTimeMs

public StoreTypes.StateOperatorProgress.Builder setAllUpdatesTimeMs(long value)

int64 all_updates_time_ms = 4;

Parameters:

value - The allUpdatesTimeMs to set.

Returns:

This builder for chaining.

clearAllUpdatesTimeMs

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The numRowsRemoved.

setNumRowsRemoved

public StoreTypes.StateOperatorProgress.Builder setNumRowsRemoved(long value)

int64 num_rows_removed = 5;

Parameters:

value - The numRowsRemoved to set.

Returns:

This builder for chaining.

clearNumRowsRemoved

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The allRemovalsTimeMs.

setAllRemovalsTimeMs

public StoreTypes.StateOperatorProgress.Builder setAllRemovalsTimeMs(long value)

int64 all_removals_time_ms = 6;

Parameters:

value - The allRemovalsTimeMs to set.

Returns:

This builder for chaining.

clearAllRemovalsTimeMs

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The commitTimeMs.

setCommitTimeMs

public StoreTypes.StateOperatorProgress.Builder setCommitTimeMs(long value)

int64 commit_time_ms = 7;

Parameters:

value - The commitTimeMs to set.

Returns:

This builder for chaining.

clearCommitTimeMs

public StoreTypes.StateOperatorProgress.Builder clearCommitTimeMs()

int64 commit_time_ms = 7;

Returns:

This builder for chaining.

getMemoryUsedBytes

public long getMemoryUsedBytes()

int64 memory_used_bytes = 8;

Specified by:

getMemoryUsedBytes in interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The memoryUsedBytes.

setMemoryUsedBytes

public StoreTypes.StateOperatorProgress.Builder setMemoryUsedBytes(long value)

int64 memory_used_bytes = 8;

Parameters:

value - The memoryUsedBytes to set.

Returns:

This builder for chaining.

clearMemoryUsedBytes

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The numRowsDroppedByWatermark.

setNumRowsDroppedByWatermark

public StoreTypes.StateOperatorProgress.Builder setNumRowsDroppedByWatermark(long value)

int64 num_rows_dropped_by_watermark = 9;

Parameters:

value - The numRowsDroppedByWatermark to set.

Returns:

This builder for chaining.

clearNumRowsDroppedByWatermark

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The numShufflePartitions.

setNumShufflePartitions

public StoreTypes.StateOperatorProgress.Builder setNumShufflePartitions(long value)

int64 num_shuffle_partitions = 10;

Parameters:

value - The numShufflePartitions to set.

Returns:

This builder for chaining.

clearNumShufflePartitions

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

Returns:

The numStateStoreInstances.

setNumStateStoreInstances

public StoreTypes.StateOperatorProgress.Builder setNumStateStoreInstances(long value)

int64 num_state_store_instances = 11;

Parameters:

value - The numStateStoreInstances to set.

Returns:

This builder for chaining.

clearNumStateStoreInstances

public StoreTypes.StateOperatorProgress.Builder 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 interface StoreTypes.StateOperatorProgressOrBuilder

containsCustomMetrics

public boolean containsCustomMetrics(String key)

map<string, int64> custom_metrics = 12;

Specified by:

containsCustomMetrics in interface StoreTypes.StateOperatorProgressOrBuilder

getCustomMetrics

@Deprecated
public Map<String,Long> getCustomMetrics()

Deprecated.

Use getCustomMetricsMap() instead.

Specified by:

getCustomMetrics in interface StoreTypes.StateOperatorProgressOrBuilder

getCustomMetricsMap

public Map<String,Long> getCustomMetricsMap()

map<string, int64> custom_metrics = 12;

Specified by:

getCustomMetricsMap in interface StoreTypes.StateOperatorProgressOrBuilder

getCustomMetricsOrDefault

public long getCustomMetricsOrDefault(String key,
 long defaultValue)

map<string, int64> custom_metrics = 12;

Specified by:

getCustomMetricsOrDefault in interface StoreTypes.StateOperatorProgressOrBuilder

getCustomMetricsOrThrow

public long getCustomMetricsOrThrow(String key)

map<string, int64> custom_metrics = 12;

Specified by:

getCustomMetricsOrThrow in interface StoreTypes.StateOperatorProgressOrBuilder

clearCustomMetrics

public StoreTypes.StateOperatorProgress.Builder clearCustomMetrics()

removeCustomMetrics

public StoreTypes.StateOperatorProgress.Builder removeCustomMetrics(String key)

map<string, int64> custom_metrics = 12;

getMutableCustomMetrics

@Deprecated
public Map<String,Long> getMutableCustomMetrics()

Deprecated.

Use alternate mutation accessors instead.

putCustomMetrics

public StoreTypes.StateOperatorProgress.Builder putCustomMetrics(String key,
 long value)

map<string, int64> custom_metrics = 12;

putAllCustomMetrics

public StoreTypes.StateOperatorProgress.Builder putAllCustomMetrics(Map<String,Long> values)

map<string, int64> custom_metrics = 12;