Function datafusion::physical_plan::execute_stream_partitioned

source · 
pub fn execute_stream_partitioned(
    plan: Arc<dyn ExecutionPlan>,
    context: Arc<TaskContext>,
) -> Result<Vec<Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>>, DataFusionError>
Expand description

Execute the ExecutionPlan and return a vec with one stream per output partition

§Aborting Execution

Dropping the stream will abort the execution of the query, and free up any allocated resources