query::analyze

Function create_output_batch

Source 
fn create_output_batch(
    total_rows: usize,
    input: Arc<dyn ExecutionPlan>,
    schema: SchemaRef,
    format: AnalyzeFormat,
) -> Result<DfRecordBatch>
Expand description

Creates the output of AnalyzeExec as a RecordBatch