declarative_dataflow

Function implement

Source 
pub fn implement<T, I, S>(
    name: &str,
    scope: &mut S,
    context: &mut I,
) -> Result<(HashMap<String, Collection<S, Vec<Value>, isize>>, ShutdownHandle), Error>
where
    T: Timestamp + Lattice + Default,
    I: ImplContext<T>,
    S: Scope<Timestamp = T>,
Expand description

Takes a query plan and turns it into a differential dataflow.