Package org.apache.beam.sdk.io.gcp.bigtable.changestreams.model

@Internal package org.apache.beam.sdk.io.gcp.bigtable.changestreams.model

User models for the Google Cloud Bigtable change stream API.

Related Packages

Package	Description
org.apache.beam.sdk.io.gcp.bigtable.changestreams	Change stream for Google Cloud Bigtable.

Classes

Class	Description
DetectNewPartitionsState	Metadata of the progress of DetectNewPartitionsDoFn from the metadata table.
InitialPipelineState	States to initialize a pipeline outputted by InitializeDoFn.
NewPartition	Represent new partition as a result of splits and merges.
PartitionRecord	Output result of DetectNewPartitionsDoFn containing information required to stream a partition.
StreamPartitionWithWatermark