Skip to content

Commit

Permalink
fix a typo
Browse files Browse the repository at this point in the history
  • Loading branch information
wongxingjun committed Jul 4, 2016
1 parent cf42ff2 commit b93b0d6
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 b93b0d6

Please sign in to comment.