public static interface StoreTypes.StreamingQueryProgressOrBuilder
extends com.google.protobuf.MessageOrBuilder
| 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; |
long |
getBatchDuration()
int64 batch_duration = 6; |
long |
getBatchId()
int64 batch_id = 5; |
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; |
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.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; |
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; |
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneofboolean hasId()
optional string id = 1;String getId()
optional string id = 1;com.google.protobuf.ByteString getIdBytes()
optional string id = 1;boolean hasRunId()
optional string run_id = 2;String getRunId()
optional string run_id = 2;com.google.protobuf.ByteString getRunIdBytes()
optional string run_id = 2;boolean hasName()
optional string name = 3;String getName()
optional string name = 3;com.google.protobuf.ByteString getNameBytes()
optional string name = 3;boolean hasTimestamp()
optional string timestamp = 4;String getTimestamp()
optional string timestamp = 4;com.google.protobuf.ByteString getTimestampBytes()
optional string timestamp = 4;long getBatchId()
int64 batch_id = 5;long getBatchDuration()
int64 batch_duration = 6;int getDurationMsCount()
map<string, int64> duration_ms = 7;boolean containsDurationMs(String key)
map<string, int64> duration_ms = 7;@Deprecated java.util.Map<String,Long> getDurationMs()
getDurationMsMap() instead.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;int getEventTimeCount()
map<string, string> event_time = 8;boolean containsEventTime(String key)
map<string, string> event_time = 8;@Deprecated java.util.Map<String,String> getEventTime()
getEventTimeMap() instead.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;java.util.List<StoreTypes.StateOperatorProgress> getStateOperatorsList()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;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<? extends StoreTypes.StateOperatorProgressOrBuilder> getStateOperatorsOrBuilderList()
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<StoreTypes.SourceProgress> getSourcesList()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;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<? extends StoreTypes.SourceProgressOrBuilder> getSourcesOrBuilderList()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;StoreTypes.SourceProgressOrBuilder getSourcesOrBuilder(int index)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;boolean hasSink()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;StoreTypes.SinkProgress getSink()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;StoreTypes.SinkProgressOrBuilder getSinkOrBuilder()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;int getObservedMetricsCount()
map<string, string> observed_metrics = 12;boolean containsObservedMetrics(String key)
map<string, string> observed_metrics = 12;@Deprecated java.util.Map<String,String> getObservedMetrics()
getObservedMetricsMap() instead.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;