pub trait DfRecordBatchEncoder { // Required method fn write(&mut self, batch: &RecordBatch) -> Result<()>; }