Method make_record_batch

benchmarks/src/dict.rs:386–421

(&self, query: &DictionaryQuery)

    }

    fn make_record_batch(&self, query: &DictionaryQuery) -> Result<RecordBatch> {
        let size = self.num_rows;

        let col1 = generate_dict(
            query.col.value_type,
            query.col.cardinality,
            query.col.null_percent,
            size,
        );

        let (schema, columns): (Schema, Vec<ArrayRef>) = match &query.col2 {
            None => {
                let schema = Schema::new(vec![Field::new(
                    "dict_col",
                    col1.data_type().clone(),
                    true,
                )]);
                (schema, vec![col1])
            }
            Some(col2_params) => {
                let col2 = generate_dict(
                    col2_params.value_type,
                    col2_params.cardinality,
                    col2_params.null_percent,
                    size,
                );
                let schema = Schema::new(vec![
                    Field::new("dict_col", col1.data_type().clone(), true),
                    Field::new("dict_col2", col2.data_type().clone(), true),
                ]);
                (schema, vec![col1, col2])
            }
        };

        Ok(RecordBatch::try_new(Arc::new(schema), columns)?)
    }

    async fn execute_query_without_result_buffering(
        sql: &str,