MCPcopy Create free account
hub / github.com/apache/datafusion / register_csv

Method register_csv

datafusion/core/tests/datasource/object_store_access.rs:986–995  ·  view source on GitHub ↗

Register a CSV file at the given path

(self, table_name: &str, path: &str)

Source from the content-addressed store, hash-verified

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 {

Callers 14

register_current_csvFunction · 0.45
register_aggregate_csvFunction · 0.45
nycFunction · 0.45
with_single_file_csvMethod · 0.45
with_multi_file_csvMethod · 0.45
write_csv_with_orderFunction · 0.45
write_parquet_resultsFunction · 0.45

Calls 1

newFunction · 0.85

Tested by

no test coverage detected