Struct BatchPolicy 

pub struct BatchPolicy {
    pub max_rows: usize,
    pub max_latency: Duration,
    pub flush_on_watermark: bool,
}

Controls when the bridge consumer flushes accumulated rows into a RecordBatch.

The consumer flushes when any of these conditions is met:

• The row count reaches max_rows.
• The time since the first row exceeds max_latency.
• A watermark message arrives and flush_on_watermark is true.
• A checkpoint barrier arrives (always flushes).
• An EOF message arrives (always flushes).

Fields

max_rows: usize

Maximum number of rows before a flush.

max_latency: Duration

Maximum time a row may wait before flushing.

flush_on_watermark: bool

Whether a watermark advance triggers a flush of pending rows.

When true (the default), rows accumulated before a watermark are flushed as a batch before the watermark is forwarded to Ring 1. This prevents partial-batch emissions tied to arbitrary batch boundaries (Issue #55).

Implementations

impl BatchPolicy

pub const fn with_max_rows(self, max_rows: usize) -> Self

Sets the maximum row count before a flush.

pub const fn with_max_latency(self, max_latency: Duration) -> Self

Sets the maximum latency before a flush.

pub const fn with_flush_on_watermark(self, flush_on_watermark: bool) -> Self

Sets whether watermark advances flush pending rows.

Trait Implementations

impl Clone for BatchPolicy

fn clone(&self) -> BatchPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchPolicy

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

Formats the value using the given formatter.

impl Default for BatchPolicy

fn default() -> Self

Returns the “default value” for a type.