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, hasOneof
boolean 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;