()
| 63 | use zstd::Encoder as ZstdEncoder; |
| 64 | |
| 65 | pub fn create_table_dual() -> Arc<dyn TableProvider> { |
| 66 | let dual_schema = Arc::new(Schema::new(vec![ |
| 67 | Field::new("id", DataType::Int32, false), |
| 68 | Field::new("name", DataType::Utf8, false), |
| 69 | ])); |
| 70 | let batch = RecordBatch::try_new( |
| 71 | Arc::<Schema>::clone(&dual_schema), |
| 72 | vec![ |
| 73 | Arc::new(Int32Array::from(vec![1])), |
| 74 | Arc::new(array::StringArray::from(vec!["a"])), |
| 75 | ], |
| 76 | ) |
| 77 | .unwrap(); |
| 78 | let provider = MemTable::try_new(dual_schema, vec![vec![batch]]).unwrap(); |
| 79 | Arc::new(provider) |
| 80 | } |
| 81 | |
| 82 | /// Returns a [`DataSourceExec`] that scans "aggregate_test_100.csv" with `partitions` partitions |
| 83 | pub fn scan_partitioned_csv( |
no test coverage detected
searching dependent graphs…