diff options
Diffstat (limited to 'examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java')
-rw-r--r-- | examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java b/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java index 5f342e1ead..3af786978b 100644 --- a/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java +++ b/examples/src/main/java/org/apache/spark/examples/sql/streaming/JavaStructuredNetworkWordCount.java @@ -21,7 +21,6 @@ import org.apache.spark.sql.*; import org.apache.spark.sql.streaming.StreamingQuery; import java.util.Arrays; -import java.util.Iterator; /** * Counts words in UTF8 encoded, '\n' delimited text received from the network. @@ -61,13 +60,9 @@ public final class JavaStructuredNetworkWordCount { .load(); // Split the lines into words - Dataset<String> words = lines.as(Encoders.STRING()) - .flatMap(new FlatMapFunction<String, String>() { - @Override - public Iterator<String> call(String x) { - return Arrays.asList(x.split(" ")).iterator(); - } - }, Encoders.STRING()); + Dataset<String> words = lines.as(Encoders.STRING()).flatMap( + (FlatMapFunction<String, String>) x -> Arrays.asList(x.split(" ")).iterator(), + Encoders.STRING()); // Generate running word count Dataset<Row> wordCounts = words.groupBy("value").count(); |