async fn pivot(&self) -> StringSetRef {
            let schema = Self::input_schema();

            // prepare input
            let input_batches = self
                .input_batches
                .iter()
                .map(|test_batch| {
                    let a_vec = test_batch.a.to_vec();
                    RecordBatch::try_new(
                        Arc::clone(&schema),
                        vec![
                            Arc::new(Int64Array::from(a_vec)),
                            to_string_array(test_batch.b),
                        ],
                    )
                    .expect("Creating new record batch")
                })
                .collect::<Vec<_>>();

            let pivot = make_schema_pivot(schema, input_batches);

            let results = test_execute_partition(pivot, 0).await;

            reader_to_stringset(results).await
        }
/// run the input batches through a schema pivot and return the results
/// as a StringSetRef
run the input batches through a schema pivot and return the results
as a StringSetRef
run the input batches through a schema pivot and return the results as a StringSetRef
async fn pivot(&self) -> StringSetRef {
            let schema = Self::input_schema();
            // prepare input
            let input_batches = self
                .input_batches
                .iter()
                .map(|test_batch| {
                    let a_vec = test_batch.a.to_vec();
                    RecordBatch::try_new(
                        Arc::clone(&schema),
                        vec![
                            Arc::new(Int64Array::from(a_vec)),
                            to_string_array(test_batch.b),
                        ],
                    )
                    .expect("Creating new record batch")
                })
                .collect::<Vec<_>>();
            let pivot = make_schema_pivot(schema, input_batches);
            let results = test_execute_partition(pivot, 0).await;
            reader_to_stringset(results).await
        }
async fn pivot ( & self ) -> StringSetRef { let schema = Self :: input_schema ( ) ; // prepare input let input_batches = self . input_batches . iter ( ) . map ( | test_batch | { let a_vec = test_batch . a . to_vec ( ) ; RecordBatch :: try_new ( Arc :: clone ( & schema ) , vec ! [ Arc new ( Int64Array from ( a_vec ) ) to_string_array ( test_batch b ) ] , ) . expect ( " " ) } ) . collect :: < Vec < _ > > ( ) ; let pivot = make_schema_pivot ( schema , input_batches ) ; let results = test_execute_partition ( pivot , 0 ) . await ; reader_to_stringset ( results ) . await }
run the input batches through a schema pivot and return the results
as a StringSetRef
run the input batches through a schema pivot and return the results as a StringSetRef
&self
&self