in src/columnar_storage/src/operator.rs [31:39]
fn merge(&self, batch: RecordBatch) -> Result<RecordBatch>;
}
pub type MergeOperatorRef = Arc<dyn MergeOperator>;
#[derive(Debug)]
pub struct LastValueOperator;
impl MergeOperator for LastValueOperator {