Skip to content

Commit 21dfaa0

Browse files
committed
fix
Signed-off-by: Joe Isaacs <joe.isaacs@live.co.uk>
1 parent 53c067b commit 21dfaa0

File tree

1 file changed

+15
-3
lines changed

1 file changed

+15
-3
lines changed

vortex-bench/src/bin/data-gen.rs

Lines changed: 15 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,23 +67,35 @@ async fn main() -> anyhow::Result<()> {
6767
let parquet_dir = base_path.join(Format::Parquet.name());
6868
idempotent_dir_async(&parquet_dir, || benchmark.generate_base_data()).await?;
6969

70-
if args.formats.iter().any(|f| matches!(f, Format::OnDiskVortex)) {
70+
if args
71+
.formats
72+
.iter()
73+
.any(|f| matches!(f, Format::OnDiskVortex))
74+
{
7175
let vortex_dir = base_path.join(Format::OnDiskVortex.name());
7276
idempotent_dir_async(&vortex_dir, || {
7377
convert_parquet_directory_to_vortex(&base_path, CompactionStrategy::Default)
7478
})
7579
.await?;
7680
}
7781

78-
if args.formats.iter().any(|f| matches!(f, Format::VortexCompact)) {
82+
if args
83+
.formats
84+
.iter()
85+
.any(|f| matches!(f, Format::VortexCompact))
86+
{
7987
let compact_dir = base_path.join(Format::VortexCompact.name());
8088
idempotent_dir_async(&compact_dir, || {
8189
convert_parquet_directory_to_vortex(&base_path, CompactionStrategy::Compact)
8290
})
8391
.await?;
8492
}
8593

86-
if args.formats.iter().any(|f| matches!(f, Format::OnDiskDuckDB)) {
94+
if args
95+
.formats
96+
.iter()
97+
.any(|f| matches!(f, Format::OnDiskDuckDB))
98+
{
8799
let duckdb_dir = base_path.join(Format::OnDiskDuckDB.name());
88100
idempotent_dir(&duckdb_dir, || generate_duckdb(&base_path, &*benchmark))?;
89101
}

0 commit comments

Comments
 (0)