Struct BatchMeta 

pub struct BatchMeta {
    pub oml_name: Option<String>,
}

Batch-level runtime metadata passed from engine to sink.

BatchMeta carries information that belongs to the batch/frame level (not to individual records), such as the OML output model name. Sinks decide how to consume it — e.g. TcpArrowSink uses oml_name as the Arrow frame tag in arrow_framed mode.

Fields

oml_name: Option<String>

OML output model name — identifies the logical output stream.

Implementations

impl BatchMeta

pub fn new() -> Self

pub fn with_oml_name(name: impl Into<String>) -> Self

pub fn oml_name(&self) -> Option<&str>

pub fn is_empty(&self) -> bool

Trait Implementations

impl Clone for BatchMeta

fn clone(&self) -> BatchMeta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchMeta

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

Formats the value using the given formatter.

impl Default for BatchMeta

fn default() -> BatchMeta

Returns the “default value” for a type.

impl Eq for BatchMeta

impl PartialEq for BatchMeta

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for BatchMeta