delta_arrow_reader/
lib.rs

1#![doc = include_str!("../README.md")]
2
3mod config;
4#[cfg(feature = "datafusion")]
5mod datafusion_dynamic_filters;
6#[cfg(feature = "datafusion")]
7mod datafusion_dynamic_partition_pruning;
8#[cfg(feature = "datafusion")]
9mod datafusion_execution;
10#[cfg(feature = "datafusion")]
11mod datafusion_planning;
12#[cfg(feature = "datafusion")]
13mod datafusion_provider;
14mod deletion_vector;
15mod direct;
16mod error;
17mod kernel;
18#[cfg(feature = "native-async")]
19#[allow(dead_code)]
20mod metered_object_store;
21mod metrics;
22#[cfg(feature = "native-async")]
23#[allow(dead_code)]
24mod native_async_reader;
25#[cfg(feature = "native-async")]
26#[allow(dead_code)]
27mod native_async_row_group_pruning;
28#[cfg(feature = "official-kernel")]
29#[allow(dead_code)]
30mod official_kernel_reader;
31mod partition_target;
32mod planning;
33mod predicate;
34mod protocol;
35#[allow(dead_code)]
36mod scheduling;
37mod snapshot;
38mod transform;
39mod uri;
40
41pub use config::{
42    DeltaReaderBackend, DeltaReaderExecutionOptions, DeltaSnapshotSelection, DeltaStorageOptions,
43};
44#[cfg(feature = "datafusion")]
45pub use datafusion_execution::{
46    DeltaDataFusionMetrics, DeltaDataFusionMetricsSnapshot, collect_delta_datafusion_metrics,
47};
48#[cfg(feature = "datafusion")]
49pub use datafusion_provider::{
50    DeltaDataFusionScanOptions, DeltaTableProvider, RegisteredDeltaTable, register_delta_table,
51};
52pub use direct::{
53    DeltaBatchStream, DeltaScan, DeltaScanBuilder, DeltaTable, DeltaTableBuilder,
54    DeltaTableSnapshot,
55};
56pub use error::{DeltaReaderError, DeltaReaderPhase};
57pub use metrics::{DeltaReadMetrics, DeltaReadMetricsSnapshot};
58#[doc(hidden)]
59pub use partition_target::{
60    DeltaScanPartitionTargetDiagnosticInput, DeltaScanPartitionTargetDiagnosticOutput,
61    DeltaScanPartitionTargetDiagnosticSource, DeltaScanPartitionTargetLocalEnvironmentDiagnostic,
62    DeltaScanPartitionTargetLocalUnixFileDescriptorLimitStatus,
63    delta_scan_partition_target_local_environment_diagnostic,
64    derive_delta_scan_partition_target_diagnostic,
65};
66pub use predicate::{DeltaComparison, DeltaPredicate, DeltaScalar};
67pub use protocol::DeltaProtocolInfo;
68
69/// The crate version.
70pub const VERSION: &str = env!("CARGO_PKG_VERSION");
71
72/// Returns the crate version.
73pub const fn version() -> &'static str {
74    VERSION
75}
delta_arrow_reader/lib.rs

delta_arrow_reader/
lib.rs
