Skip to content

Commit

Permalink
revert local
Browse files Browse the repository at this point in the history
  • Loading branch information
a10y committed Jul 30, 2024
1 parent 720fb39 commit 6f5bd8c
Showing 1 changed file with 0 additions and 33 deletions.
33 changes: 0 additions & 33 deletions bench-vortex/src/tpch/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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))?;

Expand Down Expand Up @@ -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();
}
}

0 comments on commit 6f5bd8c

Please sign in to comment.