Package org.apache.beam.sdk.io.gcp.spanner.changestreams.model
package org.apache.beam.sdk.io.gcp.spanner.changestreams.model
User models for the Spanner change stream API.
-
ClassDescriptionRepresents a Spanner Change Stream Record.Holds internal execution metrics / metadata for the processed
ChangeStreamRecord.A child partition represents a new partition that should be queried.Represents a ChildPartitionsRecord.Defines a column type from a Cloud Spanner table with the following information: column name, column type, flag indicating if column is primary key and column position in the table.A data change record encodes modifications to Cloud Spanner rows.A heartbeat record serves as a notification that the change stream query has returned all changes for the partition less or equal to the record timestamp.Utility class to determine initial partition constants and methods.Represents a modification in a table emitted within aDataChangeRecord.Represents the type of modification applied in theDataChangeRecord.A partition end record serves as a notification that the client should stop reading the partition.A partition event record describes key range changes for a change stream partition.Model for the partition metadata database table used in the Connector.Partition metadata builder for better user experience.The state at which a partition can be in the system: CREATED: the partition has been created, but no query has been done against it yet.A partition start record serves as a notification that the client should schedule the partitions to be queried.Represents a type of a column within Cloud Spanner.Represents the capture type of a change stream.