[SPARK-7096] Java example for Streaming on site uses map instead of mapToPair

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 1.3.1
• Component/s: Documentation, Java API

Environment

Web

• Assignee: Unassigned
• Reporter: Edward Sargisson
• Created: 23/Apr/15 18:10
• Updated: 23/Apr/15 18:14
• Resolved: 23/Apr/15 18:14

Description

https://spark.apache.org/docs/latest/streaming-programming-guide.html

Here word count example for java is incorrect. It should be mapToPair instead of map.

Incorrect:

JavaPairDStream<String, Integer> pairs = words.map(
  new PairFunction<String, String, Integer>() {
    @Override public Tuple2<String, Integer> call(String s) throws Exception {
      return new Tuple2<String, Integer>(s, 1);
    }
  });

Issue Links

• duplicates: SPARK-4046 Incorrect Java example on site
• is a clone of: SPARK-4046 Incorrect Java example on site