class Google::Apis::SpannerV1::PartitionEventRecord
destination partitions that they can continue processing.
event describes move-outs, the reader can notify the readers of the
commit_timestamp, before advancing beyond this PartitionEventRecord. If the
have processed all records with timestamps <= this PartitionEventRecord.
of this partition needs to wait until the readers of the source partitions
processing for each primary key, if the event describes move-ins, the reader
key is not needed, this event can be ignored. To guarantee time ordered
key in timestamp order. If time ordered processing of changes for a primary
event is needed if users want to guarantee processing of the changes for any
such as Spanner’s dynamic splitting and load balancing, etc. Processing this
of key ranges across change stream partitions is a reflection of activities,
a different change stream partition for a different time range. This movement
one change stream partition for a specific time range, and then be captured in
partition. The changes to a row defined by its primary key can be captured in
A partition event record describes key range changes for a change stream
def initialize(**args)
def initialize(**args) update!(**args) end
def update!(**args)
def update!(**args) @commit_timestamp = args[:commit_timestamp] if args.key?(:commit_timestamp) @move_in_events = args[:move_in_events] if args.key?(:move_in_events) @move_out_events = args[:move_out_events] if args.key?(:move_out_events) @partition_token = args[:partition_token] if args.key?(:partition_token) @record_sequence = args[:record_sequence] if args.key?(:record_sequence) end