Struct StreamingCheckpoint 

pub struct StreamingCheckpoint {
    pub file_path: String,
    pub line_number: usize,
    pub bytes_processed: usize,
    pub chunk_number: usize,
    pub total_chunks: Option<usize>,
    pub schema_version: String,
    pub timestamp: String,
    pub config_hash: String,
}

Checkpoint information for resuming streaming

Fields

file_path: String

File path being processed

line_number: usize

Current line number (0-based)

bytes_processed: usize

Total bytes processed so far

chunk_number: usize

Chunk number being processed

total_chunks: Option<usize>

Total chunks expected (if known)

schema_version: String

Schema version used

timestamp: String

Timestamp when checkpoint was created

config_hash: String

Configuration hash for validation

Implementations

impl StreamingCheckpoint

pub fn new( file_path: String, line_number: usize, bytes_processed: usize, chunk_number: usize, config: &BatlessConfig, ) -> Self

Create a new checkpoint

pub fn is_compatible(&self, config: &BatlessConfig) -> bool

Validate that this checkpoint is compatible with the current config

Trait Implementations

impl Clone for StreamingCheckpoint

fn clone(&self) -> StreamingCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamingCheckpoint

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamingCheckpoint

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.