delta_arrow_reader/
lib.rs

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

delta_arrow_reader/
lib.rs
