See: Description
| Class | Description |
|---|---|
| DetectNewPartitionsRangeTracker |
This restriction tracker delegates most of its behavior to an internal
TimestampRangeTracker. |
| PartitionPosition |
Represents the current position of the running SDF within PartitionRestriction.
|
| PartitionRestriction |
Represents the restriction for PartitionRestrictionTracker.
|
| PartitionRestrictionClaimer |
The PartitionRestrictionClaimer class.
|
| PartitionRestrictionMetadata |
The PartitionRestrictionMetadata class.
|
| PartitionRestrictionMetadata.Builder | |
| PartitionRestrictionProgressChecker | |
| PartitionRestrictionSplitter |
The PartitionRestrictionSplitter class.
|
| PartitionRestrictionTracker | |
| 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.
|
| Enum | Description |
|---|---|
| PartitionMode |
This enum contains the states that PartitionRestrictionTracker will go through.
|