diff --git a/bench-vortex/src/data_downloads.rs b/bench-vortex/src/data_downloads.rs index 4986fb4e49..473aa38e7e 100644 --- a/bench-vortex/src/data_downloads.rs +++ b/bench-vortex/src/data_downloads.rs @@ -73,7 +73,7 @@ pub fn data_vortex_uncompressed(fname_out: &str, downloaded_data: PathBuf) -> Pa pub fn decompress_bz2(input_path: &str, output_path: &str) -> PathBuf { idempotent(output_path, |path| { - let input_file = File::open(input_path).unwrap(); + let input_file = File::open(data_path(input_path)).unwrap(); let mut decoder = BzDecoder::new(input_file); let mut buffer = Vec::new(); diff --git a/bench-vortex/src/medicare_data.rs b/bench-vortex/src/medicare_data.rs index a0bfe08cca..bdc20f59db 100644 --- a/bench-vortex/src/medicare_data.rs +++ b/bench-vortex/src/medicare_data.rs @@ -14,20 +14,16 @@ use vortex_error::VortexError; use vortex_schema::DType; use crate::data_downloads::{decompress_bz2, download_data, parquet_to_lance}; -use crate::idempotent; use crate::reader::{compress_csv_to_vortex, default_csv_format, write_csv_as_parquet}; +use crate::idempotent; -#[allow(dead_code)] pub fn medicare_data_csv() -> PathBuf { let fname = "Medicare1_1.csv.bz2"; download_data( fname, "http://www.cwi.nl/~boncz/PublicBIbenchmark/Medicare1/Medicare1_1.csv.bz2", ); - decompress_bz2( - "/Users/jcasale/fulcrum/vortex/bench-vortex/data/Medicare1_1.csv.bz2", - "Medicare1_1.csv", - ) + decompress_bz2("Medicare1_1.csv.bz2", "Medicare1_1.csv") } pub fn medicare_data_lance() -> PathBuf {