(
&self,
nested: &mut Iterative<'b, S, u64>,
local_arrangements: &VariableMap<Iterative<'b, S, u64>>,
context: &mut I,
)
| 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 | } |
nothing calls this directly
no test coverage detected