Package org.apache.spark.status.protobuf
Class StoreTypes.StreamingQueryProgress
Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
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,Serializable,StoreTypes.StreamingQueryProgressOrBuilder
- Enclosing class:
- StoreTypes
public static final class StoreTypes.StreamingQueryProgress
extends com.google.protobuf.GeneratedMessage
implements StoreTypes.StreamingQueryProgressOrBuilder
Protobuf type
org.apache.spark.status.protobuf.StreamingQueryProgress- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classProtobuf typeorg.apache.spark.status.protobuf.StreamingQueryProgressNested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT, BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message, T extends Object> -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final intstatic final int -
Method Summary
Modifier and TypeMethodDescriptionbooleancontainsDurationMs(String key) map<string, int64> duration_ms = 7;booleancontainsEventTime(String key) map<string, string> event_time = 8;booleanmap<string, string> observed_metrics = 12;booleanlongint64 batch_duration = 6;longint64 batch_id = 5;static final com.google.protobuf.Descriptors.DescriptorDeprecated.intmap<string, int64> duration_ms = 7;map<string, int64> duration_ms = 7;longgetDurationMsOrDefault(String key, long defaultValue) map<string, int64> duration_ms = 7;longmap<string, int64> duration_ms = 7;Deprecated.intmap<string, string> event_time = 8;map<string, string> event_time = 8;getEventTimeOrDefault(String key, String defaultValue) map<string, string> event_time = 8;map<string, string> event_time = 8;getId()optional string id = 1;com.google.protobuf.ByteStringoptional string id = 1;getName()optional string name = 3;com.google.protobuf.ByteStringoptional string name = 3;Deprecated.intmap<string, string> observed_metrics = 12;map<string, string> observed_metrics = 12;getObservedMetricsOrDefault(String key, String defaultValue) map<string, string> observed_metrics = 12;map<string, string> observed_metrics = 12;com.google.protobuf.Parser<StoreTypes.StreamingQueryProgress>getRunId()optional string run_id = 2;com.google.protobuf.ByteStringoptional string run_id = 2;intgetSink().org.apache.spark.status.protobuf.SinkProgress sink = 11;.org.apache.spark.status.protobuf.SinkProgress sink = 11;getSources(int index) repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;intrepeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;getSourcesOrBuilder(int index) repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;List<? extends StoreTypes.SourceProgressOrBuilder>repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;getStateOperators(int index) repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;intrepeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;getStateOperatorsOrBuilder(int index) repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;List<? extends StoreTypes.StateOperatorProgressOrBuilder>repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;optional string timestamp = 4;com.google.protobuf.ByteStringoptional string timestamp = 4;inthashCode()booleanhasId()optional string id = 1;booleanhasName()optional string name = 3;booleanhasRunId()optional string run_id = 2;booleanhasSink().org.apache.spark.status.protobuf.SinkProgress sink = 11;booleanoptional string timestamp = 4;final booleannewBuilder(StoreTypes.StreamingQueryProgress prototype) parseDelimitedFrom(InputStream input) parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(byte[] data) parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(com.google.protobuf.ByteString data) parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(com.google.protobuf.CodedInputStream input) parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(InputStream input) parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) parseFrom(ByteBuffer data) parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static com.google.protobuf.Parser<StoreTypes.StreamingQueryProgress>parser()voidwriteTo(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessage
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, newFileScopedGeneratedExtension, newMessageScopedGeneratedExtensionMethods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Field Details
-
ID_FIELD_NUMBER
public static final int ID_FIELD_NUMBER- See Also:
-
RUN_ID_FIELD_NUMBER
public static final int RUN_ID_FIELD_NUMBER- See Also:
-
NAME_FIELD_NUMBER
public static final int NAME_FIELD_NUMBER- See Also:
-
TIMESTAMP_FIELD_NUMBER
public static final int TIMESTAMP_FIELD_NUMBER- See Also:
-
BATCH_ID_FIELD_NUMBER
public static final int BATCH_ID_FIELD_NUMBER- See Also:
-
BATCH_DURATION_FIELD_NUMBER
public static final int BATCH_DURATION_FIELD_NUMBER- See Also:
-
DURATION_MS_FIELD_NUMBER
public static final int DURATION_MS_FIELD_NUMBER- See Also:
-
EVENT_TIME_FIELD_NUMBER
public static final int EVENT_TIME_FIELD_NUMBER- See Also:
-
STATE_OPERATORS_FIELD_NUMBER
public static final int STATE_OPERATORS_FIELD_NUMBER- See Also:
-
SOURCES_FIELD_NUMBER
public static final int SOURCES_FIELD_NUMBER- See Also:
-
SINK_FIELD_NUMBER
public static final int SINK_FIELD_NUMBER- See Also:
-
OBSERVED_METRICS_FIELD_NUMBER
public static final int OBSERVED_METRICS_FIELD_NUMBER- See Also:
-
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
hasId
public boolean hasId()optional string id = 1;- Specified by:
hasIdin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- Whether the id field is set.
-
getId
optional string id = 1;- Specified by:
getIdin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The id.
-
getIdBytes
public com.google.protobuf.ByteString getIdBytes()optional string id = 1;- Specified by:
getIdBytesin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The bytes for id.
-
hasRunId
public boolean hasRunId()optional string run_id = 2;- Specified by:
hasRunIdin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- Whether the runId field is set.
-
getRunId
optional string run_id = 2;- Specified by:
getRunIdin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The runId.
-
getRunIdBytes
public com.google.protobuf.ByteString getRunIdBytes()optional string run_id = 2;- Specified by:
getRunIdBytesin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The bytes for runId.
-
hasName
public boolean hasName()optional string name = 3;- Specified by:
hasNamein interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- Whether the name field is set.
-
getName
optional string name = 3;- Specified by:
getNamein interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The name.
-
getNameBytes
public com.google.protobuf.ByteString getNameBytes()optional string name = 3;- Specified by:
getNameBytesin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The bytes for name.
-
hasTimestamp
public boolean hasTimestamp()optional string timestamp = 4;- Specified by:
hasTimestampin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- Whether the timestamp field is set.
-
getTimestamp
optional string timestamp = 4;- Specified by:
getTimestampin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The timestamp.
-
getTimestampBytes
public com.google.protobuf.ByteString getTimestampBytes()optional string timestamp = 4;- Specified by:
getTimestampBytesin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The bytes for timestamp.
-
getBatchId
public long getBatchId()int64 batch_id = 5;- Specified by:
getBatchIdin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The batchId.
-
getBatchDuration
public long getBatchDuration()int64 batch_duration = 6;- Specified by:
getBatchDurationin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The batchDuration.
-
getDurationMsCount
public int getDurationMsCount()Description copied from interface:StoreTypes.StreamingQueryProgressOrBuildermap<string, int64> duration_ms = 7;- Specified by:
getDurationMsCountin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
containsDurationMs
map<string, int64> duration_ms = 7;- Specified by:
containsDurationMsin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMs
Deprecated.UsegetDurationMsMap()instead.- Specified by:
getDurationMsin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMsMap
map<string, int64> duration_ms = 7;- Specified by:
getDurationMsMapin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMsOrDefault
map<string, int64> duration_ms = 7;- Specified by:
getDurationMsOrDefaultin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMsOrThrow
map<string, int64> duration_ms = 7;- Specified by:
getDurationMsOrThrowin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeCount
public int getEventTimeCount()Description copied from interface:StoreTypes.StreamingQueryProgressOrBuildermap<string, string> event_time = 8;- Specified by:
getEventTimeCountin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
containsEventTime
map<string, string> event_time = 8;- Specified by:
containsEventTimein interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTime
Deprecated.UsegetEventTimeMap()instead.- Specified by:
getEventTimein interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeMap
map<string, string> event_time = 8;- Specified by:
getEventTimeMapin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeOrDefault
map<string, string> event_time = 8;- Specified by:
getEventTimeOrDefaultin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeOrThrow
map<string, string> event_time = 8;- Specified by:
getEventTimeOrThrowin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsList
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;- Specified by:
getStateOperatorsListin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsOrBuilderList
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;- Specified by:
getStateOperatorsOrBuilderListin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsCount
public int getStateOperatorsCount()repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;- Specified by:
getStateOperatorsCountin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperators
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;- Specified by:
getStateOperatorsin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsOrBuilder
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;- Specified by:
getStateOperatorsOrBuilderin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesList
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;- Specified by:
getSourcesListin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesOrBuilderList
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;- Specified by:
getSourcesOrBuilderListin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesCount
public int getSourcesCount()repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;- Specified by:
getSourcesCountin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSources
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;- Specified by:
getSourcesin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesOrBuilder
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;- Specified by:
getSourcesOrBuilderin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
hasSink
public boolean hasSink().org.apache.spark.status.protobuf.SinkProgress sink = 11;- Specified by:
hasSinkin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- Whether the sink field is set.
-
getSink
.org.apache.spark.status.protobuf.SinkProgress sink = 11;- Specified by:
getSinkin interfaceStoreTypes.StreamingQueryProgressOrBuilder- Returns:
- The sink.
-
getSinkOrBuilder
.org.apache.spark.status.protobuf.SinkProgress sink = 11;- Specified by:
getSinkOrBuilderin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsCount
public int getObservedMetricsCount()Description copied from interface:StoreTypes.StreamingQueryProgressOrBuildermap<string, string> observed_metrics = 12;- Specified by:
getObservedMetricsCountin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
containsObservedMetrics
map<string, string> observed_metrics = 12;- Specified by:
containsObservedMetricsin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetrics
Deprecated.UsegetObservedMetricsMap()instead.- Specified by:
getObservedMetricsin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsMap
map<string, string> observed_metrics = 12;- Specified by:
getObservedMetricsMapin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsOrDefault
map<string, string> observed_metrics = 12;- Specified by:
getObservedMetricsOrDefaultin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsOrThrow
map<string, string> observed_metrics = 12;- Specified by:
getObservedMetricsOrThrowin interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage
-
writeTo
- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessage- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessage
-
equals
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static StoreTypes.StreamingQueryProgress parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static StoreTypes.StreamingQueryProgress parseFrom(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
- Throws:
IOException
-
parseFrom
public static StoreTypes.StreamingQueryProgress parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseDelimitedFrom
public static StoreTypes.StreamingQueryProgress parseDelimitedFrom(InputStream input) throws IOException - Throws:
IOException
-
parseDelimitedFrom
public static StoreTypes.StreamingQueryProgress parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseFrom
public static StoreTypes.StreamingQueryProgress parseFrom(com.google.protobuf.CodedInputStream input) throws IOException - Throws:
IOException
-
parseFrom
public static StoreTypes.StreamingQueryProgress parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
newBuilderForType
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
public static StoreTypes.StreamingQueryProgress.Builder newBuilder(StoreTypes.StreamingQueryProgress prototype) -
toBuilder
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessage
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-