@@ -18,12 +18,13 @@ You can create a new scope in any other scope by invoking the `scoped` method:
18
18
extern crate timely;
19
19
20
20
use timely :: dataflow :: Scope ;
21
+ use timely :: progress :: SubgraphBuilder ;
21
22
22
23
fn main () {
23
24
timely :: example (| scope | {
24
25
25
26
// Create a new scope with the same (u64) timestamp.
26
- scope . scoped :: <u64 ,_ ,_ >(" SubScope" , | subscope | {
27
+ scope . scoped :: <u64 ,_ ,_ , SubgraphBuilder < _ , _ > >(" SubScope" , | subscope | {
27
28
// probably want something here
28
29
})
29
30
@@ -46,14 +47,15 @@ extern crate timely;
46
47
47
48
use timely :: dataflow :: Scope ;
48
49
use timely :: dataflow :: operators :: * ;
50
+ use timely :: progress :: SubgraphBuilder ;
49
51
50
52
fn main () {
51
53
timely :: example (| scope | {
52
54
53
55
let stream = (0 .. 10 ). to_stream (scope );
54
56
55
57
// Create a new scope with the same (u64) timestamp.
56
- let result = scope . scoped :: <u64 ,_ ,_ >(" SubScope" , | subscope | {
58
+ let result = scope . scoped :: <u64 ,_ ,_ , SubgraphBuilder < _ , _ > >(" SubScope" , | subscope | {
57
59
stream . enter (subscope )
58
60
. inspect_batch (| t , xs | println! (" {:?}, {:?}" , t , xs ))
59
61
. leave ()
@@ -108,14 +110,15 @@ extern crate timely;
108
110
109
111
use timely :: dataflow :: Scope ;
110
112
use timely :: dataflow :: operators :: * ;
113
+ use timely :: progress :: SubgraphBuilder ;
111
114
112
115
fn main () {
113
116
timely :: example (| scope | {
114
117
115
118
let stream = (0 .. 10 ). to_stream (scope );
116
119
117
120
// Create a new scope with a (u64, u32) timestamp.
118
- let result = scope . iterative :: <u32 ,_ ,_ >(| subscope | {
121
+ let result = scope . iterative :: <u32 ,_ ,_ , SubgraphBuilder < _ , _ > >(| subscope | {
119
122
stream . enter (subscope )
120
123
. inspect_batch (| t , xs | println! (" {:?}, {:?}" , t , xs ))
121
124
. leave ()
0 commit comments