See: Description
| 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 |