Struct SealedBatch 

pub struct SealedBatch {
    pub frames: Vec<Bytes>,
    pub rows: u64,
    pub bytes: u64,
    pub dedup_token: String,
}

A batch sealed by a shard worker, ready to write. Frames concatenate to the full wire payload (a stream of one or more self-describing blocks for block formats like ClickHouse Native).

Fields

frames: Vec<Bytes>

Encoded frames, in order.

rows: u64

Total rows across frames.

bytes: u64

Total bytes across frames.

dedup_token: String

Deterministic-within-a-session batch identity. Retries of the same sealed batch — including on other replicas — reuse the same token, so sinks with server-side deduplication windows treat them as idempotent. Crash replay produces different tokens (documented at-least-once semantics).

Trait Implementations

impl Debug for SealedBatch

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

Formats the value using the given formatter.