faucet-source-iceberg 1.2.2

Apache Iceberg table source for the faucet-stream ecosystem — projection, pushdown, time travel, incremental snapshot reads
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

#![cfg_attr(docsrs, feature(doc_cfg))]

//! # faucet-source-iceberg
//!
//! Apache Iceberg table source for the faucet-stream ecosystem. Reads a table
//! through a REST / Glue / SQL / HMS catalog (shared with the Iceberg sink via
//! `faucet-common-iceberg`) with column projection, a pushed-down row filter,
//! time travel (`snapshot_id` / `as_of_timestamp`), and incremental reads of
//! the data files added by `append` snapshots since a bookmarked snapshot.

pub mod config;
pub mod convert;
pub mod filter;
pub mod snapshots;
pub mod stream;

pub use config::{CatalogConfig, IcebergSourceConfig, OnExpired, OnRewrite, ReadMode};
pub use stream::IcebergSource;

mod descriptor;
pub use descriptor::DESCRIPTOR;