public static final class StoreTypes.StreamingQueryProgress.Builder extends com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder> implements StoreTypes.StreamingQueryProgressOrBuilder
org.apache.spark.status.protobuf.StreamingQueryProgress| Modifier and Type | Method and 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 |
addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
StoreTypes.StreamingQueryProgress.Builder |
addSources(int index,
StoreTypes.SourceProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10; |
StoreTypes.StreamingQueryProgress.Builder |
addSources(int index,
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.StreamingQueryProgress.Builder |
addSources(StoreTypes.SourceProgress value)
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.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9; |
StoreTypes.StreamingQueryProgress.Builder |
addStateOperators(int index,
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.StreamingQueryProgress.Builder |
addStateOperators(StoreTypes.StateOperatorProgress value)
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 |
clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
StoreTypes.StreamingQueryProgress.Builder |
clearId()
optional string id = 1; |
StoreTypes.StreamingQueryProgress.Builder |
clearName()
optional string name = 3; |
StoreTypes.StreamingQueryProgress.Builder |
clearObservedMetrics() |
StoreTypes.StreamingQueryProgress.Builder |
clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
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; |
StoreTypes.StreamingQueryProgress.Builder |
clone() |
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 com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
com.google.protobuf.Descriptors.Descriptor |
getDescriptorForType() |
java.util.Map<String,Long> |
getDurationMs()
Deprecated.
|
int |
getDurationMsCount()
map<string, int64> duration_ms = 7; |
java.util.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; |
java.util.Map<String,String> |
getEventTime()
Deprecated.
|
int |
getEventTimeCount()
map<string, string> event_time = 8; |
java.util.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; |
java.util.Map<String,Long> |
getMutableDurationMs()
Deprecated.
|
java.util.Map<String,String> |
getMutableEventTime()
Deprecated.
|
java.util.Map<String,String> |
getMutableObservedMetrics()
Deprecated.
|
String |
getName()
optional string name = 3; |
com.google.protobuf.ByteString |
getNameBytes()
optional string name = 3; |
java.util.Map<String,String> |
getObservedMetrics()
Deprecated.
|
int |
getObservedMetricsCount()
map<string, string> observed_metrics = 12; |
java.util.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; |
java.util.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; |
java.util.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; |
java.util.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; |
java.util.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; |
java.util.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; |
java.util.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; |
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 |
mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
StoreTypes.StreamingQueryProgress.Builder |
putAllDurationMs(java.util.Map<String,Long> values)
map<string, int64> duration_ms = 7; |
StoreTypes.StreamingQueryProgress.Builder |
putAllEventTime(java.util.Map<String,String> values)
map<string, string> event_time = 8; |
StoreTypes.StreamingQueryProgress.Builder |
putAllObservedMetrics(java.util.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 |
setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
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 |
setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
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.Builder builderForValue)
.org.apache.spark.status.protobuf.SinkProgress sink = 11; |
StoreTypes.StreamingQueryProgress.Builder |
setSink(StoreTypes.SinkProgress value)
.org.apache.spark.status.protobuf.SinkProgress sink = 11; |
StoreTypes.StreamingQueryProgress.Builder |
setSources(int index,
StoreTypes.SourceProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10; |
StoreTypes.StreamingQueryProgress.Builder |
setSources(int index,
StoreTypes.SourceProgress value)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10; |
StoreTypes.StreamingQueryProgress.Builder |
setStateOperators(int index,
StoreTypes.StateOperatorProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9; |
StoreTypes.StreamingQueryProgress.Builder |
setStateOperators(int index,
StoreTypes.StateOperatorProgress value)
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; |
StoreTypes.StreamingQueryProgress.Builder |
setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newBuilderForFieldfindInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toStringpublic static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.StreamingQueryProgress.Builder clear()
clear in interface com.google.protobuf.Message.Builderclear in interface com.google.protobuf.MessageLite.Builderclear in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType in interface com.google.protobuf.Message.BuildergetDescriptorForType in interface com.google.protobuf.MessageOrBuildergetDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress getDefaultInstanceForType()
getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuildergetDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilderpublic StoreTypes.StreamingQueryProgress build()
build in interface com.google.protobuf.Message.Builderbuild in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.StreamingQueryProgress buildPartial()
buildPartial in interface com.google.protobuf.Message.BuilderbuildPartial in interface com.google.protobuf.MessageLite.Builderpublic StoreTypes.StreamingQueryProgress.Builder clone()
clone in interface com.google.protobuf.Message.Builderclone in interface com.google.protobuf.MessageLite.Builderclone in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
setField in interface com.google.protobuf.Message.BuildersetField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
clearField in interface com.google.protobuf.Message.BuilderclearField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
clearOneof in interface com.google.protobuf.Message.BuilderclearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
setRepeatedField in interface com.google.protobuf.Message.BuildersetRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
addRepeatedField in interface com.google.protobuf.Message.BuilderaddRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder mergeFrom(com.google.protobuf.Message other)
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder mergeFrom(StoreTypes.StreamingQueryProgress other)
public final boolean isInitialized()
isInitialized in interface com.google.protobuf.MessageLiteOrBuilderisInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public StoreTypes.StreamingQueryProgress.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
mergeFrom in interface com.google.protobuf.Message.BuildermergeFrom in interface com.google.protobuf.MessageLite.BuildermergeFrom in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StreamingQueryProgress.Builder>java.io.IOExceptionpublic boolean hasId()
optional string id = 1;hasId in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getId()
optional string id = 1;getId in interface StoreTypes.StreamingQueryProgressOrBuilderpublic com.google.protobuf.ByteString getIdBytes()
optional string id = 1;getIdBytes in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setId(String value)
optional string id = 1;value - The id to set.public StoreTypes.StreamingQueryProgress.Builder clearId()
optional string id = 1;public StoreTypes.StreamingQueryProgress.Builder setIdBytes(com.google.protobuf.ByteString value)
optional string id = 1;value - The bytes for id to set.public boolean hasRunId()
optional string run_id = 2;hasRunId in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getRunId()
optional string run_id = 2;getRunId in interface StoreTypes.StreamingQueryProgressOrBuilderpublic com.google.protobuf.ByteString getRunIdBytes()
optional string run_id = 2;getRunIdBytes in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setRunId(String value)
optional string run_id = 2;value - The runId to set.public StoreTypes.StreamingQueryProgress.Builder clearRunId()
optional string run_id = 2;public StoreTypes.StreamingQueryProgress.Builder setRunIdBytes(com.google.protobuf.ByteString value)
optional string run_id = 2;value - The bytes for runId to set.public boolean hasName()
optional string name = 3;hasName in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getName()
optional string name = 3;getName in interface StoreTypes.StreamingQueryProgressOrBuilderpublic com.google.protobuf.ByteString getNameBytes()
optional string name = 3;getNameBytes in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setName(String value)
optional string name = 3;value - The name to set.public StoreTypes.StreamingQueryProgress.Builder clearName()
optional string name = 3;public StoreTypes.StreamingQueryProgress.Builder setNameBytes(com.google.protobuf.ByteString value)
optional string name = 3;value - The bytes for name to set.public boolean hasTimestamp()
optional string timestamp = 4;hasTimestamp in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getTimestamp()
optional string timestamp = 4;getTimestamp in interface StoreTypes.StreamingQueryProgressOrBuilderpublic com.google.protobuf.ByteString getTimestampBytes()
optional string timestamp = 4;getTimestampBytes in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setTimestamp(String value)
optional string timestamp = 4;value - The timestamp to set.public StoreTypes.StreamingQueryProgress.Builder clearTimestamp()
optional string timestamp = 4;public StoreTypes.StreamingQueryProgress.Builder setTimestampBytes(com.google.protobuf.ByteString value)
optional string timestamp = 4;value - The bytes for timestamp to set.public long getBatchId()
int64 batch_id = 5;getBatchId in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setBatchId(long value)
int64 batch_id = 5;value - The batchId to set.public StoreTypes.StreamingQueryProgress.Builder clearBatchId()
int64 batch_id = 5;public long getBatchDuration()
int64 batch_duration = 6;getBatchDuration in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setBatchDuration(long value)
int64 batch_duration = 6;value - The batchDuration to set.public StoreTypes.StreamingQueryProgress.Builder clearBatchDuration()
int64 batch_duration = 6;public int getDurationMsCount()
StoreTypes.StreamingQueryProgressOrBuildermap<string, int64> duration_ms = 7;getDurationMsCount in interface StoreTypes.StreamingQueryProgressOrBuilderpublic boolean containsDurationMs(String key)
map<string, int64> duration_ms = 7;containsDurationMs in interface StoreTypes.StreamingQueryProgressOrBuilder@Deprecated public java.util.Map<String,Long> getDurationMs()
getDurationMsMap() instead.getDurationMs in interface StoreTypes.StreamingQueryProgressOrBuilderpublic java.util.Map<String,Long> getDurationMsMap()
map<string, int64> duration_ms = 7;getDurationMsMap in interface StoreTypes.StreamingQueryProgressOrBuilderpublic long getDurationMsOrDefault(String key,
long defaultValue)
map<string, int64> duration_ms = 7;getDurationMsOrDefault in interface StoreTypes.StreamingQueryProgressOrBuilderpublic long getDurationMsOrThrow(String key)
map<string, int64> duration_ms = 7;getDurationMsOrThrow in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder clearDurationMs()
public StoreTypes.StreamingQueryProgress.Builder removeDurationMs(String key)
map<string, int64> duration_ms = 7;@Deprecated public java.util.Map<String,Long> getMutableDurationMs()
public StoreTypes.StreamingQueryProgress.Builder putDurationMs(String key, long value)
map<string, int64> duration_ms = 7;public StoreTypes.StreamingQueryProgress.Builder putAllDurationMs(java.util.Map<String,Long> values)
map<string, int64> duration_ms = 7;public int getEventTimeCount()
StoreTypes.StreamingQueryProgressOrBuildermap<string, string> event_time = 8;getEventTimeCount in interface StoreTypes.StreamingQueryProgressOrBuilderpublic boolean containsEventTime(String key)
map<string, string> event_time = 8;containsEventTime in interface StoreTypes.StreamingQueryProgressOrBuilder@Deprecated public java.util.Map<String,String> getEventTime()
getEventTimeMap() instead.getEventTime in interface StoreTypes.StreamingQueryProgressOrBuilderpublic java.util.Map<String,String> getEventTimeMap()
map<string, string> event_time = 8;getEventTimeMap in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getEventTimeOrDefault(String key,
String defaultValue)
map<string, string> event_time = 8;getEventTimeOrDefault in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getEventTimeOrThrow(String key)
map<string, string> event_time = 8;getEventTimeOrThrow in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder clearEventTime()
public StoreTypes.StreamingQueryProgress.Builder removeEventTime(String key)
map<string, string> event_time = 8;@Deprecated public java.util.Map<String,String> getMutableEventTime()
public StoreTypes.StreamingQueryProgress.Builder putEventTime(String key, String value)
map<string, string> event_time = 8;public StoreTypes.StreamingQueryProgress.Builder putAllEventTime(java.util.Map<String,String> values)
map<string, string> event_time = 8;public java.util.List<StoreTypes.StateOperatorProgress> getStateOperatorsList()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;getStateOperatorsList in interface StoreTypes.StreamingQueryProgressOrBuilderpublic int getStateOperatorsCount()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;getStateOperatorsCount in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StateOperatorProgress getStateOperators(int index)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;getStateOperators in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setStateOperators(int index, StoreTypes.StateOperatorProgress value)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder setStateOperators(int index, StoreTypes.StateOperatorProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder addStateOperators(StoreTypes.StateOperatorProgress value)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder addStateOperators(int index, StoreTypes.StateOperatorProgress value)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder addStateOperators(StoreTypes.StateOperatorProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder addStateOperators(int index, StoreTypes.StateOperatorProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder addAllStateOperators(Iterable<? extends StoreTypes.StateOperatorProgress> values)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder clearStateOperators()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StreamingQueryProgress.Builder removeStateOperators(int index)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StateOperatorProgress.Builder getStateOperatorsBuilder(int index)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StateOperatorProgressOrBuilder getStateOperatorsOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;getStateOperatorsOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilderpublic java.util.List<? extends StoreTypes.StateOperatorProgressOrBuilder> getStateOperatorsOrBuilderList()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;getStateOperatorsOrBuilderList in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StateOperatorProgress.Builder addStateOperatorsBuilder()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public StoreTypes.StateOperatorProgress.Builder addStateOperatorsBuilder(int index)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public java.util.List<StoreTypes.StateOperatorProgress.Builder> getStateOperatorsBuilderList()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;public java.util.List<StoreTypes.SourceProgress> getSourcesList()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;getSourcesList in interface StoreTypes.StreamingQueryProgressOrBuilderpublic int getSourcesCount()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;getSourcesCount in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.SourceProgress getSources(int index)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;getSources in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setSources(int index, StoreTypes.SourceProgress value)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder setSources(int index, StoreTypes.SourceProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder addSources(StoreTypes.SourceProgress value)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder addSources(int index, StoreTypes.SourceProgress value)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder addSources(StoreTypes.SourceProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder addSources(int index, StoreTypes.SourceProgress.Builder builderForValue)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder addAllSources(Iterable<? extends StoreTypes.SourceProgress> values)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder clearSources()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.StreamingQueryProgress.Builder removeSources(int index)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.SourceProgress.Builder getSourcesBuilder(int index)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.SourceProgressOrBuilder getSourcesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;getSourcesOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilderpublic java.util.List<? extends StoreTypes.SourceProgressOrBuilder> getSourcesOrBuilderList()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;getSourcesOrBuilderList in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.SourceProgress.Builder addSourcesBuilder()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public StoreTypes.SourceProgress.Builder addSourcesBuilder(int index)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public java.util.List<StoreTypes.SourceProgress.Builder> getSourcesBuilderList()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;public boolean hasSink()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;hasSink in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.SinkProgress getSink()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;getSink in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder setSink(StoreTypes.SinkProgress value)
.org.apache.spark.status.protobuf.SinkProgress sink = 11;public StoreTypes.StreamingQueryProgress.Builder setSink(StoreTypes.SinkProgress.Builder builderForValue)
.org.apache.spark.status.protobuf.SinkProgress sink = 11;public StoreTypes.StreamingQueryProgress.Builder mergeSink(StoreTypes.SinkProgress value)
.org.apache.spark.status.protobuf.SinkProgress sink = 11;public StoreTypes.StreamingQueryProgress.Builder clearSink()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;public StoreTypes.SinkProgress.Builder getSinkBuilder()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;public StoreTypes.SinkProgressOrBuilder getSinkOrBuilder()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;getSinkOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilderpublic int getObservedMetricsCount()
StoreTypes.StreamingQueryProgressOrBuildermap<string, string> observed_metrics = 12;getObservedMetricsCount in interface StoreTypes.StreamingQueryProgressOrBuilderpublic boolean containsObservedMetrics(String key)
map<string, string> observed_metrics = 12;containsObservedMetrics in interface StoreTypes.StreamingQueryProgressOrBuilder@Deprecated public java.util.Map<String,String> getObservedMetrics()
getObservedMetricsMap() instead.getObservedMetrics in interface StoreTypes.StreamingQueryProgressOrBuilderpublic java.util.Map<String,String> getObservedMetricsMap()
map<string, string> observed_metrics = 12;getObservedMetricsMap in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getObservedMetricsOrDefault(String key,
String defaultValue)
map<string, string> observed_metrics = 12;getObservedMetricsOrDefault in interface StoreTypes.StreamingQueryProgressOrBuilderpublic String getObservedMetricsOrThrow(String key)
map<string, string> observed_metrics = 12;getObservedMetricsOrThrow in interface StoreTypes.StreamingQueryProgressOrBuilderpublic StoreTypes.StreamingQueryProgress.Builder clearObservedMetrics()
public StoreTypes.StreamingQueryProgress.Builder removeObservedMetrics(String key)
map<string, string> observed_metrics = 12;@Deprecated public java.util.Map<String,String> getMutableObservedMetrics()
public StoreTypes.StreamingQueryProgress.Builder putObservedMetrics(String key, String value)
map<string, string> observed_metrics = 12;public StoreTypes.StreamingQueryProgress.Builder putAllObservedMetrics(java.util.Map<String,String> values)
map<string, string> observed_metrics = 12;public final StoreTypes.StreamingQueryProgress.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
setUnknownFields in interface com.google.protobuf.Message.BuildersetUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>public final StoreTypes.StreamingQueryProgress.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
mergeUnknownFields in interface com.google.protobuf.Message.BuildermergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>