Package org.apache.spark.status.protobuf
Class StoreTypes.StreamingQueryProgress
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
,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:
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic final class
Protobuf typeorg.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 -
Field Summary
Modifier and TypeFieldDescriptionstatic final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
static final int
-
Method Summary
Modifier and TypeMethodDescriptionboolean
containsDurationMs
(String key) map<string, int64> duration_ms = 7;
boolean
containsEventTime
(String key) map<string, string> event_time = 8;
boolean
map<string, string> observed_metrics = 12;
boolean
long
int64 batch_duration = 6;
long
int64 batch_id = 5;
static final com.google.protobuf.Descriptors.Descriptor
Deprecated.int
map<string, int64> duration_ms = 7;
map<string, int64> duration_ms = 7;
long
getDurationMsOrDefault
(String key, long defaultValue) map<string, int64> duration_ms = 7;
long
map<string, int64> duration_ms = 7;
Deprecated.int
map<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.ByteString
optional string id = 1;
getName()
optional string name = 3;
com.google.protobuf.ByteString
optional string name = 3;
Deprecated.int
map<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.ByteString
optional string run_id = 2;
int
getSink()
.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;
int
repeated .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;
int
repeated .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.ByteString
optional string timestamp = 4;
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
optional string timestamp = 4;
final boolean
newBuilder
(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()
void
writeTo
(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessageV3
getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, 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 interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeTo
Methods 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:
hasId
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- Whether the id field is set.
-
getId
optional string id = 1;
- Specified by:
getId
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The id.
-
getIdBytes
public com.google.protobuf.ByteString getIdBytes()optional string id = 1;
- Specified by:
getIdBytes
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The bytes for id.
-
hasRunId
public boolean hasRunId()optional string run_id = 2;
- Specified by:
hasRunId
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- Whether the runId field is set.
-
getRunId
optional string run_id = 2;
- Specified by:
getRunId
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The runId.
-
getRunIdBytes
public com.google.protobuf.ByteString getRunIdBytes()optional string run_id = 2;
- Specified by:
getRunIdBytes
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The bytes for runId.
-
hasName
public boolean hasName()optional string name = 3;
- Specified by:
hasName
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- Whether the name field is set.
-
getName
optional string name = 3;
- Specified by:
getName
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The name.
-
getNameBytes
public com.google.protobuf.ByteString getNameBytes()optional string name = 3;
- Specified by:
getNameBytes
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The bytes for name.
-
hasTimestamp
public boolean hasTimestamp()optional string timestamp = 4;
- Specified by:
hasTimestamp
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- Whether the timestamp field is set.
-
getTimestamp
optional string timestamp = 4;
- Specified by:
getTimestamp
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The timestamp.
-
getTimestampBytes
public com.google.protobuf.ByteString getTimestampBytes()optional string timestamp = 4;
- Specified by:
getTimestampBytes
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The bytes for timestamp.
-
getBatchId
public long getBatchId()int64 batch_id = 5;
- Specified by:
getBatchId
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The batchId.
-
getBatchDuration
public long getBatchDuration()int64 batch_duration = 6;
- Specified by:
getBatchDuration
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The batchDuration.
-
getDurationMsCount
public int getDurationMsCount()Description copied from interface:StoreTypes.StreamingQueryProgressOrBuilder
map<string, int64> duration_ms = 7;
- Specified by:
getDurationMsCount
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
containsDurationMs
map<string, int64> duration_ms = 7;
- Specified by:
containsDurationMs
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMs
Deprecated.UsegetDurationMsMap()
instead.- Specified by:
getDurationMs
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMsMap
map<string, int64> duration_ms = 7;
- Specified by:
getDurationMsMap
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMsOrDefault
map<string, int64> duration_ms = 7;
- Specified by:
getDurationMsOrDefault
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getDurationMsOrThrow
map<string, int64> duration_ms = 7;
- Specified by:
getDurationMsOrThrow
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeCount
public int getEventTimeCount()Description copied from interface:StoreTypes.StreamingQueryProgressOrBuilder
map<string, string> event_time = 8;
- Specified by:
getEventTimeCount
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
containsEventTime
map<string, string> event_time = 8;
- Specified by:
containsEventTime
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTime
Deprecated.UsegetEventTimeMap()
instead.- Specified by:
getEventTime
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeMap
map<string, string> event_time = 8;
- Specified by:
getEventTimeMap
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeOrDefault
map<string, string> event_time = 8;
- Specified by:
getEventTimeOrDefault
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getEventTimeOrThrow
map<string, string> event_time = 8;
- Specified by:
getEventTimeOrThrow
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsList
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
- Specified by:
getStateOperatorsList
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsOrBuilderList
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
- Specified by:
getStateOperatorsOrBuilderList
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsCount
public int getStateOperatorsCount()repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
- Specified by:
getStateOperatorsCount
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperators
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
- Specified by:
getStateOperators
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getStateOperatorsOrBuilder
repeated .org.apache.spark.status.protobuf.StateOperatorProgress state_operators = 9;
- Specified by:
getStateOperatorsOrBuilder
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesList
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
- Specified by:
getSourcesList
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesOrBuilderList
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
- Specified by:
getSourcesOrBuilderList
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesCount
public int getSourcesCount()repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
- Specified by:
getSourcesCount
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSources
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
- Specified by:
getSources
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getSourcesOrBuilder
repeated .org.apache.spark.status.protobuf.SourceProgress sources = 10;
- Specified by:
getSourcesOrBuilder
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
hasSink
public boolean hasSink().org.apache.spark.status.protobuf.SinkProgress sink = 11;
- Specified by:
hasSink
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- Whether the sink field is set.
-
getSink
.org.apache.spark.status.protobuf.SinkProgress sink = 11;
- Specified by:
getSink
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
- Returns:
- The sink.
-
getSinkOrBuilder
.org.apache.spark.status.protobuf.SinkProgress sink = 11;
- Specified by:
getSinkOrBuilder
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsCount
public int getObservedMetricsCount()Description copied from interface:StoreTypes.StreamingQueryProgressOrBuilder
map<string, string> observed_metrics = 12;
- Specified by:
getObservedMetricsCount
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
containsObservedMetrics
map<string, string> observed_metrics = 12;
- Specified by:
containsObservedMetrics
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetrics
Deprecated.UsegetObservedMetricsMap()
instead.- Specified by:
getObservedMetrics
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsMap
map<string, string> observed_metrics = 12;
- Specified by:
getObservedMetricsMap
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsOrDefault
map<string, string> observed_metrics = 12;
- Specified by:
getObservedMetricsOrDefault
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
getObservedMetricsOrThrow
map<string, string> observed_metrics = 12;
- Specified by:
getObservedMetricsOrThrow
in interfaceStoreTypes.StreamingQueryProgressOrBuilder
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in 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:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
public static StoreTypes.StreamingQueryProgress.Builder newBuilder(StoreTypes.StreamingQueryProgress prototype) -
toBuilder
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-