Get the schema for the aggregate_test_* csv files
()
| 89 | |
| 90 | /// Get the schema for the aggregate_test_* csv files |
| 91 | pub fn aggr_test_schema() -> SchemaRef { |
| 92 | let mut f1 = Field::new("c1", DataType::Utf8, false); |
| 93 | f1.set_metadata(HashMap::from_iter(vec![("testing".into(), "test".into())])); |
| 94 | let schema = Schema::new(vec![ |
| 95 | f1, |
| 96 | Field::new("c2", DataType::UInt32, false), |
| 97 | Field::new("c3", DataType::Int8, false), |
| 98 | Field::new("c4", DataType::Int16, false), |
| 99 | Field::new("c5", DataType::Int32, false), |
| 100 | Field::new("c6", DataType::Int64, false), |
| 101 | Field::new("c7", DataType::UInt8, false), |
| 102 | Field::new("c8", DataType::UInt16, false), |
| 103 | Field::new("c9", DataType::UInt32, false), |
| 104 | Field::new("c10", DataType::UInt64, false), |
| 105 | Field::new("c11", DataType::Float32, false), |
| 106 | Field::new("c12", DataType::Float64, false), |
| 107 | Field::new("c13", DataType::Utf8, false), |
| 108 | ]); |
| 109 | |
| 110 | Arc::new(schema) |
| 111 | } |
| 112 | |
| 113 | /// Register session context for the aggregate_test_100.csv file |
| 114 | pub async fn register_aggregate_csv( |
searching dependent graphs…