delta_arrow_reader/
lib.rs1#![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 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#[cfg(feature = "experimental-parquet-metadata-preparation")]
46pub use reader::{ParquetMetadataPreparationLimits, ParquetMetadataPreparationReport};
47pub const VERSION: &str = env!("CARGO_PKG_VERSION");