StoreTypes.StreamingQueryProgress (Spark 3.4.1 JavaDoc)

Object
- com.google.protobuf.AbstractMessageLite
- - com.google.protobuf.AbstractMessage
  - - com.google.protobuf.GeneratedMessageV3
    - - org.apache.spark.status.protobuf.StoreTypes.StreamingQueryProgress

All Implemented Interfaces:

com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, java.io.Serializable, StoreTypes.StreamingQueryProgressOrBuilder

Enclosing class:

StoreTypes
```
public static final class StoreTypes.StreamingQueryProgress
extends com.google.protobuf.GeneratedMessageV3
implements StoreTypes.StreamingQueryProgressOrBuilder
```
Protobuf type org.apache.spark.status.protobuf.StreamingQueryProgress

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class StoreTypes.StreamingQueryProgress.Builder
Protobuf type org.apache.spark.status.protobuf.StreamingQueryProgress
- Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
  com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable

Nested Classes
Modifier and Type	Class and Description
`static class`	`StoreTypes.StreamingQueryProgress.Builder` Protobuf type `org.apache.spark.status.protobuf.StreamingQueryProgress`

Field Summary

Fields
Modifier and Type	Field and Description
`static int`	`BATCH_DURATION_FIELD_NUMBER`
`static int`	`BATCH_ID_FIELD_NUMBER`
`static int`	`DURATION_MS_FIELD_NUMBER`
`static int`	`EVENT_TIME_FIELD_NUMBER`
`static int`	`ID_FIELD_NUMBER`
`static int`	`NAME_FIELD_NUMBER`
`static int`	`OBSERVED_METRICS_FIELD_NUMBER`
`static int`	`RUN_ID_FIELD_NUMBER`
`static int`	`SINK_FIELD_NUMBER`
`static int`	`SOURCES_FIELD_NUMBER`
`static int`	`STATE_OPERATORS_FIELD_NUMBER`
`static int`	`TIMESTAMP_FIELD_NUMBER`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`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;`
`boolean`	`equals(Object obj)`
`long`	`getBatchDuration()` `int64 batch_duration = 6;`
`long`	`getBatchId()` `int64 batch_id = 5;`
`static StoreTypes.StreamingQueryProgress`	`getDefaultInstance()`
`StoreTypes.StreamingQueryProgress`	`getDefaultInstanceForType()`
`static com.google.protobuf.Descriptors.Descriptor`	`getDescriptor()`
`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;`
`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;`
`com.google.protobuf.Parser<StoreTypes.StreamingQueryProgress>`	`getParserForType()`
`String`	`getRunId()` `optional string run_id = 2;`
`com.google.protobuf.ByteString`	`getRunIdBytes()` `optional string run_id = 2;`
`int`	`getSerializedSize()`
`StoreTypes.SinkProgress`	`getSink()` `.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;`
`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;`
`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;`
`com.google.protobuf.UnknownFieldSet`	`getUnknownFields()`
`int`	`hashCode()`
`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()`
`static StoreTypes.StreamingQueryProgress.Builder`	`newBuilder()`
`static StoreTypes.StreamingQueryProgress.Builder`	`newBuilder(StoreTypes.StreamingQueryProgress prototype)`
`StoreTypes.StreamingQueryProgress.Builder`	`newBuilderForType()`
`static StoreTypes.StreamingQueryProgress`	`parseDelimitedFrom(java.io.InputStream input)`
`static StoreTypes.StreamingQueryProgress`	`parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(byte[] data)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(java.nio.ByteBuffer data)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(com.google.protobuf.ByteString data)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(com.google.protobuf.CodedInputStream input)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(java.io.InputStream input)`
`static StoreTypes.StreamingQueryProgress`	`parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)`
`static com.google.protobuf.Parser<StoreTypes.StreamingQueryProgress>`	`parser()`
`StoreTypes.StreamingQueryProgress.Builder`	`toBuilder()`
`void`	`writeTo(com.google.protobuf.CodedOutputStream output)`

Methods inherited from class com.google.protobuf.GeneratedMessageV3
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof

Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo

Methods inherited from class Object
getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo

- Field Detail
  - ID_FIELD_NUMBER
