Class DetectNewPartitionsDoFn

java.lang.Object
org.apache.beam.sdk.transforms.DoFn<InitialPipelineState,PartitionRecord>
org.apache.beam.sdk.io.gcp.bigtable.changestreams.dofn.DetectNewPartitionsDoFn
All Implemented Interfaces:
Serializable, HasDisplayData

@Internal @UnboundedPerElement public class DetectNewPartitionsDoFn extends DoFn<InitialPipelineState,PartitionRecord>
See Also: