Module stream 

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.

Re-exports

pub use chain_execute::execute;

Modules

chain_execute

Spawn ChainedStreamTask from a ChainJob (framework-only, no committer).

data_stream

Linear operator chain DSL (map, filter, flat_map, sink, name).