See: Description
| Class | Description |
|---|---|
| ActionFactory |
Factory class for creating instances that will handle different functions of DoFns.
|
| ChangeStreamAction |
This class is responsible for processing individual ChangeStreamRecord.
|
| DetectNewPartitionsAction |
This class processes
DetectNewPartitionsDoFn. |
| GenerateInitialPartitionsAction |
Class to generate first set of outputs for
DetectNewPartitionsDoFn. |
| ProcessNewPartitionsAction | |
| ReadChangeStreamPartitionAction |
This class is part of
ReadChangeStreamPartitionDoFn SDF. |
| ResumeFromPreviousPipelineAction |