Skip to content

Commit 8d1f5ac

Browse files
committed
Add missing imports
1 parent 74b25fe commit 8d1f5ac

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

kernel/src/engine/sync/parquet.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,11 @@
11
use std::fs::File;
22

33
use crate::arrow::datatypes::SchemaRef as ArrowSchemaRef;
4+
use crate::engine::arrow_data::ArrowEngineData;
5+
use crate::engine::arrow_utils::{
6+
fixup_parquet_read, generate_mask, get_requested_indices, ordering_needs_row_indexes,
7+
RowIndexBuilder,
8+
};
49
use crate::engine::parquet_row_group_skipping::ParquetRowGroupSkipping;
510
use crate::parquet::arrow::arrow_reader::{ArrowReaderMetadata, ParquetRecordBatchReaderBuilder};
611
use crate::parquet::arrow::arrow_writer::ArrowWriter;
@@ -9,6 +14,8 @@ use crate::{DeltaResult, FileDataReadResultIterator, FileMeta, ParquetHandler, P
914

1015
use url::Url;
1116

17+
use super::read_files;
18+
1219
pub(crate) struct SyncParquetHandler;
1320

1421
fn try_create_from_parquet(

0 commit comments

Comments
 (0)