Expand description
Scheduled-delivery visibility kernels.
Functionsยง
- coalesce_
delivery_ range - Decide whether the next inclusive range touches the preceding range and return the maximum end offset for a merged range.
- delivery_
watermark_ advance - Bound one scheduled-delivery watermark step to the live log range.
- scheduled_
delivery_ visible - Decide whether a record batch may be exposed at the supplied clock reading.