Skip to content

Commit

Permalink
chore: fix unit tests.
Browse files Browse the repository at this point in the history
  • Loading branch information
youngsofun committed Dec 19, 2023
1 parent b3badcd commit 828e7a9
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 2 deletions.
3 changes: 2 additions & 1 deletion src/query/service/tests/it/parquet_rs/prune_pages.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,12 +57,13 @@ async fn test(scenario: Scenario, predicate: &str, expected_selection: RowSelect
ParquetReadOptions::default()
.with_prune_row_groups(false)
.with_prune_pages(true),
vec![],
)
.unwrap();

let row_groups = (0..parquet_meta.num_row_groups()).collect::<Vec<_>>();
let selection = pruner
.prune_pages(parquet_meta, &row_groups)
.prune_pages(parquet_meta, &row_groups, None)
.unwrap()
.unwrap();

Expand Down
1 change: 1 addition & 0 deletions src/query/service/tests/it/parquet_rs/prune_row_groups.rs
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,7 @@ async fn test_impl(scenario: Scenario, predicate: &str, expected_rgs: Vec<usize>
ParquetReadOptions::default()
.with_prune_row_groups(prune)
.with_prune_pages(false),
vec![]
)
.unwrap();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@ fn create_table_plan(fixture: &TestFixture, format: &str) -> CreateTablePlan {
TableField::new("c", TableDataType::Number(NumberDataType::Int32)),
]),
engine: Engine::Fuse,
engine_options: Default::default(),
storage_params: None,
read_only_attach: false,
part_prefix: "".to_string(),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ async fn test_fuse_alter_table_cluster_key() -> databend_common_exception::Resul
table: fixture.default_table_name(),
schema: TestFixture::default_table_schema(),
engine: Engine::Fuse,
engine_options: Default::default(),
storage_params: None,
read_only_attach: false,
part_prefix: "".to_string(),
Expand Down
1 change: 1 addition & 0 deletions src/query/service/tests/it/storages/fuse/pruning.rs
Original file line number Diff line number Diff line change
Expand Up @@ -94,6 +94,7 @@ async fn test_block_pruner() -> Result<()> {
table: test_tbl_name.to_string(),
schema: test_schema.clone(),
engine: Engine::Fuse,
engine_options: Default::default(),
storage_params: None,
read_only_attach: false,
part_prefix: "".to_string(),
Expand Down
1 change: 0 additions & 1 deletion src/query/storages/delta/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@ publish = false
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
databend-common-arrow = { path = "../../../common/arrow" }
databend-common-base = { path = "../../../common/base" }
databend-common-catalog = { path = "../../catalog" }
databend-common-exception = { path = "../../../common/exception" }
Expand Down

0 comments on commit 828e7a9

Please sign in to comment.