Class CloseStream (2.51.0) 

public abstract class CloseStream implements ChangeStreamRecord, Serializable

A simple wrapper for ReadChangeStreamResponse.CloseStream. This message is received when the stream reading is finished(i.e. read past the stream end time), or an error has occurred.

Inheritance

java.lang.Object > CloseStream

Static Methods

fromProto(ReadChangeStreamResponse.CloseStream closeStream)

public static CloseStream fromProto(ReadChangeStreamResponse.CloseStream closeStream)

Wraps the protobuf ReadChangeStreamResponse.CloseStream.

Parameter
Name Description
closeStream com.google.bigtable.v2.ReadChangeStreamResponse.CloseStream
Returns
Type Description
CloseStream

Constructors

CloseStream()

public CloseStream()

Methods

getChangeStreamContinuationTokens()

public abstract List<ChangeStreamContinuationToken> getChangeStreamContinuationTokens()
Returns
Type Description
List<ChangeStreamContinuationToken>

getNewPartitions()

public abstract List<Range.ByteStringRange> getNewPartitions()
Returns
Type Description
List<ByteStringRange>

getStatus()

public abstract Status getStatus()
Returns
Type Description
Status