MCPcopy Create free account
hub / github.com/comnik/declarative-dataflow / implement

Method implement

src/plan/project.rs:49–75  ·  view source on GitHub ↗
(
        &self,
        nested: &mut Iterative<'b, S, u64>,
        local_arrangements: &VariableMap<Iterative<'b, S, u64>>,
        context: &mut I,
    )

Source from the content-addressed store, hash-verified

47 }
48
49 fn implement<'b, T, I, S>(
50 &self,
51 nested: &mut Iterative<'b, S, u64>,
52 local_arrangements: &VariableMap<Iterative<'b, S, u64>>,
53 context: &mut I,
54 ) -> (Implemented<'b, S>, ShutdownHandle)
55 where
56 T: Timestamp + Lattice,
57 I: ImplContext<T>,
58 S: Scope<Timestamp = T>,
59 {
60 let (relation, mut shutdown_handle) =
61 self.plan.implement(nested, local_arrangements, context);
62 let tuples = {
63 let (projected, shutdown) = relation.projected(nested, context, &self.variables);
64 shutdown_handle.merge_with(shutdown);
65
66 projected
67 };
68
69 let projected = CollectionRelation {
70 variables: self.variables.to_vec(),
71 tuples,
72 };
73
74 (Implemented::Collection(projected), shutdown_handle)
75 }
76}

Callers

nothing calls this directly

Calls 2

projectedMethod · 0.80
merge_withMethod · 0.80

Tested by

no test coverage detected