Struct OrderedBatchIngestMetadata 

pub struct OrderedBatchIngestMetadata {
    pub paths: Vec<PathBuf>,
    pub last_path: Option<PathBuf>,
    pub max_watermark_value: Option<Value>,
}

Metadata from ingest_from_ordered_paths: which paths were read, the last path in that sequence, and (when incremental watermark options are set) the maximum value in the watermark column after the batch filter — useful for checkpointing the next run.

Fields

paths: Vec<PathBuf>

Files ingested, in the order given.

last_path: Option<PathBuf>

Last entry in Self::paths (typical append-only batch cursor).

max_watermark_value: Option<Value>

Maximum of the watermark column over non-null cells in the output dataset, when watermark options were set; otherwise None.

Trait Implementations

impl Clone for OrderedBatchIngestMetadata

fn clone(&self) -> OrderedBatchIngestMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OrderedBatchIngestMetadata

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

Formats the value using the given formatter.

impl PartialEq for OrderedBatchIngestMetadata

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for OrderedBatchIngestMetadata