@@ -160,10 +160,10 @@ <h2 id="the-iterate-operator"><a class="header" href="#the-iterate-operator">The
160160</ span > < span class ="boring "> extern crate timely;
161161</ span > < span class ="boring "> extern crate differential_dataflow;
162162</ span > < span class ="boring "> use timely::dataflow::Scope;
163- </ span > < span class ="boring "> use differential_dataflow::Collection ;
163+ </ span > < span class ="boring "> use differential_dataflow::VecCollection ;
164164</ span > < span class ="boring "> use differential_dataflow::operators::{Join, Iterate, Threshold};
165165</ span > < span class ="boring "> use differential_dataflow::lattice::Lattice;
166- </ span > < span class ="boring "> fn example<G: Scope>(manages: &Collection <G, (u64, u64)>)
166+ </ span > < span class ="boring "> fn example<G: Scope>(manages: &VecCollection <G, (u64, u64)>)
167167</ span > < span class ="boring "> where G::Timestamp: Lattice
168168</ span > < span class ="boring "> {
169169</ span > manages // transitive contains (manager, person) for many hops.
@@ -197,11 +197,11 @@ <h3 id="enter"><a class="header" href="#enter">Enter</a></h3>
197197</ span > < span class ="boring "> extern crate timely;
198198</ span > < span class ="boring "> extern crate differential_dataflow;
199199</ span > < span class ="boring "> use timely::dataflow::Scope;
200- </ span > < span class ="boring "> use differential_dataflow::Collection ;
200+ </ span > < span class ="boring "> use differential_dataflow::VecCollection ;
201201</ span > < span class ="boring "> use differential_dataflow::operators::{Join, Threshold};
202- </ span > < span class ="boring "> use differential_dataflow::operators::{Iterate, iterate::Variable };
202+ </ span > < span class ="boring "> use differential_dataflow::operators::{Iterate, iterate::VecVariable };
203203</ span > < span class ="boring "> use differential_dataflow::lattice::Lattice;
204- </ span > < span class ="boring "> fn example<G: Scope>(manages: &Collection <G, (u64, u64)>)
204+ </ span > < span class ="boring "> fn example<G: Scope>(manages: &VecCollection <G, (u64, u64)>)
205205</ span > < span class ="boring "> where G::Timestamp: Lattice
206206</ span > < span class ="boring "> {
207207</ span > manages // transitive contains (manager, person) for many hops.
@@ -232,19 +232,19 @@ <h3 id="variables"><a class="header" href="#variables">Variables</a></h3>
232232</ span > < span class ="boring "> use timely::dataflow::Scope;
233233</ span > < span class ="boring "> use timely::dataflow::scopes::Child;
234234</ span > < span class ="boring "> use timely::progress::Antichain;
235- </ span > < span class ="boring "> use differential_dataflow::Collection ;
236- </ span > < span class ="boring "> use differential_dataflow::operators::{Iterate, iterate::Variable };
235+ </ span > < span class ="boring "> use differential_dataflow::VecCollection ;
236+ </ span > < span class ="boring "> use differential_dataflow::operators::{Iterate, iterate::VecVariable };
237237</ span > < span class ="boring "> use differential_dataflow::lattice::Lattice;
238- </ span > < span class ="boring "> fn logic<'a, G: Scope>(variable: &Variable <Child<'a, G, G::Timestamp>, (u64, u64), isize>) -> Collection <Child<'a, G, G::Timestamp>, (u64, u64)>
238+ </ span > < span class ="boring "> fn logic<'a, G: Scope>(variable: &VecVariable <Child<'a, G, G::Timestamp>, (u64, u64), isize>) -> VecCollection <Child<'a, G, G::Timestamp>, (u64, u64)>
239239</ span > < span class ="boring "> where G::Timestamp: Lattice
240240</ span > < span class ="boring "> {
241241</ span > < span class ="boring "> (*variable).clone()
242242</ span > < span class ="boring "> }
243- </ span > < span class ="boring "> fn example<'a, G: Scope<Timestamp=u64>>(collection: &Collection <G, (u64, u64)>) //, logic: impl Fn(&Variable <Child<'a, G, G::Timestamp>, (u64, u64), isize>) -> Collection <Child<'a, G, G::Timestamp>, (u64, u64)>)
243+ </ span > < span class ="boring "> fn example<'a, G: Scope<Timestamp=u64>>(collection: &VecCollection <G, (u64, u64)>) //, logic: impl Fn(&VecVariable <Child<'a, G, G::Timestamp>, (u64, u64), isize>) -> VecCollection <Child<'a, G, G::Timestamp>, (u64, u64)>)
244244</ span > < span class ="boring "> where G::Timestamp: Lattice
245245</ span > < span class ="boring "> {
246246</ span > collection.scope().scoped("inner", |subgraph| {
247- let variable = Variable ::new_from(collection.enter(subgraph), 1);
247+ let variable = VecVariable ::new_from(collection.enter(subgraph), 1);
248248 let result = logic(&variable);
249249 variable.set(&result);
250250 result.leave()
0 commit comments