Skip to content

Commit

Permalink
fix arrow imports
Browse files Browse the repository at this point in the history
  • Loading branch information
sebastiantia committed Feb 21, 2025
1 parent ff67fcf commit fbe1d87
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 6 deletions.
2 changes: 1 addition & 1 deletion kernel/src/log_segment/tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ use std::{path::PathBuf, sync::Arc};

use itertools::Itertools;
use object_store::{memory::InMemory, path::Path, ObjectStore};
use parquet::arrow::ArrowWriter;
use url::Url;

use crate::actions::visitors::AddVisitor;
Expand All @@ -16,6 +15,7 @@ use crate::engine::default::filesystem::ObjectStoreFileSystemClient;
use crate::engine::default::DefaultEngine;
use crate::engine::sync::SyncEngine;
use crate::log_segment::LogSegment;
use crate::parquet::arrow::ArrowWriter;
use crate::path::ParsedLogPath;
use crate::scan::test_utils::{
add_batch_simple, add_batch_with_remove, sidecar_batch_with_given_paths,
Expand Down
7 changes: 3 additions & 4 deletions kernel/src/scan/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -663,11 +663,10 @@ pub fn selection_vector(
// some utils that are used in file_stream.rs and state.rs tests
#[cfg(test)]
pub(crate) mod test_utils {
use std::sync::Arc;

use arrow_array::{RecordBatch, StringArray};
use arrow_schema::{DataType, Field, Schema as ArrowSchema};
use crate::arrow::array::{RecordBatch, StringArray};
use crate::arrow::datatypes::{DataType, Field, Schema as ArrowSchema};
use itertools::Itertools;
use std::sync::Arc;

use crate::{
actions::get_log_schema,
Expand Down
2 changes: 1 addition & 1 deletion kernel/src/utils.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ pub(crate) use require;

#[cfg(test)]
pub(crate) mod test_utils {
use arrow_array::RecordBatch;
use crate::arrow::array::RecordBatch;
use itertools::Itertools;
use object_store::local::LocalFileSystem;
use object_store::ObjectStore;
Expand Down

0 comments on commit fbe1d87

Please sign in to comment.