1. 背景：之前已經學習過Spark SQL的相關知識，現在開始對Spark的另一模組Streaming部分進行學習。首先是參考官網上的Demo進行樣例的編寫，但是發現程式碼有點問題，百度之後發現，在一處程式碼處發現問題，所以寫此文。

2. 介紹：一些部落格上的

 JavaDStream<String> words = lines.flatMap(new FlatMapFunction<String,String>(){ //如果是Scala，由於SAM裝換，可以寫成val words = lines.flatMap{line => line.split("　＂)}

            @Override
            public Iterable<String> call(String line) throws Exception {

                return Arrays.asList(line.split(" "));//將其變成Iterable的子類
            }
        });
 

// Split each line into words
JavaDStream<String> words = lines.flatMap(x -> Arrays.asList(x.split(" ")).iterator());

JavaDStream<String> words = lines.flatMap(new FlatMapFunction<String, String>() {
            public Iterator<String> call(String line) throws Exception {
                String aStr[] = line.split(",");
                return Arrays.asList(aStr).iterator();
            }
        });
 

Iterator iterator = list.iterator();        while(iterator.hasNext()){            String string = iterator.next();            //do something        }

$ nc -lk 9999