tinyflow-framework 0.1.1

Streaming runtime engine — checkpoint, chained task execution, and state store
Documentation 
1
2
3
4
5
6
7
8
9

//! Stream DSL: linear in-process operator chains (`map`, `filter`, `flat_map`, `sink`).
//!
//! **Production Iceberg jobs**: [`crate::connectors::iceberg::data_stream_ext::IcebergDataStreamExt::add_iceberg_sink`]
//! then [`crate::stream::chain_execute::execute`].

pub mod chain_execute;
pub mod data_stream;

pub use chain_execute::execute;