Skip to content

Commit

Permalink
Merge pull request lw-lin#20 from klion26/master
Browse files Browse the repository at this point in the history
Fix typo
  • Loading branch information
lw-lin authored Jul 5, 2016
2 parents de73c43 + c6e178c commit c001005
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ def flatMap[U: ClassTag](flatMapFunc: T => Traversable[U]): DStream[U] = ssc.wit

后面几行也是如此,所以我们如果用 DStream DAG 图来表示之前那段 quick example 的话,就是这个样子:

![image](1.imgs/010.jpg)
![image](1.imgs/010.png)

也即,我们给出的那段代码,用具体的实现来替换的话,结果如下:

Expand Down

0 comments on commit c001005

Please sign in to comment.