faucet_source_iceberg/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-source-iceberg
4//!
5//! Apache Iceberg table source for the faucet-stream ecosystem. Reads a table
6//! through a REST / Glue / SQL / HMS catalog (shared with the Iceberg sink via
7//! `faucet-common-iceberg`) with column projection, a pushed-down row filter,
8//! time travel (`snapshot_id` / `as_of_timestamp`), and incremental reads of
9//! the data files added by `append` snapshots since a bookmarked snapshot.
10
11pub mod config;
12pub mod convert;
13pub mod filter;
14pub mod snapshots;
15pub mod stream;
16
17pub use config::{CatalogConfig, IcebergSourceConfig, OnExpired, OnRewrite, ReadMode};
18pub use stream::IcebergSource;
19
20mod descriptor;
21pub use descriptor::DESCRIPTOR;