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

Function copy_to_object_store_table_s3

datafusion-cli/src/exec.rs:642–653  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

640
641 #[tokio::test]
642 async fn copy_to_object_store_table_s3() -> Result<()> {
643 let access_key_id = "fake_access_key_id";
644 let secret_access_key = "fake_secret_access_key";
645 let location = "s3://bucket/path/file.parquet";
646
647 // Missing region, use object_store defaults
648 let sql = format!("COPY (values (1,2)) TO '{location}' STORED AS PARQUET
649 OPTIONS ('aws.access_key_id' '{access_key_id}', 'aws.secret_access_key' '{secret_access_key}')");
650 copy_to_table_test(location, &sql).await?;
651
652 Ok(())
653 }
654
655 #[tokio::test]
656 async fn create_object_store_table_s3() -> Result<()> {

Callers

nothing calls this directly

Calls 1

copy_to_table_testFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…