Skip to content

Commit

Permalink
fix clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
jiacai2050 committed Dec 26, 2024
1 parent dd089bd commit 9817e45
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
3 changes: 1 addition & 2 deletions src/metric_engine/src/read.rs
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,6 @@ use datafusion::{
use futures::{Stream, StreamExt};
use itertools::Itertools;
use parquet::arrow::async_reader::ParquetObjectReader;
use tracing::debug;

use crate::{
compare_primitive_columns,
Expand Down Expand Up @@ -250,11 +249,11 @@ impl MergeStream {
}

fn maybe_remove_builtin_columns(&self, batch: &mut RecordBatch) {
debug!(batch = ?batch, keep=self.keep_builtin, "maybe_remove_builtin_columns");
if self.keep_builtin {
return;
}

// builtin columns are always at the end.
for _ in 0..BUILTIN_COLUMN_NUM {
batch.remove_column(batch.num_columns() - 1);
}
Expand Down
2 changes: 1 addition & 1 deletion src/metric_engine/src/types.rs
Original file line number Diff line number Diff line change
Expand Up @@ -288,7 +288,7 @@ mod tests {
.unwrap();
assert_eq!(new_batch, expected_batch);

let mut testcases = vec![
let mut testcases = [
(None, None),
(Some(vec![]), Some(vec![0, 1, 3, 4])),
(Some(vec![1]), Some(vec![1, 0, 3, 4])),
Expand Down

0 comments on commit 9817e45

Please sign in to comment.