```
public static final int ID_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - RUN_ID_FIELD_NUMBER
```
public static final int RUN_ID_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - NAME_FIELD_NUMBER
```
public static final int NAME_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - TIMESTAMP_FIELD_NUMBER
```
public static final int TIMESTAMP_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - BATCH_ID_FIELD_NUMBER
```
public static final int BATCH_ID_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - BATCH_DURATION_FIELD_NUMBER
```
public static final int BATCH_DURATION_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - DURATION_MS_FIELD_NUMBER
```
public static final int DURATION_MS_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - EVENT_TIME_FIELD_NUMBER
```
public static final int EVENT_TIME_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - STATE_OPERATORS_FIELD_NUMBER
```
public static final int STATE_OPERATORS_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - SOURCES_FIELD_NUMBER
```
public static final int SOURCES_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - SINK_FIELD_NUMBER
```
public static final int SINK_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
  - OBSERVED_METRICS_FIELD_NUMBER
```
public static final int OBSERVED_METRICS_FIELD_NUMBER
```
    See Also:
    
    Constant Field Values
- Method Detail
  - getUnknownFields
```
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
```
    Specified by:
    
    getUnknownFields in interface com.google.protobuf.MessageOrBuilder
    
    Overrides:
    
    getUnknownFields in class com.google.protobuf.GeneratedMessageV3
  - getDescriptor
```
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
```
  - 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.
  - 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.
  - 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.
  - 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.
  - getBatchId
```
public long getBatchId()
```
    int64 batch_id = 5;
    
    Specified by:
    
    getBatchId in interface StoreTypes.StreamingQueryProgressOrBuilder
    
    Returns:
    
    The batchId.
  - getBatchDuration
```
public long getBatchDuration()
```
    int64 batch_duration = 6;
    
    Specified by:
    
    getBatchDuration in interface StoreTypes.StreamingQueryProgressOrBuilder
    
    Returns:
    
    The batchDuration.
  - 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 java.util.Map<String,Long> getDurationMs()
```
    Deprecated.
    
    Use getDurationMsMap() instead.
    
    Specified by:
    
    getDurationMs in interface StoreTypes.StreamingQueryProgressOrBuilder
  - getDurationMsMap
```
public java.util.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
  - 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 java.util.Map<String,String> getEventTime()
```
    Deprecated.
    
    Use getEventTimeMap() instead.
    
    Specified by:
    
    getEventTime in interface StoreTypes.StreamingQueryProgressOrBuilder
  - getEventTimeMap
```
public java.util.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
  - getStateOperatorsList
```
public java.util.List<StoreTypes.StateOperatorProgress> getStateOperatorsList()
```
    repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
    
    Specified by:
    
    getStateOperatorsList in interface StoreTypes.StreamingQueryProgressOrBuilder
  - getStateOperatorsOrBuilderList
```
public java.util.List<? extends StoreTypes.StateOperatorProgressOrBuilder> getStateOperatorsOrBuilderList()
```
    repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
    
    Specified by:
    
    getStateOperatorsOrBuilderList 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
  - getStateOperatorsOrBuilder
```
public StoreTypes.StateOperatorProgressOrBuilder getStateOperatorsOrBuilder(int index)
```
    repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
    
    Specified by:
    
    getStateOperatorsOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilder
  - getSourcesList
```
public java.util.List<StoreTypes.SourceProgress> getSourcesList()
```
    repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
    
    Specified by:
    
    getSourcesList in interface StoreTypes.StreamingQueryProgressOrBuilder
  - getSourcesOrBuilderList
```
public java.util.List<? extends StoreTypes.SourceProgressOrBuilder> getSourcesOrBuilderList()
```
    repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
    
    Specified by:
    
    getSourcesOrBuilderList 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
  - getSourcesOrBuilder
```
public StoreTypes.SourceProgressOrBuilder getSourcesOrBuilder(int index)
```
    repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
    
    Specified by:
    
    getSourcesOrBuilder in interface StoreTypes.StreamingQueryProgressOrBuilder
  - 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.
  - 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 java.util.Map<String,String> getObservedMetrics()
```
    Deprecated.
    
    Use getObservedMetricsMap() instead.
    
    Specified by:
    
    getObservedMetrics in interface StoreTypes.StreamingQueryProgressOrBuilder
  - getObservedMetricsMap
```
public java.util.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
  - isInitialized
```
public final boolean isInitialized()
```
    Specified by:
    
    isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
    
    Overrides:
    
    isInitialized in class com.google.protobuf.GeneratedMessageV3
  - writeTo
```
public void writeTo(com.google.protobuf.CodedOutputStream output)
             throws java.io.IOException
