Skip to content

Commit f9bff57

Browse files
committed
changes required after rebase on main
1 parent 7eb7cd3 commit f9bff57

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

crates/iceberg/src/arrow/caching_delete_file_loader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ use std::collections::HashMap;
2020
use futures::channel::oneshot;
2121
use futures::future::join_all;
2222
use futures::{StreamExt, TryStreamExt};
23-
use tokio::sync::oneshot::{channel, Receiver};
23+
use tokio::sync::oneshot::{Receiver, channel};
2424

2525
use super::delete_filter::{DeleteFilter, EqDelFuture};
2626
use crate::arrow::delete_file_loader::BasicDeleteFileLoader;

crates/iceberg/src/arrow/delete_file_loader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@ use std::sync::Arc;
1919

2020
use futures::{StreamExt, TryStreamExt};
2121

22-
use crate::arrow::record_batch_transformer::RecordBatchTransformer;
2322
use crate::arrow::ArrowReader;
23+
use crate::arrow::record_batch_transformer::RecordBatchTransformer;
2424
use crate::io::FileIO;
2525
use crate::scan::{ArrowRecordBatchStream, FileScanTaskDeleteFile};
2626
use crate::spec::{Schema, SchemaRef};

crates/iceberg/src/delete_vector.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,9 @@
1717

1818
use std::ops::BitOrAssign;
1919

20+
use roaring::RoaringTreemap;
2021
use roaring::bitmap::Iter;
2122
use roaring::treemap::BitmapIter;
22-
use roaring::RoaringTreemap;
2323

2424
#[derive(Debug, Default)]
2525
pub struct DeleteVector {
@@ -63,7 +63,7 @@ impl Iterator for DeleteVectorIterator<'_> {
6363
type Item = u64;
6464

6565
fn next(&mut self) -> Option<Self::Item> {
66-
if let Some(ref mut inner) = &mut self.inner {
66+
if let Some(inner) = &mut self.inner {
6767
if let Some(inner_next) = inner.bitmap_iter.next() {
6868
return Some(u64::from(inner.high_bits) << 32 | u64::from(inner_next));
6969
}

0 commit comments

Comments
 (0)