src/main/java/com/aliyun/emr/example/spark/streaming/JavaLoghubWordCount.java [68:74]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    JavaDStream<String> words = lines.map(new Function<byte[], String>() {
      @Override
      public String call(byte[] v1) throws Exception {
        return new String(v1);
      }
    }).flatMap(new FlatMapFunction<String, String>() {
      @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/aliyun/emr/example/spark/streaming/SparkMNSJavaDemo.java [59:65]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        JavaDStream<String> words = lines.map(new Function<byte[], String>() {
            @Override
            public String call(byte[] v1) throws Exception {
                return new String(v1);
            }
        }).flatMap(new FlatMapFunction<String, String>() {
            @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -