Package com.google.bigtable.v2

Class ReadChangeStreamResponse.Heartbeat

    • Field Detail

      • CONTINUATION_TOKEN_FIELD_NUMBER

        public static final int CONTINUATION_TOKEN_FIELD_NUMBER
        See Also:
        Constant Field Values

      • ESTIMATED_LOW_WATERMARK_FIELD_NUMBER

        public static final int ESTIMATED_LOW_WATERMARK_FIELD_NUMBER
        See Also:
        Constant Field Values

    • Method Detail

      • newInstance

        protected Object newInstance​(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
        Overrides:
        newInstance in class com.google.protobuf.GeneratedMessageV3

      • getDescriptor

        public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3

      • hasContinuationToken

        public boolean hasContinuationToken()
         A token that can be provided to a subsequent `ReadChangeStream` call
 to pick up reading at the current stream position.
        .google.bigtable.v2.StreamContinuationToken continuation_token = 1;
        Specified by:
        hasContinuationToken in interface ReadChangeStreamResponse.HeartbeatOrBuilder
        Returns:
        Whether the continuationToken field is set.

      • hasEstimatedLowWatermark

        public boolean hasEstimatedLowWatermark()
         An estimate of the commit timestamp that is usually lower than or equal
 to any timestamp for a record that will be delivered in the future on the
 stream. It is possible that, under particular circumstances that a future
 record has a timestamp is is lower than a previously seen timestamp. For
 an example usage see
 https://beam.apache.org/documentation/basics/#watermarks
        .google.protobuf.Timestamp estimated_low_watermark = 2;
        Specified by:
        hasEstimatedLowWatermark in interface ReadChangeStreamResponse.HeartbeatOrBuilder
        Returns:
        Whether the estimatedLowWatermark field is set.

      • getEstimatedLowWatermark

        public com.google.protobuf.Timestamp getEstimatedLowWatermark()
         An estimate of the commit timestamp that is usually lower than or equal
 to any timestamp for a record that will be delivered in the future on the
 stream. It is possible that, under particular circumstances that a future
 record has a timestamp is is lower than a previously seen timestamp. For
 an example usage see
 https://beam.apache.org/documentation/basics/#watermarks
        .google.protobuf.Timestamp estimated_low_watermark = 2;
        Specified by:
        getEstimatedLowWatermark in interface ReadChangeStreamResponse.HeartbeatOrBuilder
        Returns:
        The estimatedLowWatermark.

      • getEstimatedLowWatermarkOrBuilder

        public com.google.protobuf.TimestampOrBuilder getEstimatedLowWatermarkOrBuilder()
         An estimate of the commit timestamp that is usually lower than or equal
 to any timestamp for a record that will be delivered in the future on the
 stream. It is possible that, under particular circumstances that a future
 record has a timestamp is is lower than a previously seen timestamp. For
 an example usage see
 https://beam.apache.org/documentation/basics/#watermarks
        .google.protobuf.Timestamp estimated_low_watermark = 2;
        Specified by:
        getEstimatedLowWatermarkOrBuilder in interface ReadChangeStreamResponse.HeartbeatOrBuilder

      • isInitialized

        public final boolean isInitialized()
        Specified by:
        isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
        Overrides:
        isInitialized in class com.google.protobuf.GeneratedMessageV3

      • writeTo

        public void writeTo​(com.google.protobuf.CodedOutputStream output)
             throws IOException
        Specified by:
        writeTo in interface com.google.protobuf.MessageLite
        Overrides:
        writeTo in class com.google.protobuf.GeneratedMessageV3
        Throws:
        IOException

      • getSerializedSize

        public int getSerializedSize()
        Specified by:
        getSerializedSize in interface com.google.protobuf.MessageLite
        Overrides:
        getSerializedSize in class com.google.protobuf.GeneratedMessageV3

      • equals

        public boolean equals​(Object obj)
        Specified by:
        equals in interface com.google.protobuf.Message
        Overrides:
        equals in class com.google.protobuf.AbstractMessage

      • hashCode

        public int hashCode()
        Specified by:
        hashCode in interface com.google.protobuf.Message
        Overrides:
        hashCode in class com.google.protobuf.AbstractMessage

      • parseFrom

        public static ReadChangeStreamResponse.Heartbeat parseFrom​(ByteBuffer data,
                                                           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static ReadChangeStreamResponse.Heartbeat parseFrom​(com.google.protobuf.ByteString data)
                                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static ReadChangeStreamResponse.Heartbeat parseFrom​(com.google.protobuf.ByteString data,
                                                           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static ReadChangeStreamResponse.Heartbeat parseFrom​(byte[] data)
                                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static ReadChangeStreamResponse.Heartbeat parseFrom​(byte[] data,
                                                           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • newBuilderForType

        public ReadChangeStreamResponse.Heartbeat.Builder newBuilderForType()
        Specified by:
        newBuilderForType in interface com.google.protobuf.Message
        Specified by:
        newBuilderForType in interface com.google.protobuf.MessageLite

      • toBuilder

        public ReadChangeStreamResponse.Heartbeat.Builder toBuilder()
        Specified by:
        toBuilder in interface com.google.protobuf.Message
        Specified by:
        toBuilder in interface com.google.protobuf.MessageLite

      • newBuilderForType

        protected ReadChangeStreamResponse.Heartbeat.Builder newBuilderForType​(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
        Specified by:
        newBuilderForType in class com.google.protobuf.GeneratedMessageV3

      • getParserForType

        public com.google.protobuf.Parser<ReadChangeStreamResponse.Heartbeat> getParserForType()
        Specified by:
        getParserForType in interface com.google.protobuf.Message
        Specified by:
        getParserForType in interface com.google.protobuf.MessageLite
        Overrides:
        getParserForType in class com.google.protobuf.GeneratedMessageV3

      • getDefaultInstanceForType

        public ReadChangeStreamResponse.Heartbeat getDefaultInstanceForType()
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder