See: Description
| Class | Description |
|---|---|
| DetectNewPartitionsRangeTracker |
This restriction tracker delegates most of its behavior to an internal
TimestampRangeTracker. |
| ReadChangeStreamPartitionRangeTracker |
This restriction tracker delegates most of its behavior to an internal
TimestampRangeTracker. |
| ThroughputEstimator |
An estimator to provide an estimate on the throughput of the outputted elements.
|
| TimestampRange |
A restriction represented by a range of timestamps [from, to).
|
| TimestampRangeTracker |
A
RestrictionTracker for claiming positions in a TimestampRange in a
monotonically increasing fashion. |
| TimestampUtils |
Provides methods in order to convert timestamp to nanoseconds representation and back.
|