Method execute

datafusion/physical-plan/src/test.rs:155–161

(
        &self,
        partition: usize,
        context: Arc<TaskContext>,
    )

    }

    fn execute(
        &self,
        partition: usize,
        context: Arc<TaskContext>,
    ) -> Result<SendableRecordBatchStream> {
        self.open(partition, context)
    }

    fn metrics(&self) -> Option<MetricsSet> {
        unimplemented!()