Struct StreamFusion 

pub struct StreamFusion {
    pub min_iterations: u64,
    pub fuse_nested: bool,
}

Stream fusion optimization

This is RipTide’s key optimization that achieves 27-52% operator reduction by fusing loop induction variable computations into single Stream operators.

Pattern detected:

Constant(start) --> Add --> Compare --> Steer
                     ^          |
                     |          v
                  Carry <--- (loop body)

Becomes:

Stream(start, step, bound) --> (loop body)

Fields

min_iterations: u64

Minimum loop iterations to consider for fusion

fuse_nested: bool

Whether to fuse nested loops

Implementations

impl StreamFusion

pub fn new() -> Self

pub fn optimize(&self, dfg: &mut DataflowGraph) -> usize

Run stream fusion on a dataflow graph

Trait Implementations

impl Default for StreamFusion

fn default() -> Self

Returns the “default value” for a type.