Register a CSV file at the given path
(self, table_name: &str, path: &str)
| 984 | |
| 985 | /// Register a CSV file at the given path |
| 986 | async fn register_csv(self, table_name: &str, path: &str) -> Self { |
| 987 | let mut options = CsvReadOptions::new(); |
| 988 | options.has_header = true; |
| 989 | let url = format!("mem://{path}"); |
| 990 | self.session_context |
| 991 | .register_csv(table_name, url, options) |
| 992 | .await |
| 993 | .unwrap(); |
| 994 | self |
| 995 | } |
| 996 | |
| 997 | /// Register a partitioned CSV table at the given path |
| 998 | async fn register_partitioned_csv(self, table_name: &str, path: &str) -> Self { |
no test coverage detected