Enum CheckpointWatermark 

pub enum CheckpointWatermark {
    Uninitialized,
    Idle,
    Active(i64),
}

One participant’s event-time position at a checkpoint cut.

An uninitialized participant must block watermark advancement. An explicitly idle participant has no input that can currently hold back the cut and is excluded from the active minimum.

Variants

Uninitialized

At least one required input has not established an event-time frontier.

Idle

Every required input is explicitly idle.

Active(i64)

Minimum active input watermark for this participant.

Implementations

impl CheckpointWatermark

pub const fn cluster_min(self, other: Self) -> Self

Fold two required participants into a safe cluster watermark state.

pub const fn active_value(self) -> Option<i64>

Active watermark value, if this participant has active inputs.

pub fn validate(self) -> Result<(), String>

Reject the reserved uninitialized sentinel as an active watermark.

Errors

Returns an error when an active watermark uses the reserved sentinel.

Trait Implementations

impl Clone for CheckpointWatermark

fn clone(&self) -> CheckpointWatermark

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for CheckpointWatermark

impl Debug for CheckpointWatermark

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for CheckpointWatermark

fn default() -> CheckpointWatermark

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for CheckpointWatermark

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for CheckpointWatermark

impl PartialEq for CheckpointWatermark

fn eq(&self, other: &CheckpointWatermark) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for CheckpointWatermark

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for CheckpointWatermark