From 6f5bd8cbdb5b40e474294c50bd9d03fca5d610ef Mon Sep 17 00:00:00 2001 From: Andrew Duffy Date: Tue, 30 Jul 2024 13:10:06 -0400 Subject: [PATCH] revert local --- bench-vortex/src/tpch/mod.rs | 33 --------------------------------- 1 file changed, 33 deletions(-) diff --git a/bench-vortex/src/tpch/mod.rs b/bench-vortex/src/tpch/mod.rs index 96bf9afb87..59c8914794 100644 --- a/bench-vortex/src/tpch/mod.rs +++ b/bench-vortex/src/tpch/mod.rs @@ -120,7 +120,6 @@ async fn register_arrow( .collect() .await?; - // Convert to StringView for all of the relevant columns let mem_table = MemTable::try_new(Arc::new(schema.clone()), vec![record_batches])?; session.register_table(name, Arc::new(mem_table))?; @@ -222,35 +221,3 @@ pub fn tpch_query(query_idx: usize) -> String { .join(format!("q{}.sql", query_idx)); fs::read_to_string(manifest_dir).unwrap() } - -#[cfg(test)] -mod test { - use crate::tpch::{load_datasets, tpch_query, Format}; - - #[tokio::test] - async fn test_schema() { - println!("TEST START"); - let session_ctx = load_datasets( - "/Volumes/Code/vortex/bench-vortex/data/tpch/1", - Format::Arrow, - ) - .await - .unwrap(); - println!("DATA LOADED"); - - // get access to session context - let logical_plan = session_ctx - .state() - .create_logical_plan(&tpch_query(7)) - .await - .unwrap(); - println!("LOGICAL PLAN: {}", logical_plan.display_indent()); - session_ctx - .sql(&tpch_query(1)) - .await - .unwrap() - .show() - .await - .unwrap(); - } -}