diff options
Diffstat (limited to 'docs/streaming-programming-guide.md')
-rw-r--r-- | docs/streaming-programming-guide.md | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/docs/streaming-programming-guide.md b/docs/streaming-programming-guide.md index 93c34efb66..7e681b67cf 100644 --- a/docs/streaming-programming-guide.md +++ b/docs/streaming-programming-guide.md @@ -165,8 +165,8 @@ space into words. // Split each line into words JavaDStream<String> words = lines.flatMap( new FlatMapFunction<String, String>() { - @Override public Iterable<String> call(String x) { - return Arrays.asList(x.split(" ")); + @Override public Iterator<String> call(String x) { + return Arrays.asList(x.split(" ")).iterator(); } }); {% endhighlight %} |