Activate the source operator in the arrange example
@@ -6,6 +6,7 @@ use rand::{Rng, SeedableRng, StdRng};
use timely::dataflow::operators::*;
use timely::order::Product;
+use timely::scheduling::Scheduler;
use differential_dataflow::input::Input;
use differential_dataflow::AsCollection;
@@ -38,7 +39,9 @@ fn main() {
let mut graph = worker.dataflow::<Product<(),usize>,_,_>(|scope| {
// create a source operator which will produce random edges and delete them.
- timely::dataflow::operators::generic::source(scope, "RandomGraph", |mut capability, _info| {
+ timely::dataflow::operators::generic::source(scope, "RandomGraph", |mut capability, info| {
+
+ let activator = scope.activator_for(&info.address[..]);
let seed: &[_] = &[1, 2, 3, index];
let mut rng1: StdRng = SeedableRng::from_seed(seed); // rng for edge additions
@@ -87,6 +90,7 @@ fn main() {
// println!("downgrading {:?} to {:?}", capability, time);
capability.downgrade(&time);
}
+ activator.activate();
}
})
.probe_with(&mut probe)
