tinyflow_framework/stream/mod.rs
1//! Stream DSL: linear in-process operator chains (`map`, `filter`, `flat_map`, `sink`).
2//!
3//! **Production Iceberg jobs**: [`crate::connectors::iceberg::data_stream_ext::IcebergDataStreamExt::add_iceberg_sink`]
4//! then [`crate::stream::chain_execute::execute`].
5
6pub mod chain_execute;
7pub mod data_stream;
8
9pub use chain_execute::execute;