pub fn classify_channel_progress(
channels: &[ChannelProgress],
) -> Result<CheckpointWatermark, String>Expand description
Reconstruct the event-time state represented by an exact channel cut.
ยงErrors
Returns an error when a channel uses the reserved uninitialized watermark value.