diff --git a/vortex-file/src/v2/file.rs b/vortex-file/src/v2/file.rs index fdd7f04cf6..d35249d524 100644 --- a/vortex-file/src/v2/file.rs +++ b/vortex-file/src/v2/file.rs @@ -50,10 +50,6 @@ impl Scan { pub fn new(projection: ExprRef, filter: Option) -> Self { Self { projection, filter } } - - pub fn build(self, dtype: DType) -> VortexResult> { - Ok(Arc::new(Scanner::new(dtype, self.projection, self.filter)?)) - } } /// Async implementation of Vortex File. @@ -141,7 +137,11 @@ impl VortexFile { where R: Iterator + Send + 'static, { - let scanner = scan.build(self.dtype().clone())?; + let scanner = Arc::new(Scanner::new( + self.dtype().clone(), + scan.projection, + scan.filter, + )?); let result_dtype = scanner.result_dtype().clone();