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, newBuilderForField
findInitializationErrors, getInitializationErrorString, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, toString
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
public StoreTypes.StreamingQueryProgress.Builder clear()
clear
in interface com.google.protobuf.Message.Builder
clear
in interface com.google.protobuf.MessageLite.Builder
clear
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
getDescriptorForType
in interface com.google.protobuf.Message.Builder
getDescriptorForType
in interface com.google.protobuf.MessageOrBuilder
getDescriptorForType
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>
public StoreTypes.StreamingQueryProgress getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
public StoreTypes.StreamingQueryProgress build()
build
in interface com.google.protobuf.Message.Builder
build
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.StreamingQueryProgress buildPartial()
buildPartial
in interface com.google.protobuf.Message.Builder
buildPartial
in interface com.google.protobuf.MessageLite.Builder
public StoreTypes.StreamingQueryProgress.Builder clone()
clone
in interface com.google.protobuf.Message.Builder
clone
in interface com.google.protobuf.MessageLite.Builder
clone
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.Builder
setField
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.Builder
clearField
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.Builder
clearOneof
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.Builder
setRepeatedField
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.Builder
addRepeatedField
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.Builder
mergeFrom
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.MessageLiteOrBuilder
isInitialized
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.Builder
mergeFrom
in interface com.google.protobuf.MessageLite.Builder
mergeFrom
in class com.google.protobuf.AbstractMessage.Builder<StoreTypes.StreamingQueryProgress.Builder>
java.io.IOException
public boolean hasId()
optional string id = 1;
hasId
in interface StoreTypes.StreamingQueryProgressOrBuilder
public String getId()
optional string id = 1;
getId
in interface StoreTypes.StreamingQueryProgressOrBuilder
public com.google.protobuf.ByteString getIdBytes()
optional string id = 1;
getIdBytes
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public String getRunId()
optional string run_id = 2;
getRunId
in interface StoreTypes.StreamingQueryProgressOrBuilder
public com.google.protobuf.ByteString getRunIdBytes()
optional string run_id = 2;
getRunIdBytes
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public String getName()
optional string name = 3;
getName
in interface StoreTypes.StreamingQueryProgressOrBuilder
public com.google.protobuf.ByteString getNameBytes()
optional string name = 3;
getNameBytes
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public String getTimestamp()
optional string timestamp = 4;
getTimestamp
in interface StoreTypes.StreamingQueryProgressOrBuilder
public com.google.protobuf.ByteString getTimestampBytes()
optional string timestamp = 4;
getTimestampBytes
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
map<string, int64> duration_ms = 7;
getDurationMsCount
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public java.util.Map<String,Long> getDurationMsMap()
map<string, int64> duration_ms = 7;
getDurationMsMap
in interface StoreTypes.StreamingQueryProgressOrBuilder
public long getDurationMsOrDefault(String key, long defaultValue)
map<string, int64> duration_ms = 7;
getDurationMsOrDefault
in interface StoreTypes.StreamingQueryProgressOrBuilder
public long getDurationMsOrThrow(String key)
map<string, int64> duration_ms = 7;
getDurationMsOrThrow
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
map<string, string> event_time = 8;
getEventTimeCount
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public java.util.Map<String,String> getEventTimeMap()
map<string, string> event_time = 8;
getEventTimeMap
in interface StoreTypes.StreamingQueryProgressOrBuilder
public String getEventTimeOrDefault(String key, String defaultValue)
map<string, string> event_time = 8;
getEventTimeOrDefault
in interface StoreTypes.StreamingQueryProgressOrBuilder
public String getEventTimeOrThrow(String key)
map<string, string> event_time = 8;
getEventTimeOrThrow
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public int getStateOperatorsCount()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
getStateOperatorsCount
in interface StoreTypes.StreamingQueryProgressOrBuilder
public StoreTypes.StateOperatorProgress getStateOperators(int index)
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
getStateOperators
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public java.util.List<? extends StoreTypes.StateOperatorProgressOrBuilder> getStateOperatorsOrBuilderList()
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
getStateOperatorsOrBuilderList
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public int getSourcesCount()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
getSourcesCount
in interface StoreTypes.StreamingQueryProgressOrBuilder
public StoreTypes.SourceProgress getSources(int index)
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
getSources
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public java.util.List<? extends StoreTypes.SourceProgressOrBuilder> getSourcesOrBuilderList()
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
getSourcesOrBuilderList
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public StoreTypes.SinkProgress getSink()
.org.apache.spark.status.protobuf.SinkProgress sink = 11;
getSink
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public int getObservedMetricsCount()
StoreTypes.StreamingQueryProgressOrBuilder
map<string, string> observed_metrics = 12;
getObservedMetricsCount
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.StreamingQueryProgressOrBuilder
public java.util.Map<String,String> getObservedMetricsMap()
map<string, string> observed_metrics = 12;
getObservedMetricsMap
in interface StoreTypes.StreamingQueryProgressOrBuilder
public String getObservedMetricsOrDefault(String key, String defaultValue)
map<string, string> observed_metrics = 12;
getObservedMetricsOrDefault
in interface StoreTypes.StreamingQueryProgressOrBuilder
public String getObservedMetricsOrThrow(String key)
map<string, string> observed_metrics = 12;
getObservedMetricsOrThrow
in interface StoreTypes.StreamingQueryProgressOrBuilder
public 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.Builder
setUnknownFields
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.Builder
mergeUnknownFields
in class com.google.protobuf.GeneratedMessageV3.Builder<StoreTypes.StreamingQueryProgress.Builder>