Skip to main content

run_stream

Function run_stream 

Source
pub fn run_stream(cfg: StreamConfig) -> Result<(), String>
Expand description

Run the stream: convert the settings into a plan (Plan::from_stream) and validate and run it through the declarative layer (Recon). Recreates the output folder. The output is the same as when the session reducer + pipeline + default output hooks are assembled directly.