From c6e178cf34bcaa6278e8bb276f829e0f02d9139b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B1=E4=BB=8E=E8=B4=A4?= Date: Sun, 29 May 2016 22:27:32 +0800 Subject: [PATCH] fix typo --- ...220 RDD \345\256\236\344\276\213\350\257\246\350\247\243.md" | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git "a/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/1.2 DStream \347\224\237\346\210\220 RDD \345\256\236\344\276\213\350\257\246\350\247\243.md" "b/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/1.2 DStream \347\224\237\346\210\220 RDD \345\256\236\344\276\213\350\257\246\350\247\243.md" index c2f7ad9..9de6231 100644 --- "a/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/1.2 DStream \347\224\237\346\210\220 RDD \345\256\236\344\276\213\350\257\246\350\247\243.md" +++ "b/Spark Streaming \346\272\220\347\240\201\350\247\243\346\236\220\347\263\273\345\210\227/1.2 DStream \347\224\237\346\210\220 RDD \345\256\236\344\276\213\350\257\246\350\247\243.md" @@ -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) 也即，我们给出的那段代码，用具体的实现来替换的话，结果如下：