(file_io: &FileIO, table_path: &str)
| 765 | } |
| 766 | |
| 767 | async fn setup_dirs(file_io: &FileIO, table_path: &str) { |
| 768 | file_io |
| 769 | .mkdirs(&format!("{table_path}/snapshot/")) |
| 770 | .await |
| 771 | .unwrap(); |
| 772 | file_io |
| 773 | .mkdirs(&format!("{table_path}/manifest/")) |
| 774 | .await |
| 775 | .unwrap(); |
| 776 | } |
| 777 | |
| 778 | fn make_batch(ids: Vec<i32>, values: Vec<i32>) -> RecordBatch { |
| 779 | let schema = Arc::new(ArrowSchema::new(vec![ |