fn execute()

in src/columnar_storage/src/read.rs [178:193]

• 15 lines of code
• 2 McCabe index (conditional complexity)

    fn execute(
        &self,
        partition: usize,
        context: Arc<TaskContext>,
    ) -> DfResult<SendableRecordBatchStream> {
        if 0 != partition {
            return internal_err!("MergeExec invalid partition {partition}");
        }

        Ok(Box::pin(MergeStream::new(
            self.input.execute(partition, context)?,
            self.num_primary_keys,
            self.value_operator.clone(),
            self.keep_builtin,
        )))
    }