Package org.apache.spark.status.protobuf

Class StoreTypes.StreamingQueryProgress.Builder

Object

com.google.protobuf.AbstractMessageLite.Builder

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

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

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

All Implemented Interfaces:

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

Enclosing class:

StoreTypes.StreamingQueryProgress

public static final class StoreTypes.StreamingQueryProgress.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StoreTypes.StreamingQueryProgress.Builder>
implements StoreTypes.StreamingQueryProgressOrBuilder

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

Method Summary

Modifier and Type	Method	Description
StoreTypes.StreamingQueryProgress.Builder	addAllSources(Iterable<? extends StoreTypes.SourceProgress> values)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	addAllStateOperators(Iterable<? extends StoreTypes.StateOperatorProgress> values)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	addSources(int index, StoreTypes.SourceProgress value)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	addSources(int index, StoreTypes.SourceProgress.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	addSources(StoreTypes.SourceProgress value)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	addSources(StoreTypes.SourceProgress.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.SourceProgress.Builder	addSourcesBuilder()	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.SourceProgress.Builder	addSourcesBuilder(int index)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	addStateOperators(int index, StoreTypes.StateOperatorProgress value)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	addStateOperators(int index, StoreTypes.StateOperatorProgress.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	addStateOperators(StoreTypes.StateOperatorProgress value)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	addStateOperators(StoreTypes.StateOperatorProgress.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StateOperatorProgress.Builder	addStateOperatorsBuilder()	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StateOperatorProgress.Builder	addStateOperatorsBuilder(int index)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress	build()
StoreTypes.StreamingQueryProgress	buildPartial()
StoreTypes.StreamingQueryProgress.Builder	clear()
StoreTypes.StreamingQueryProgress.Builder	clearBatchDuration()	int64 batch_duration = 6;
StoreTypes.StreamingQueryProgress.Builder	clearBatchId()	int64 batch_id = 5;
StoreTypes.StreamingQueryProgress.Builder	clearDurationMs()
StoreTypes.StreamingQueryProgress.Builder	clearEventTime()
StoreTypes.StreamingQueryProgress.Builder	clearId()	optional string id = 1;
StoreTypes.StreamingQueryProgress.Builder	clearName()	optional string name = 3;
StoreTypes.StreamingQueryProgress.Builder	clearObservedMetrics()
StoreTypes.StreamingQueryProgress.Builder	clearRunId()	optional string run_id = 2;
StoreTypes.StreamingQueryProgress.Builder	clearSink()	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
StoreTypes.StreamingQueryProgress.Builder	clearSources()	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	clearStateOperators()	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	clearTimestamp()	optional string timestamp = 4;
boolean	containsDurationMs(String key)	map<string, int64> duration_ms = 7;
boolean	containsEventTime(String key)	map<string, string> event_time = 8;
boolean	containsObservedMetrics(String key)	map<string, string> observed_metrics = 12;
long	getBatchDuration()	int64 batch_duration = 6;
long	getBatchId()	int64 batch_id = 5;
StoreTypes.StreamingQueryProgress	getDefaultInstanceForType()
static final com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
Map<String,Long>	getDurationMs()	Deprecated.
int	getDurationMsCount()	map<string, int64> duration_ms = 7;
Map<String,Long>	getDurationMsMap()	map<string, int64> duration_ms = 7;
long	getDurationMsOrDefault(String key, long defaultValue)	map<string, int64> duration_ms = 7;
long	getDurationMsOrThrow(String key)	map<string, int64> duration_ms = 7;
Map<String,String>	getEventTime()	Deprecated.
int	getEventTimeCount()	map<string, string> event_time = 8;
Map<String,String>	getEventTimeMap()	map<string, string> event_time = 8;
String	getEventTimeOrDefault(String key, String defaultValue)	map<string, string> event_time = 8;
String	getEventTimeOrThrow(String key)	map<string, string> event_time = 8;
String	getId()	optional string id = 1;
com.google.protobuf.ByteString	getIdBytes()	optional string id = 1;
Map<String,Long>	getMutableDurationMs()	Deprecated.
Map<String,String>	getMutableEventTime()	Deprecated.
Map<String,String>	getMutableObservedMetrics()	Deprecated.
String	getName()	optional string name = 3;
com.google.protobuf.ByteString	getNameBytes()	optional string name = 3;
Map<String,String>	getObservedMetrics()	Deprecated.
int	getObservedMetricsCount()	map<string, string> observed_metrics = 12;
Map<String,String>	getObservedMetricsMap()	map<string, string> observed_metrics = 12;
String	getObservedMetricsOrDefault(String key, String defaultValue)	map<string, string> observed_metrics = 12;
String	getObservedMetricsOrThrow(String key)	map<string, string> observed_metrics = 12;
String	getRunId()	optional string run_id = 2;
com.google.protobuf.ByteString	getRunIdBytes()	optional string run_id = 2;
StoreTypes.SinkProgress	getSink()	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
StoreTypes.SinkProgress.Builder	getSinkBuilder()	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
StoreTypes.SinkProgressOrBuilder	getSinkOrBuilder()	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
StoreTypes.SourceProgress	getSources(int index)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.SourceProgress.Builder	getSourcesBuilder(int index)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
List<StoreTypes.SourceProgress.Builder>	getSourcesBuilderList()	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
int	getSourcesCount()	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
List<StoreTypes.SourceProgress>	getSourcesList()	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.SourceProgressOrBuilder	getSourcesOrBuilder(int index)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
List<? extends StoreTypes.SourceProgressOrBuilder>	getSourcesOrBuilderList()	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StateOperatorProgress	getStateOperators(int index)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StateOperatorProgress.Builder	getStateOperatorsBuilder(int index)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
List<StoreTypes.StateOperatorProgress.Builder>	getStateOperatorsBuilderList()	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
int	getStateOperatorsCount()	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
List<StoreTypes.StateOperatorProgress>	getStateOperatorsList()	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StateOperatorProgressOrBuilder	getStateOperatorsOrBuilder(int index)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
List<? extends StoreTypes.StateOperatorProgressOrBuilder>	getStateOperatorsOrBuilderList()	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
String	getTimestamp()	optional string timestamp = 4;
com.google.protobuf.ByteString	getTimestampBytes()	optional string timestamp = 4;
boolean	hasId()	optional string id = 1;
boolean	hasName()	optional string name = 3;
boolean	hasRunId()	optional string run_id = 2;
boolean	hasSink()	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
boolean	hasTimestamp()	optional string timestamp = 4;
final boolean	isInitialized()
StoreTypes.StreamingQueryProgress.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
StoreTypes.StreamingQueryProgress.Builder	mergeFrom(com.google.protobuf.Message other)
StoreTypes.StreamingQueryProgress.Builder	mergeFrom(StoreTypes.StreamingQueryProgress other)
StoreTypes.StreamingQueryProgress.Builder	mergeSink(StoreTypes.SinkProgress value)	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
StoreTypes.StreamingQueryProgress.Builder	putAllDurationMs(Map<String,Long> values)	map<string, int64> duration_ms = 7;
StoreTypes.StreamingQueryProgress.Builder	putAllEventTime(Map<String,String> values)	map<string, string> event_time = 8;
StoreTypes.StreamingQueryProgress.Builder	putAllObservedMetrics(Map<String,String> values)	map<string, string> observed_metrics = 12;
StoreTypes.StreamingQueryProgress.Builder	putDurationMs(String key, long value)	map<string, int64> duration_ms = 7;
StoreTypes.StreamingQueryProgress.Builder	putEventTime(String key, String value)	map<string, string> event_time = 8;
StoreTypes.StreamingQueryProgress.Builder	putObservedMetrics(String key, String value)	map<string, string> observed_metrics = 12;
StoreTypes.StreamingQueryProgress.Builder	removeDurationMs(String key)	map<string, int64> duration_ms = 7;
StoreTypes.StreamingQueryProgress.Builder	removeEventTime(String key)	map<string, string> event_time = 8;
StoreTypes.StreamingQueryProgress.Builder	removeObservedMetrics(String key)	map<string, string> observed_metrics = 12;
StoreTypes.StreamingQueryProgress.Builder	removeSources(int index)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	removeStateOperators(int index)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	setBatchDuration(long value)	int64 batch_duration = 6;
StoreTypes.StreamingQueryProgress.Builder	setBatchId(long value)	int64 batch_id = 5;
StoreTypes.StreamingQueryProgress.Builder	setId(String value)	optional string id = 1;
StoreTypes.StreamingQueryProgress.Builder	setIdBytes(com.google.protobuf.ByteString value)	optional string id = 1;
StoreTypes.StreamingQueryProgress.Builder	setName(String value)	optional string name = 3;
StoreTypes.StreamingQueryProgress.Builder	setNameBytes(com.google.protobuf.ByteString value)	optional string name = 3;
StoreTypes.StreamingQueryProgress.Builder	setRunId(String value)	optional string run_id = 2;
StoreTypes.StreamingQueryProgress.Builder	setRunIdBytes(com.google.protobuf.ByteString value)	optional string run_id = 2;
StoreTypes.StreamingQueryProgress.Builder	setSink(StoreTypes.SinkProgress value)	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
StoreTypes.StreamingQueryProgress.Builder	setSink(StoreTypes.SinkProgress.Builder builderForValue)	.org.apache.spark.status.protobuf.SinkProgress sink = 11;
StoreTypes.StreamingQueryProgress.Builder	setSources(int index, StoreTypes.SourceProgress value)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	setSources(int index, StoreTypes.SourceProgress.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
StoreTypes.StreamingQueryProgress.Builder	setStateOperators(int index, StoreTypes.StateOperatorProgress value)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	setStateOperators(int index, StoreTypes.StateOperatorProgress.Builder builderForValue)	repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
StoreTypes.StreamingQueryProgress.Builder	setTimestamp(String value)	optional string timestamp = 4;
StoreTypes.StreamingQueryProgress.Builder	setTimestampBytes(com.google.protobuf.ByteString value)	optional string timestamp = 4;

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

getDefaultInstanceForType

public StoreTypes.StreamingQueryProgress getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public StoreTypes.StreamingQueryProgress build()

Specified by:

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

Specified by:

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

buildPartial

public StoreTypes.StreamingQueryProgress buildPartial()

Specified by:

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

Specified by:

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

mergeFrom

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

mergeFrom

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

mergeFrom

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

Throws:

IOException

hasId

public boolean hasId()

optional string id = 1;

Specified by:

hasId in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

Whether the id field is set.

getId

public String getId()

optional string id = 1;

Specified by:

getId in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The id.

getIdBytes

public com.google.protobuf.ByteString getIdBytes()

optional string id = 1;

Specified by:

getIdBytes in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The bytes for id.

setId

public StoreTypes.StreamingQueryProgress.Builder setId(String value)

optional string id = 1;

Parameters:

value - The id to set.

Returns:

This builder for chaining.

clearId

public StoreTypes.StreamingQueryProgress.Builder clearId()

optional string id = 1;

Returns:

This builder for chaining.

setIdBytes

public StoreTypes.StreamingQueryProgress.Builder setIdBytes(com.google.protobuf.ByteString value)

optional string id = 1;

Parameters:

value - The bytes for id to set.

Returns:

This builder for chaining.

hasRunId

public boolean hasRunId()

optional string run_id = 2;

Specified by:

hasRunId in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

Whether the runId field is set.

getRunId

public String getRunId()

optional string run_id = 2;

Specified by:

getRunId in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The runId.

getRunIdBytes

public com.google.protobuf.ByteString getRunIdBytes()

optional string run_id = 2;

Specified by:

getRunIdBytes in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The bytes for runId.

setRunId

public StoreTypes.StreamingQueryProgress.Builder setRunId(String value)

optional string run_id = 2;

Parameters:

value - The runId to set.

Returns:

This builder for chaining.

clearRunId

public StoreTypes.StreamingQueryProgress.Builder clearRunId()

optional string run_id = 2;

Returns:

This builder for chaining.

setRunIdBytes

public StoreTypes.StreamingQueryProgress.Builder setRunIdBytes(com.google.protobuf.ByteString value)

optional string run_id = 2;

Parameters:

value - The bytes for runId to set.

Returns:

This builder for chaining.

hasName

public boolean hasName()

optional string name = 3;

Specified by:

hasName in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

Whether the name field is set.

getName

public String getName()

optional string name = 3;

Specified by:

getName in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The name.

getNameBytes

public com.google.protobuf.ByteString getNameBytes()

optional string name = 3;

Specified by:

getNameBytes in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The bytes for name.

setName

public StoreTypes.StreamingQueryProgress.Builder setName(String value)

optional string name = 3;

Parameters:

value - The name to set.

Returns:

This builder for chaining.

clearName

public StoreTypes.StreamingQueryProgress.Builder clearName()

optional string name = 3;

Returns:

This builder for chaining.

setNameBytes

public StoreTypes.StreamingQueryProgress.Builder setNameBytes(com.google.protobuf.ByteString value)

optional string name = 3;

Parameters:

value - The bytes for name to set.

Returns:

This builder for chaining.

hasTimestamp

public boolean hasTimestamp()

optional string timestamp = 4;

Specified by:

hasTimestamp in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

Whether the timestamp field is set.

getTimestamp

public String getTimestamp()

optional string timestamp = 4;

Specified by:

getTimestamp in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The timestamp.

getTimestampBytes

public com.google.protobuf.ByteString getTimestampBytes()

optional string timestamp = 4;

Specified by:

getTimestampBytes in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The bytes for timestamp.

setTimestamp

public StoreTypes.StreamingQueryProgress.Builder setTimestamp(String value)

optional string timestamp = 4;

Parameters:

value - The timestamp to set.

Returns:

This builder for chaining.

clearTimestamp

public StoreTypes.StreamingQueryProgress.Builder clearTimestamp()

optional string timestamp = 4;

Returns:

This builder for chaining.

setTimestampBytes

public StoreTypes.StreamingQueryProgress.Builder setTimestampBytes(com.google.protobuf.ByteString value)

optional string timestamp = 4;

Parameters:

value - The bytes for timestamp to set.

Returns:

This builder for chaining.

getBatchId

public long getBatchId()

int64 batch_id = 5;

Specified by:

getBatchId in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The batchId.

setBatchId

public StoreTypes.StreamingQueryProgress.Builder setBatchId(long value)

int64 batch_id = 5;

Parameters:

value - The batchId to set.

Returns:

This builder for chaining.

clearBatchId

public StoreTypes.StreamingQueryProgress.Builder clearBatchId()

int64 batch_id = 5;

Returns:

This builder for chaining.

getBatchDuration

public long getBatchDuration()

int64 batch_duration = 6;

Specified by:

getBatchDuration in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The batchDuration.

setBatchDuration

public StoreTypes.StreamingQueryProgress.Builder setBatchDuration(long value)

int64 batch_duration = 6;

Parameters:

value - The batchDuration to set.

Returns:

This builder for chaining.

clearBatchDuration

public StoreTypes.StreamingQueryProgress.Builder clearBatchDuration()

int64 batch_duration = 6;

Returns:

This builder for chaining.

getDurationMsCount

public int getDurationMsCount()

Description copied from interface: StoreTypes.StreamingQueryProgressOrBuilder

map<string, int64> duration_ms = 7;

Specified by:

getDurationMsCount in interface StoreTypes.StreamingQueryProgressOrBuilder

containsDurationMs

public boolean containsDurationMs(String key)

map<string, int64> duration_ms = 7;

Specified by:

containsDurationMs in interface StoreTypes.StreamingQueryProgressOrBuilder

getDurationMs

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

Deprecated.

Use getDurationMsMap() instead.

Specified by:

getDurationMs in interface StoreTypes.StreamingQueryProgressOrBuilder

getDurationMsMap

public Map<String,Long> getDurationMsMap()

map<string, int64> duration_ms = 7;

Specified by:

getDurationMsMap in interface StoreTypes.StreamingQueryProgressOrBuilder

getDurationMsOrDefault

public long getDurationMsOrDefault(String key,
 long defaultValue)

map<string, int64> duration_ms = 7;

Specified by:

getDurationMsOrDefault in interface StoreTypes.StreamingQueryProgressOrBuilder

getDurationMsOrThrow

public long getDurationMsOrThrow(String key)

map<string, int64> duration_ms = 7;

Specified by:

getDurationMsOrThrow in interface StoreTypes.StreamingQueryProgressOrBuilder

clearDurationMs

public StoreTypes.StreamingQueryProgress.Builder clearDurationMs()

removeDurationMs

public StoreTypes.StreamingQueryProgress.Builder removeDurationMs(String key)

map<string, int64> duration_ms = 7;

getMutableDurationMs

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

Deprecated.

Use alternate mutation accessors instead.

putDurationMs

public StoreTypes.StreamingQueryProgress.Builder putDurationMs(String key,
 long value)

map<string, int64> duration_ms = 7;

putAllDurationMs

public StoreTypes.StreamingQueryProgress.Builder putAllDurationMs(Map<String,Long> values)

map<string, int64> duration_ms = 7;

getEventTimeCount

public int getEventTimeCount()

Description copied from interface: StoreTypes.StreamingQueryProgressOrBuilder

map<string, string> event_time = 8;

Specified by:

getEventTimeCount in interface StoreTypes.StreamingQueryProgressOrBuilder

containsEventTime

public boolean containsEventTime(String key)

map<string, string> event_time = 8;

Specified by:

containsEventTime in interface StoreTypes.StreamingQueryProgressOrBuilder

getEventTime

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

Deprecated.

Use getEventTimeMap() instead.

Specified by:

getEventTime in interface StoreTypes.StreamingQueryProgressOrBuilder

getEventTimeMap

public Map<String,String> getEventTimeMap()

map<string, string> event_time = 8;

Specified by:

getEventTimeMap in interface StoreTypes.StreamingQueryProgressOrBuilder

getEventTimeOrDefault

public String getEventTimeOrDefault(String key,
 String defaultValue)

map<string, string> event_time = 8;

Specified by:

getEventTimeOrDefault in interface StoreTypes.StreamingQueryProgressOrBuilder

getEventTimeOrThrow

public String getEventTimeOrThrow(String key)

map<string, string> event_time = 8;

Specified by:

getEventTimeOrThrow in interface StoreTypes.StreamingQueryProgressOrBuilder

clearEventTime

public StoreTypes.StreamingQueryProgress.Builder clearEventTime()

removeEventTime

public StoreTypes.StreamingQueryProgress.Builder removeEventTime(String key)

map<string, string> event_time = 8;

getMutableEventTime

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

Deprecated.

Use alternate mutation accessors instead.

putEventTime

public StoreTypes.StreamingQueryProgress.Builder putEventTime(String key,
 String value)

map<string, string> event_time = 8;

putAllEventTime

public StoreTypes.StreamingQueryProgress.Builder putAllEventTime(Map<String,String> values)

map<string, string> event_time = 8;

getStateOperatorsList

public List<StoreTypes.StateOperatorProgress> getStateOperatorsList()

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

Specified by:

getStateOperatorsList in interface StoreTypes.StreamingQueryProgressOrBuilder

getStateOperatorsCount

public int getStateOperatorsCount()

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

Specified by:

getStateOperatorsCount in interface StoreTypes.StreamingQueryProgressOrBuilder

getStateOperators

public StoreTypes.StateOperatorProgress getStateOperators(int index)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

Specified by:

getStateOperators in interface StoreTypes.StreamingQueryProgressOrBuilder

setStateOperators

public StoreTypes.StreamingQueryProgress.Builder setStateOperators(int index,
 StoreTypes.StateOperatorProgress value)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

setStateOperators

public StoreTypes.StreamingQueryProgress.Builder setStateOperators(int index,
 StoreTypes.StateOperatorProgress.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

addStateOperators

public StoreTypes.StreamingQueryProgress.Builder addStateOperators(StoreTypes.StateOperatorProgress value)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

addStateOperators

public StoreTypes.StreamingQueryProgress.Builder addStateOperators(int index,
 StoreTypes.StateOperatorProgress value)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

addStateOperators

public StoreTypes.StreamingQueryProgress.Builder addStateOperators(StoreTypes.StateOperatorProgress.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

addStateOperators

public StoreTypes.StreamingQueryProgress.Builder addStateOperators(int index,
 StoreTypes.StateOperatorProgress.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

addAllStateOperators

public StoreTypes.StreamingQueryProgress.Builder addAllStateOperators(Iterable<? extends StoreTypes.StateOperatorProgress> values)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

clearStateOperators

public StoreTypes.StreamingQueryProgress.Builder clearStateOperators()

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

removeStateOperators

public StoreTypes.StreamingQueryProgress.Builder removeStateOperators(int index)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

getStateOperatorsBuilder

public StoreTypes.StateOperatorProgress.Builder getStateOperatorsBuilder(int index)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

getStateOperatorsOrBuilder

public StoreTypes.StateOperatorProgressOrBuilder getStateOperatorsOrBuilder(int index)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

Specified by:

getStateOperatorsOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilder

getStateOperatorsOrBuilderList

public List<? extends StoreTypes.StateOperatorProgressOrBuilder> getStateOperatorsOrBuilderList()

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

Specified by:

getStateOperatorsOrBuilderList in interface StoreTypes.StreamingQueryProgressOrBuilder

addStateOperatorsBuilder

public StoreTypes.StateOperatorProgress.Builder addStateOperatorsBuilder()

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

addStateOperatorsBuilder

public StoreTypes.StateOperatorProgress.Builder addStateOperatorsBuilder(int index)

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

getStateOperatorsBuilderList

public List<StoreTypes.StateOperatorProgress.Builder> getStateOperatorsBuilderList()

repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;

getSourcesList

public List<StoreTypes.SourceProgress> getSourcesList()

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

Specified by:

getSourcesList in interface StoreTypes.StreamingQueryProgressOrBuilder

getSourcesCount

public int getSourcesCount()

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

Specified by:

getSourcesCount in interface StoreTypes.StreamingQueryProgressOrBuilder

getSources

public StoreTypes.SourceProgress getSources(int index)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

Specified by:

getSources in interface StoreTypes.StreamingQueryProgressOrBuilder

setSources

public StoreTypes.StreamingQueryProgress.Builder setSources(int index,
 StoreTypes.SourceProgress value)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

setSources

public StoreTypes.StreamingQueryProgress.Builder setSources(int index,
 StoreTypes.SourceProgress.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

addSources

public StoreTypes.StreamingQueryProgress.Builder addSources(StoreTypes.SourceProgress value)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

addSources

public StoreTypes.StreamingQueryProgress.Builder addSources(int index,
 StoreTypes.SourceProgress value)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

addSources

public StoreTypes.StreamingQueryProgress.Builder addSources(StoreTypes.SourceProgress.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

addSources

public StoreTypes.StreamingQueryProgress.Builder addSources(int index,
 StoreTypes.SourceProgress.Builder builderForValue)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

addAllSources

public StoreTypes.StreamingQueryProgress.Builder addAllSources(Iterable<? extends StoreTypes.SourceProgress> values)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

clearSources

public StoreTypes.StreamingQueryProgress.Builder clearSources()

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

removeSources

public StoreTypes.StreamingQueryProgress.Builder removeSources(int index)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

getSourcesBuilder

public StoreTypes.SourceProgress.Builder getSourcesBuilder(int index)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

getSourcesOrBuilder

public StoreTypes.SourceProgressOrBuilder getSourcesOrBuilder(int index)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

Specified by:

getSourcesOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilder

getSourcesOrBuilderList

public List<? extends StoreTypes.SourceProgressOrBuilder> getSourcesOrBuilderList()

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

Specified by:

getSourcesOrBuilderList in interface StoreTypes.StreamingQueryProgressOrBuilder

addSourcesBuilder

public StoreTypes.SourceProgress.Builder addSourcesBuilder()

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

addSourcesBuilder

public StoreTypes.SourceProgress.Builder addSourcesBuilder(int index)

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

getSourcesBuilderList

public List<StoreTypes.SourceProgress.Builder> getSourcesBuilderList()

repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;

hasSink

public boolean hasSink()

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

Specified by:

hasSink in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

Whether the sink field is set.

getSink

public StoreTypes.SinkProgress getSink()

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

Specified by:

getSink in interface StoreTypes.StreamingQueryProgressOrBuilder

Returns:

The sink.

setSink

public StoreTypes.StreamingQueryProgress.Builder setSink(StoreTypes.SinkProgress value)

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

setSink

public StoreTypes.StreamingQueryProgress.Builder setSink(StoreTypes.SinkProgress.Builder builderForValue)

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

mergeSink

public StoreTypes.StreamingQueryProgress.Builder mergeSink(StoreTypes.SinkProgress value)

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

clearSink

public StoreTypes.StreamingQueryProgress.Builder clearSink()

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

getSinkBuilder

public StoreTypes.SinkProgress.Builder getSinkBuilder()

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

getSinkOrBuilder

public StoreTypes.SinkProgressOrBuilder getSinkOrBuilder()

.org.apache.spark.status.protobuf.SinkProgress sink = 11;

Specified by:

getSinkOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilder

getObservedMetricsCount

public int getObservedMetricsCount()

Description copied from interface: StoreTypes.StreamingQueryProgressOrBuilder

map<string, string> observed_metrics = 12;

Specified by:

getObservedMetricsCount in interface StoreTypes.StreamingQueryProgressOrBuilder

containsObservedMetrics

public boolean containsObservedMetrics(String key)

map<string, string> observed_metrics = 12;

Specified by:

containsObservedMetrics in interface StoreTypes.StreamingQueryProgressOrBuilder

getObservedMetrics

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

Deprecated.

Use getObservedMetricsMap() instead.

Specified by:

getObservedMetrics in interface StoreTypes.StreamingQueryProgressOrBuilder

getObservedMetricsMap

public Map<String,String> getObservedMetricsMap()

map<string, string> observed_metrics = 12;

Specified by:

getObservedMetricsMap in interface StoreTypes.StreamingQueryProgressOrBuilder

getObservedMetricsOrDefault

public String getObservedMetricsOrDefault(String key,
 String defaultValue)

map<string, string> observed_metrics = 12;

Specified by:

getObservedMetricsOrDefault in interface StoreTypes.StreamingQueryProgressOrBuilder

getObservedMetricsOrThrow

public String getObservedMetricsOrThrow(String key)

map<string, string> observed_metrics = 12;

Specified by:

getObservedMetricsOrThrow in interface StoreTypes.StreamingQueryProgressOrBuilder

clearObservedMetrics

public StoreTypes.StreamingQueryProgress.Builder clearObservedMetrics()

removeObservedMetrics

public StoreTypes.StreamingQueryProgress.Builder removeObservedMetrics(String key)

map<string, string> observed_metrics = 12;

getMutableObservedMetrics

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

Deprecated.

Use alternate mutation accessors instead.

putObservedMetrics

public StoreTypes.StreamingQueryProgress.Builder putObservedMetrics(String key,
 String value)

map<string, string> observed_metrics = 12;

putAllObservedMetrics

public StoreTypes.StreamingQueryProgress.Builder putAllObservedMetrics(Map<String,String> values)

map<string, string> observed_metrics = 12;