Package org.apache.spark.status.protobuf

Class StoreTypes.SourceProgress.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

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

com.google.protobuf.GeneratedMessage.Builder<StoreTypes.SourceProgress.Builder>

org.apache.spark.status.protobuf.StoreTypes.SourceProgress.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, Cloneable, StoreTypes.SourceProgressOrBuilder

Enclosing class:

StoreTypes.SourceProgress

public static final class StoreTypes.SourceProgress.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.SourceProgress.Builder>
implements StoreTypes.SourceProgressOrBuilder

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

Method Summary

Modifier and Type	Method	Description
StoreTypes.SourceProgress	build()
StoreTypes.SourceProgress	buildPartial()
StoreTypes.SourceProgress.Builder	clear()
StoreTypes.SourceProgress.Builder	clearDescription()	optional string description = 1;
StoreTypes.SourceProgress.Builder	clearEndOffset()	optional string end_offset = 3;
StoreTypes.SourceProgress.Builder	clearInputRowsPerSecond()	double input_rows_per_second = 6;
StoreTypes.SourceProgress.Builder	clearLatestOffset()	optional string latest_offset = 4;
StoreTypes.SourceProgress.Builder	clearMetrics()
StoreTypes.SourceProgress.Builder	clearNumInputRows()	int64 num_input_rows = 5;
StoreTypes.SourceProgress.Builder	clearProcessedRowsPerSecond()	double processed_rows_per_second = 7;
StoreTypes.SourceProgress.Builder	clearStartOffset()	optional string start_offset = 2;
boolean	containsMetrics(String key)	map<string, string> metrics = 8;
StoreTypes.SourceProgress	getDefaultInstanceForType()
String	getDescription()	optional string description = 1;
com.google.protobuf.ByteString	getDescriptionBytes()	optional string description = 1;
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
String	getEndOffset()	optional string end_offset = 3;
com.google.protobuf.ByteString	getEndOffsetBytes()	optional string end_offset = 3;
double	getInputRowsPerSecond()	double input_rows_per_second = 6;
String	getLatestOffset()	optional string latest_offset = 4;
com.google.protobuf.ByteString	getLatestOffsetBytes()	optional string latest_offset = 4;
Map<String,String>	getMetrics()	Deprecated.
int	getMetricsCount()	map<string, string> metrics = 8;
Map<String,String>	getMetricsMap()	map<string, string> metrics = 8;
String	getMetricsOrDefault(String key, String defaultValue)	map<string, string> metrics = 8;
String	getMetricsOrThrow(String key)	map<string, string> metrics = 8;
Map<String,String>	getMutableMetrics()	Deprecated.
long	getNumInputRows()	int64 num_input_rows = 5;
double	getProcessedRowsPerSecond()	double processed_rows_per_second = 7;
String	getStartOffset()	optional string start_offset = 2;
com.google.protobuf.ByteString	getStartOffsetBytes()	optional string start_offset = 2;
boolean	hasDescription()	optional string description = 1;
boolean	hasEndOffset()	optional string end_offset = 3;
boolean	hasLatestOffset()	optional string latest_offset = 4;
boolean	hasStartOffset()	optional string start_offset = 2;
final boolean	isInitialized()
StoreTypes.SourceProgress.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.SourceProgress.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.SourceProgress.Builder	mergeFrom(StoreTypes.SourceProgress other)
StoreTypes.SourceProgress.Builder	putAllMetrics(Map<String,String> values)	map<string, string> metrics = 8;
StoreTypes.SourceProgress.Builder	putMetrics(String key, String value)	map<string, string> metrics = 8;
StoreTypes.SourceProgress.Builder	removeMetrics(String key)	map<string, string> metrics = 8;
StoreTypes.SourceProgress.Builder	setDescription(String value)	optional string description = 1;
StoreTypes.SourceProgress.Builder	setDescriptionBytes(com.google.protobuf.ByteString value)	optional string description = 1;
StoreTypes.SourceProgress.Builder	setEndOffset(String value)	optional string end_offset = 3;
StoreTypes.SourceProgress.Builder	setEndOffsetBytes(com.google.protobuf.ByteString value)	optional string end_offset = 3;
StoreTypes.SourceProgress.Builder	setInputRowsPerSecond(double value)	double input_rows_per_second = 6;
StoreTypes.SourceProgress.Builder	setLatestOffset(String value)	optional string latest_offset = 4;
StoreTypes.SourceProgress.Builder	setLatestOffsetBytes(com.google.protobuf.ByteString value)	optional string latest_offset = 4;
StoreTypes.SourceProgress.Builder	setNumInputRows(long value)	int64 num_input_rows = 5;
StoreTypes.SourceProgress.Builder	setProcessedRowsPerSecond(double value)	double processed_rows_per_second = 7;
StoreTypes.SourceProgress.Builder	setStartOffset(String value)	optional string start_offset = 2;
StoreTypes.SourceProgress.Builder	setStartOffsetBytes(com.google.protobuf.ByteString value)	optional string start_offset = 2;

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.SourceProgress.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.SourceProgress.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.SourceProgress.Builder>

