Skip to content

Commit 993a62c

Browse files
ion-elgrecortyler
authored andcommitted
chore: move writer to write module
Signed-off-by: Ion Koutsouris <[email protected]>
1 parent 19fb4a1 commit 993a62c

File tree

5 files changed

+3
-3
lines changed

5 files changed

+3
-3
lines changed

crates/core/src/operations/mod.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,6 @@ pub mod set_tbl_properties;
6868
pub mod update;
6969
#[cfg(feature = "datafusion")]
7070
pub mod write;
71-
pub mod writer;
7271

7372
#[async_trait]
7473
pub trait CustomExecuteHandler: Send + Sync {

crates/core/src/operations/optimize.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ use tracing::*;
4343
use uuid::Uuid;
4444

4545
use super::transaction::PROTOCOL;
46-
use super::writer::{PartitionWriter, PartitionWriterConfig};
46+
use super::write::writer::{PartitionWriter, PartitionWriterConfig};
4747
use super::{CustomExecuteHandler, Operation};
4848
use crate::errors::{DeltaResult, DeltaTableError};
4949
use crate::kernel::Add;

crates/core/src/operations/write/execution.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,14 +13,14 @@ use parquet::file::properties::WriterProperties;
1313
use tracing::log::*;
1414
use uuid::Uuid;
1515

16+
use super::writer::{DeltaWriter, WriterConfig};
1617
use crate::delta_datafusion::expr::fmt_expr_to_sql;
1718
use crate::delta_datafusion::{find_files, DeltaScanConfigBuilder, DeltaTableProvider};
1819
use crate::delta_datafusion::{DataFusionMixins, DeltaDataChecker};
1920
use crate::errors::DeltaResult;
2021
use crate::kernel::{Action, Add, AddCDCFile, Remove, StructType, StructTypeExt};
2122
use crate::logstore::LogStoreRef;
2223
use crate::operations::cdc::should_write_cdc;
23-
use crate::operations::writer::{DeltaWriter, WriterConfig};
2424
use crate::storage::ObjectStoreRef;
2525
use crate::table::state::DeltaTableState;
2626
use crate::table::Constraint as DeltaConstraint;

crates/core/src/operations/write/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ pub(crate) mod execution;
2828
pub(crate) mod generated_columns;
2929
pub(crate) mod metrics;
3030
pub(crate) mod schema_evolution;
31+
pub mod writer;
3132

3233
use arrow_schema::Schema;
3334
pub use configs::WriterStatsConfig;

0 commit comments

Comments
 (0)