delta-funnel 0.2.0

Lightweight, fast Delta Lake to SQL Server loads with DataFusion SQL and native TDS
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

//! SQL Server connection, lifecycle, sink, and write execution modules.

#[allow(dead_code)]
mod connection;
mod lifecycle;
mod sink;
mod workflow;
mod write;

pub use crate::report::sql_server::{
    MssqlBatchShapingReport, MssqlOutputBatchValidationReport, MssqlOutputFieldReport,
    MssqlTargetCleanupStatus, MssqlWriteFailureContext, MssqlWriteReport, MssqlWriteStats,
};
pub(crate) use lifecycle::{MssqlConnectedLifecycleClient, table_name_from_target};
pub use lifecycle::{MssqlPreparedTarget, MssqlPreparedTargetAction, MssqlPreparedTargetReport};
pub use sink::write_output_batches_to_mssql;
pub(crate) use sink::write_output_batches_to_mssql_with_validation_options;
pub use workflow::{
    MssqlOutputBatchStream, MssqlOutputBatchStreamFactory, MssqlOutputWriteJob,
    MssqlOutputWriteStatus, MssqlWorkflowWriteOptions, MssqlWorkflowWriteReport,
    MssqlWriteFailureReport, MssqlWriteSkippedReason, MssqlWriteSkippedReport,
    write_mssql_outputs_to_mssql,
};
pub(crate) use workflow::{MssqlWorkflowOutputWriter, write_mssql_outputs_with_writer};
pub(crate) use write::MssqlBulkLoadWriter;
pub use write::{
    MssqlWriteBackend, MssqlWritePhase, default_mssql_write_backend,
    mssql_write_backend_for_output_plan, validate_mssql_output_record_batch,
    validate_mssql_output_schema,
};

pub(super) use super::{
    LoadMode, MssqlConnectionConfig, MssqlConnectionSource, MssqlConnectionSummary,
    MssqlLifecycleExecutionGuardrail, MssqlSchemaPlanOptions, MssqlTargetOutputPlan,
    MssqlTargetSummary, MssqlTargetTable, MssqlTargetTableState, ResolvedMssqlTarget,
    plan_mssql_output_schema, plan_mssql_target_output,
};