getDefaultInstanceForType

public StoreTypes.SourceProgress getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.SourceProgress build()

Specified by:

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

Specified by:

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

buildPartial

public StoreTypes.SourceProgress buildPartial()

Specified by:

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

Specified by:

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

mergeFrom

public StoreTypes.SourceProgress.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.SourceProgress.Builder>

mergeFrom

public StoreTypes.SourceProgress.Builder mergeFrom(StoreTypes.SourceProgress 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.SourceProgress.Builder>

mergeFrom

public StoreTypes.SourceProgress.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.SourceProgress.Builder>

Throws:

IOException

hasDescription

public boolean hasDescription()

optional string description = 1;

Specified by:

hasDescription in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the description field is set.

getDescription

public String getDescription()

optional string description = 1;

Specified by:

getDescription in interface StoreTypes.SourceProgressOrBuilder

Returns:

The description.

getDescriptionBytes

public com.google.protobuf.ByteString getDescriptionBytes()

optional string description = 1;

Specified by:

getDescriptionBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for description.

setDescription

public StoreTypes.SourceProgress.Builder setDescription(String value)

optional string description = 1;

Parameters:

value - The description to set.

Returns:

This builder for chaining.

clearDescription

public StoreTypes.SourceProgress.Builder clearDescription()

optional string description = 1;

Returns:

This builder for chaining.

setDescriptionBytes

public StoreTypes.SourceProgress.Builder setDescriptionBytes(com.google.protobuf.ByteString value)

optional string description = 1;

Parameters:

value - The bytes for description to set.

Returns:

This builder for chaining.

hasStartOffset

public boolean hasStartOffset()

optional string start_offset = 2;

Specified by:

hasStartOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the startOffset field is set.

getStartOffset

public String getStartOffset()

optional string start_offset = 2;

Specified by:

getStartOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

The startOffset.

getStartOffsetBytes

public com.google.protobuf.ByteString getStartOffsetBytes()

optional string start_offset = 2;

Specified by:

getStartOffsetBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for startOffset.

setStartOffset

public StoreTypes.SourceProgress.Builder setStartOffset(String value)

optional string start_offset = 2;

Parameters:

value - The startOffset to set.

Returns:

This builder for chaining.

clearStartOffset

public StoreTypes.SourceProgress.Builder clearStartOffset()

optional string start_offset = 2;

Returns:

This builder for chaining.

setStartOffsetBytes

public StoreTypes.SourceProgress.Builder setStartOffsetBytes(com.google.protobuf.ByteString value)

optional string start_offset = 2;

Parameters:

value - The bytes for startOffset to set.

Returns:

This builder for chaining.

hasEndOffset

public boolean hasEndOffset()

optional string end_offset = 3;

Specified by:

hasEndOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the endOffset field is set.

getEndOffset

public String getEndOffset()

optional string end_offset = 3;

Specified by:

getEndOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

The endOffset.

getEndOffsetBytes

public com.google.protobuf.ByteString getEndOffsetBytes()

optional string end_offset = 3;

Specified by:

getEndOffsetBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for endOffset.

setEndOffset

public StoreTypes.SourceProgress.Builder setEndOffset(String value)

optional string end_offset = 3;

Parameters:

value - The endOffset to set.

Returns:

This builder for chaining.

clearEndOffset

public StoreTypes.SourceProgress.Builder clearEndOffset()

optional string end_offset = 3;

Returns:

This builder for chaining.

setEndOffsetBytes

public StoreTypes.SourceProgress.Builder setEndOffsetBytes(com.google.protobuf.ByteString value)

optional string end_offset = 3;

Parameters:

value - The bytes for endOffset to set.

Returns:

This builder for chaining.

hasLatestOffset

public boolean hasLatestOffset()

optional string latest_offset = 4;

Specified by:

hasLatestOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

Whether the latestOffset field is set.

getLatestOffset

public String getLatestOffset()

optional string latest_offset = 4;

Specified by:

getLatestOffset in interface StoreTypes.SourceProgressOrBuilder

Returns:

The latestOffset.

getLatestOffsetBytes

public com.google.protobuf.ByteString getLatestOffsetBytes()

optional string latest_offset = 4;

Specified by:

getLatestOffsetBytes in interface StoreTypes.SourceProgressOrBuilder

Returns:

The bytes for latestOffset.

setLatestOffset

public StoreTypes.SourceProgress.Builder setLatestOffset(String value)

optional string latest_offset = 4;

Parameters:

value - The latestOffset to set.

Returns:

This builder for chaining.

clearLatestOffset

public StoreTypes.SourceProgress.Builder clearLatestOffset()

optional string latest_offset = 4;

Returns:

This builder for chaining.

setLatestOffsetBytes

public StoreTypes.SourceProgress.Builder setLatestOffsetBytes(com.google.protobuf.ByteString value)

optional string latest_offset = 4;

Parameters:

value - The bytes for latestOffset to set.

Returns:

This builder for chaining.

getNumInputRows

public long getNumInputRows()

int64 num_input_rows = 5;

Specified by:

getNumInputRows in interface StoreTypes.SourceProgressOrBuilder

Returns:

The numInputRows.

setNumInputRows

public StoreTypes.SourceProgress.Builder setNumInputRows(long value)

int64 num_input_rows = 5;

Parameters:

value - The numInputRows to set.

Returns:

This builder for chaining.

clearNumInputRows

public StoreTypes.SourceProgress.Builder clearNumInputRows()

int64 num_input_rows = 5;

Returns:

This builder for chaining.

getInputRowsPerSecond

public double getInputRowsPerSecond()

double input_rows_per_second = 6;

Specified by:

getInputRowsPerSecond in interface StoreTypes.SourceProgressOrBuilder

Returns:

The inputRowsPerSecond.

setInputRowsPerSecond

public StoreTypes.SourceProgress.Builder setInputRowsPerSecond(double value)

double input_rows_per_second = 6;

Parameters:

value - The inputRowsPerSecond to set.

Returns:

This builder for chaining.

clearInputRowsPerSecond

public StoreTypes.SourceProgress.Builder clearInputRowsPerSecond()

double input_rows_per_second = 6;

Returns:

This builder for chaining.

getProcessedRowsPerSecond

public double getProcessedRowsPerSecond()

double processed_rows_per_second = 7;

Specified by:

getProcessedRowsPerSecond in interface StoreTypes.SourceProgressOrBuilder

Returns:

The processedRowsPerSecond.

setProcessedRowsPerSecond

public StoreTypes.SourceProgress.Builder setProcessedRowsPerSecond(double value)

double processed_rows_per_second = 7;

Parameters:

value - The processedRowsPerSecond to set.

Returns:

This builder for chaining.

clearProcessedRowsPerSecond

public StoreTypes.SourceProgress.Builder clearProcessedRowsPerSecond()

double processed_rows_per_second = 7;

Returns:

This builder for chaining.

getMetricsCount

public int getMetricsCount()

Description copied from interface: StoreTypes.SourceProgressOrBuilder

map<string, string> metrics = 8;

Specified by:

getMetricsCount in interface StoreTypes.SourceProgressOrBuilder

containsMetrics

public boolean containsMetrics(String key)

map<string, string> metrics = 8;

Specified by:

containsMetrics in interface StoreTypes.SourceProgressOrBuilder

getMetrics

@Deprecated
public Map<String,String> getMetrics()

Deprecated.

Use getMetricsMap() instead.

Specified by:

getMetrics in interface StoreTypes.SourceProgressOrBuilder

getMetricsMap

public Map<String,String> getMetricsMap()

map<string, string> metrics = 8;

Specified by:

getMetricsMap in interface StoreTypes.SourceProgressOrBuilder

getMetricsOrDefault

public String getMetricsOrDefault(String key,
 String defaultValue)

map<string, string> metrics = 8;

Specified by:

getMetricsOrDefault in interface StoreTypes.SourceProgressOrBuilder

getMetricsOrThrow

public String getMetricsOrThrow(String key)

map<string, string> metrics = 8;

Specified by:

getMetricsOrThrow in interface StoreTypes.SourceProgressOrBuilder

clearMetrics

public StoreTypes.SourceProgress.Builder clearMetrics()

removeMetrics

public StoreTypes.SourceProgress.Builder removeMetrics(String key)

map<string, string> metrics = 8;

getMutableMetrics

@Deprecated
public Map<String,String> getMutableMetrics()

Deprecated.

Use alternate mutation accessors instead.

putMetrics

public StoreTypes.SourceProgress.Builder putMetrics(String key,
 String value)

map<string, string> metrics = 8;

putAllMetrics

public StoreTypes.SourceProgress.Builder putAllMetrics(Map<String,String> values)

map<string, string> metrics = 8;