delta_arrow_reader/
lib.rs

1#![doc = include_str!("../README.md")]
2#![cfg_attr(test, allow(clippy::panic))]
3
4mod delta;
5mod error;
6mod reader;
7
8pub mod guides;
9
10#[cfg(feature = "datafusion")]
11pub use reader::datafusion;
12
13pub use delta::DeltaProtocol;
14pub use error::{DeltaReaderError, DeltaReaderPhase};
15#[doc(hidden)]
16pub mod diagnostics {
17    pub mod parquet_range_planning {
18        pub use crate::reader::{
19            ParquetRangePlanningDiagnosticSnapshot as Snapshot, ParquetRangeReadPolicy as Policy,
20        };
21
22        /// Returns internal measurements used by the range-planning benchmark.
23        pub fn snapshot(metrics: &crate::DeltaScanMetrics) -> Snapshot {
24            metrics.parquet_range_planning_diagnostic_snapshot()
25        }
26    }
27
28    pub mod partition_target {
29        pub use crate::reader::partition_target::{
30            DeltaScanPartitionTargetDiagnosticInput as Input,
31            DeltaScanPartitionTargetDiagnosticOutput as Output,
32            DeltaScanPartitionTargetDiagnosticSource as Source,
33            DeltaScanPartitionTargetLocalEnvironmentDiagnostic as LocalEnvironment,
34            DeltaScanPartitionTargetLocalUnixFileDescriptorLimitStatus as UnixFileDescriptorLimitStatus,
35            delta_scan_partition_target_local_environment_diagnostic as collect_local_environment,
36            derive_delta_scan_partition_target_diagnostic as derive,
37        };
38    }
39}
40pub use reader::{
41    DeltaBatchStream, DeltaComparison, DeltaPredicate, DeltaScalar, DeltaScan, DeltaScanBuilder,
42    DeltaScanExecutionOptions, DeltaScanMetrics, DeltaScanMetricsSnapshot, DeltaSnapshotSelection,
43    DeltaStorageOptions, DeltaTable, DeltaTableBuilder, DeltaTableSnapshot, ParquetReaderBackend,
44};
45/// The crate version.
46pub const VERSION: &str = env!("CARGO_PKG_VERSION");
delta_arrow_reader/lib.rs

delta_arrow_reader/
lib.rs
