fn make_schema_pivot(
        input_schema: SchemaRef,
        data: Vec<RecordBatch>,
    ) -> Arc<dyn ExecutionPlan> {
        let input = make_memory_exec(input_schema, data);
        let output_schema = Arc::new(make_schema_pivot_output_schema().as_ref().clone().into());
        Arc::new(SchemaPivotExec::new(input, output_schema))
    }
/// Create a schema pivot node with a single input
Create a schema pivot node with a single input
Create a schema pivot node with a single input
fn make_schema_pivot(
        input_schema: SchemaRef,
        data: Vec<RecordBatch>,
    ) -> Arc<dyn ExecutionPlan> {
        let input = make_memory_exec(input_schema, data);
        let output_schema = Arc::new(make_schema_pivot_output_schema().as_ref().clone().into());
        Arc::new(SchemaPivotExec::new(input, output_schema))
    }
fn make_schema_pivot ( input_schema : SchemaRef , data : Vec < RecordBatch > , ) -> Arc < dyn ExecutionPlan > { let input = make_memory_exec ( input_schema , data ) ; let output_schema = Arc :: new ( make_schema_pivot_output_schema ( ) . as_ref ( ) . clone ( ) . into ( ) ) ; Arc :: new ( SchemaPivotExec :: new ( input , output_schema ) ) }
Create a schema pivot node with a single input
Create a schema pivot node with a single input
input_schema
SchemaRef
data
Vec<RecordBatch>
input_schema
SchemaRef
data
Vec<RecordBatch>