```
    Specified by:
    
    writeTo in interface com.google.protobuf.MessageLite
    
    Overrides:
    
    writeTo in class com.google.protobuf.GeneratedMessageV3
    
    Throws:
    
    java.io.IOException
  - getSerializedSize
```
public int getSerializedSize()
```
    Specified by:
    
    getSerializedSize in interface com.google.protobuf.MessageLite
    
    Overrides:
    
    getSerializedSize in class com.google.protobuf.GeneratedMessageV3
  - equals
```
public boolean equals(Object obj)
```
    Specified by:
    
    equals in interface com.google.protobuf.Message
    
    Overrides:
    
    equals in class com.google.protobuf.AbstractMessage
  - hashCode
```
public int hashCode()
```
    Specified by:
    
    hashCode in interface com.google.protobuf.Message
    
    Overrides:
    
    hashCode in class com.google.protobuf.AbstractMessage
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(java.nio.ByteBuffer data)
                                                   throws com.google.protobuf.InvalidProtocolBufferException
```
    Throws:
    
    com.google.protobuf.InvalidProtocolBufferException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(java.nio.ByteBuffer data,
                                                          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                   throws com.google.protobuf.InvalidProtocolBufferException
```
    Throws:
    
    com.google.protobuf.InvalidProtocolBufferException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(com.google.protobuf.ByteString data)
                                                   throws com.google.protobuf.InvalidProtocolBufferException
```
    Throws:
    
    com.google.protobuf.InvalidProtocolBufferException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(com.google.protobuf.ByteString data,
                                                          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                   throws com.google.protobuf.InvalidProtocolBufferException
```
    Throws:
    
    com.google.protobuf.InvalidProtocolBufferException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(byte[] data)
                                                   throws com.google.protobuf.InvalidProtocolBufferException
```
    Throws:
    
    com.google.protobuf.InvalidProtocolBufferException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(byte[] data,
                                                          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                   throws com.google.protobuf.InvalidProtocolBufferException
```
    Throws:
    
    com.google.protobuf.InvalidProtocolBufferException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(java.io.InputStream input)
                                                   throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(java.io.InputStream input,
                                                          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                   throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - parseDelimitedFrom
```
public static StoreTypes.StreamingQueryProgress parseDelimitedFrom(java.io.InputStream input)
                                                            throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - parseDelimitedFrom
```
public static StoreTypes.StreamingQueryProgress parseDelimitedFrom(java.io.InputStream input,
                                                                   com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                            throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(com.google.protobuf.CodedInputStream input)
                                                   throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - parseFrom
```
public static StoreTypes.StreamingQueryProgress parseFrom(com.google.protobuf.CodedInputStream input,
                                                          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                   throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - newBuilderForType
```
public StoreTypes.StreamingQueryProgress.Builder newBuilderForType()
```
    Specified by:
    
    newBuilderForType in interface com.google.protobuf.Message
    
    Specified by:
    
    newBuilderForType in interface com.google.protobuf.MessageLite
  - newBuilder
```
public static StoreTypes.StreamingQueryProgress.Builder newBuilder()
```
  - newBuilder
```
public static StoreTypes.StreamingQueryProgress.Builder newBuilder(StoreTypes.StreamingQueryProgress prototype)
```
  - toBuilder
```
public StoreTypes.StreamingQueryProgress.Builder toBuilder()
```
    Specified by:
    
    toBuilder in interface com.google.protobuf.Message
    
    Specified by:
    
    toBuilder in interface com.google.protobuf.MessageLite
  - getDefaultInstance
```
public static StoreTypes.StreamingQueryProgress getDefaultInstance()
```
  - parser
```
public static com.google.protobuf.Parser<StoreTypes.StreamingQueryProgress> parser()
```
  - getParserForType
```
public com.google.protobuf.Parser<StoreTypes.StreamingQueryProgress> getParserForType()
```
    Specified by:
    
    getParserForType in interface com.google.protobuf.Message
    
    Specified by:
    
    getParserForType in interface com.google.protobuf.MessageLite
    
    Overrides:
    
    getParserForType in class com.google.protobuf.GeneratedMessageV3
  - getDefaultInstanceForType
```
public StoreTypes.StreamingQueryProgress getDefaultInstanceForType()
```
    Specified by:
    
    getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
    
    Specified by:
    
    getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

Class StoreTypes.StreamingQueryProgress

Nested Class Summary

Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3

Field Summary

Method Summary

Methods inherited from class com.google.protobuf.GeneratedMessageV3

Methods inherited from class com.google.protobuf.AbstractMessage

Methods inherited from class com.google.protobuf.AbstractMessageLite

Methods inherited from class Object

Methods inherited from interface com.google.protobuf.MessageOrBuilder

Methods inherited from interface com.google.protobuf.MessageLite

Field Detail

ID_FIELD_NUMBER

RUN_ID_FIELD_NUMBER

NAME_FIELD_NUMBER

TIMESTAMP_FIELD_NUMBER

BATCH_ID_FIELD_NUMBER

BATCH_DURATION_FIELD_NUMBER

DURATION_MS_FIELD_NUMBER

EVENT_TIME_FIELD_NUMBER

STATE_OPERATORS_FIELD_NUMBER

SOURCES_FIELD_NUMBER

SINK_FIELD_NUMBER

OBSERVED_METRICS_FIELD_NUMBER

Method Detail

getUnknownFields

getDescriptor

hasId

getId

getIdBytes

hasRunId

getRunId

getRunIdBytes

hasName

getName

getNameBytes

hasTimestamp

getTimestamp

getTimestampBytes

getBatchId

getBatchDuration

getDurationMsCount

containsDurationMs

getDurationMs

getDurationMsMap

getDurationMsOrDefault

getDurationMsOrThrow

getEventTimeCount

containsEventTime

getEventTime

getEventTimeMap

getEventTimeOrDefault

getEventTimeOrThrow

getStateOperatorsList

getStateOperatorsOrBuilderList

getStateOperatorsCount

getStateOperators

getStateOperatorsOrBuilder

getSourcesList

getSourcesOrBuilderList

getSourcesCount

getSources

getSourcesOrBuilder

hasSink

getSink

getSinkOrBuilder

getObservedMetricsCount

containsObservedMetrics

getObservedMetrics

getObservedMetricsMap

getObservedMetricsOrDefault

getObservedMetricsOrThrow

isInitialized

writeTo

getSerializedSize

equals

hashCode

parseFrom

parseFrom

parseFrom