Struct BatchMeta 

pub struct BatchMeta {
    pub oml_name: Option<String>,
    pub output_disabled: Vec<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 and output metadata field policy. 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.

output_disabled: Vec<String>

Metadata payload fields disabled by the engine/group configuration.

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 with_output_disabled( fields: impl IntoIterator<Item = impl Into<String>>, ) -> Self

pub fn set_output_disabled( &mut self, fields: impl IntoIterator<Item = impl Into<String>>, )

pub fn output_disabled(&self) -> &[String]

pub fn is_output_disabled(&self, field: &str) -> bool

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