fn optimize_dataflow_filters(
    dataflow: &mut DataflowDesc
) -> Result<(), TransformError>
Expand description

Pushes predicate to dataflow inputs.