Skip to content

Commit b4cf77b

Browse files
committed
better
1 parent 4f53d8d commit b4cf77b

2 files changed

Lines changed: 1 addition & 17 deletions

File tree

benchmarks/datafusion-bench/src/main.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -316,7 +316,7 @@ async fn register_v2_tables<B: Benchmark + ?Sized>(
316316
None => format!("*.{}", format.ext()),
317317
};
318318

319-
let (multi_ds, _) = MultiFileDataSource::new(SESSION.clone())
319+
let multi_ds = MultiFileDataSource::new(SESSION.clone())
320320
.with_glob(glob_pattern, Some(fs))
321321
.build()
322322
.await?;

vortex-file/src/footer/file_statistics.rs

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -146,22 +146,6 @@ impl FileStatistics {
146146
pub fn get(&self, field_idx: usize) -> (&StatsSet, &DType) {
147147
(&self.stats[field_idx], &self.dtypes[field_idx])
148148
}
149-
150-
pub fn merge(self, other: &FileStatistics) -> VortexResult<FileStatistics> {
151-
vortex_ensure_eq!(self.stats.len(), other.stats_sets().len());
152-
153-
let FileStatistics { mut stats, dtypes } = self;
154-
for (this, other_stat, dtype) in itertools::izip!(
155-
Arc::make_mut(&mut stats).iter_mut(),
156-
other.stats_sets().iter(),
157-
dtypes.iter()
158-
) {
159-
let owned = std::mem::take(this);
160-
*this = owned.merge_unordered(other_stat, dtype);
161-
}
162-
163-
Ok(FileStatistics::new(stats, dtypes))
164-
}
165149
}
166150

167151
impl<'a> IntoIterator for &'a FileStatistics {

0 commit comments

Comments
 (0)