Skip to main content

optimize_dataflow_snapshot

Function optimize_dataflow_snapshot 

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

Determine whether we require snapshots from our durable source imports. (For example, these can often be skipped for simple subscribe queries.)