Package org.apache.beam.sdk.io.gcp.bigtable.changestreams.action
@Internal
package org.apache.beam.sdk.io.gcp.bigtable.changestreams.action
Business logic to process change stream for Google Cloud Bigtable.
-
ClassesClassDescriptionFactory class for creating instances that will handle different functions of DoFns.This class is responsible for processing individual ChangeStreamRecord.This class processes
DetectNewPartitionsDoFn.Class to generate first set of outputs forDetectNewPartitionsDoFn.This class is part ofReadChangeStreamPartitionDoFnSDF.