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 |