Struct UnalignedCheckpointer 

pub struct UnalignedCheckpointer<T> { /* private fields */ }

State machine for unaligned checkpoints with timeout-based fallback.

Manages the transition between aligned and unaligned checkpoint modes for a single operator with multiple inputs.

Type Parameter

T is the event type flowing through the operator (e.g., RecordBatch).

Implementations

impl<T> UnalignedCheckpointer<T>

pub fn new( num_inputs: usize, config: UnalignedCheckpointConfig, is_sink: bool, ) -> Self

Creates a new unaligned checkpointer.

Arguments

• num_inputs — Number of input channels
• config — Unaligned checkpoint configuration
• is_sink — Whether this operator is a sink (disables unaligned mode)

pub fn aligned_count(&self) -> usize

Returns the current number of aligned inputs (for testing/observability).

pub fn is_checkpointing(&self) -> bool

Returns whether a checkpoint is in progress.

pub fn buffered_bytes(&self) -> usize

Returns the total buffered in-flight bytes.

pub fn on_barrier( &mut self, input_id: usize, barrier: CheckpointBarrier, ) -> UnalignedAction<T>

where T: Debug,

Processes a barrier arriving from the given input.

Returns the action to take. The caller must handle the action (e.g., take a snapshot, forward events, etc.).

pub fn check_timeout(&mut self) -> Option<UnalignedAction<T>>

where T: Debug,

Checks whether the alignment timeout has expired.

Call this periodically (e.g., on each event poll) to detect timeout. Returns Some(UnalignedSnapshot) if timeout triggered.

pub fn buffer_event( &mut self, input_id: usize, event: T, size_bytes: usize, ) -> bool

Buffers an event from the given input during alignment.

Returns false if the buffer size would exceed the configured limit (event is NOT buffered). Returns true on success.

Trait Implementations

impl<T: Debug> Debug for UnalignedCheckpointer<T>

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

Formats the value using the given formatter.