From caed6879e6a42441ffad2053bda074a559c278cd Mon Sep 17 00:00:00 2001
From: Weny Xu <wenymedia@gmail.com>
Date: Sun, 25 Jun 2023 11:56:31 +0900
Subject: [PATCH] refactor: remove redundant code (#1821)

---
 src/file-table-engine/src/table/format.rs | 25 ++---------------------
 1 file changed, 2 insertions(+), 23 deletions(-)

diff --git a/src/file-table-engine/src/table/format.rs b/src/file-table-engine/src/table/format.rs
index 47d58ee69c1c..ee3f0262ddac 100644
--- a/src/file-table-engine/src/table/format.rs
+++ b/src/file-table-engine/src/table/format.rs
@@ -94,29 +94,8 @@ fn build_scan_plan<T: FileOpener + Send + 'static>(
     projection: Option<&Vec<usize>>,
     limit: Option<usize>,
 ) -> Result<PhysicalPlanRef> {
-    let stream = FileStream::new(
-        &FileScanConfig {
-            object_store_url: ObjectStoreUrl::parse("empty://").unwrap(), // won't be used
-            file_schema,
-            file_groups: vec![files
-                .iter()
-                .map(|filename| PartitionedFile::new(filename.to_string(), 0))
-                .collect::<Vec<_>>()],
-            statistics: Default::default(),
-            projection: projection.cloned(),
-            limit,
-            table_partition_cols: vec![],
-            output_ordering: None,
-            infinite_source: false,
-        },
-        0, // partition: hard-code
-        opener,
-        &ExecutionPlanMetricsSet::new(),
-    )
-    .context(error::BuildStreamSnafu)?;
-    let adapter = RecordBatchStreamAdapter::try_new(Box::pin(stream))
-        .context(error::BuildStreamAdapterSnafu)?;
-    Ok(Arc::new(StreamScanAdapter::new(Box::pin(adapter))))
+    let adapter = build_record_batch_stream(opener, file_schema, files, projection, limit)?;
+    Ok(Arc::new(StreamScanAdapter::new(adapter)))
 }
 
 fn build_record_batch_stream<T: FileOpener + Send + 'static>(