Struct LogEntriesRecordBuilder 

pub struct LogEntriesRecordBuilder { /* private fields */ }

A builder for creating a RecordBatch of log entries.

Implementations

impl LogEntriesRecordBuilder

pub fn with_capacity(capacity: usize) -> LogEntriesRecordBuilder

pub fn get_time_range(&self) -> Option<TimeRange>

pub fn len(&self) -> i64

pub fn is_empty(&self) -> bool

pub fn append(&mut self, row: &LogEntry<'_>) -> Result<(), Error>

pub fn append_entry_only(&mut self, row: &LogEntry<'_>) -> Result<(), Error>

Append only per-entry variable data (optimized for batch processing)

pub fn fill_constant_columns( &mut self, process: &ProcessMetadata, stream_id: &str, block_id: &str, insert_time: i64, entry_count: usize, ) -> Result<(), Error>

Batch fill all constant columns for all entries in block

pub fn finish(self) -> Result<RecordBatch, Error>