/* package whatever; // don't place package name! */
import java.util.*;
import java.lang.*;
import java.io.*;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.function.FlatMapFunction;
import org.apache.spark.api.java.function.Function;
/* Name of the class has to be "Main" only if the class is public. */
class Ideone
{
{
// your code goes here
List
<String
> data
= Arrays.
asList("Learn",
"Apache",
"Spark",
"with",
"Tutorial Kart"); JavaRDD<String> words = sc.parallelize(data,1);
JavaPairRDD<Int, String> withKeys = words.keyBy((w) -> w.length);
System.
out.
println(withKeys.
collect()); }
}
LyogcGFja2FnZSB3aGF0ZXZlcjsgLy8gZG9uJ3QgcGxhY2UgcGFja2FnZSBuYW1lISAqLwoKaW1wb3J0IGphdmEudXRpbC4qOwppbXBvcnQgamF2YS5sYW5nLio7CmltcG9ydCBqYXZhLmlvLio7CmltcG9ydCBvcmcuYXBhY2hlLnNwYXJrLmFwaS5qYXZhLkphdmFSREQ7CmltcG9ydCBvcmcuYXBhY2hlLnNwYXJrLmFwaS5qYXZhLmZ1bmN0aW9uLkZsYXRNYXBGdW5jdGlvbjsKaW1wb3J0IG9yZy5hcGFjaGUuc3BhcmsuYXBpLmphdmEuZnVuY3Rpb24uRnVuY3Rpb247Ci8qIE5hbWUgb2YgdGhlIGNsYXNzIGhhcyB0byBiZSAiTWFpbiIgb25seSBpZiB0aGUgY2xhc3MgaXMgcHVibGljLiAqLwpjbGFzcyBJZGVvbmUKewoJcHVibGljIHN0YXRpYyB2b2lkIG1haW4gKFN0cmluZ1tdIGFyZ3MpIHRocm93cyBqYXZhLmxhbmcuRXhjZXB0aW9uCgl7CgkJLy8geW91ciBjb2RlIGdvZXMgaGVyZQoJCUxpc3Q8U3RyaW5nPiBkYXRhID0gQXJyYXlzLmFzTGlzdCgiTGVhcm4iLCJBcGFjaGUiLCJTcGFyayIsIndpdGgiLCJUdXRvcmlhbCBLYXJ0Iik7IAogICAgICAgIEphdmFSREQ8U3RyaW5nPiB3b3JkcyA9IHNjLnBhcmFsbGVsaXplKGRhdGEsMSk7CgkKICAgICAgICAgSmF2YVBhaXJSREQ8SW50LCBTdHJpbmc+IHdpdGhLZXlzID0gd29yZHMua2V5QnkoKHcpIC0+IHcubGVuZ3RoKTsKICAgICAgICAgU3lzdGVtLm91dC5wcmludGxuKHdpdGhLZXlzLmNvbGxlY3QoKSk7Cgl9Cn0=
Main.java:6: error: package org.apache.spark.api.java does not exist
import org.apache.spark.api.java.JavaRDD;
^
Main.java:7: error: package org.apache.spark.api.java.function does not exist
import org.apache.spark.api.java.function.FlatMapFunction;
^
Main.java:8: error: package org.apache.spark.api.java.function does not exist
import org.apache.spark.api.java.function.Function;
^
Main.java:16: error: cannot find symbol
JavaRDD<String> words = sc.parallelize(data,1);
^
symbol: class JavaRDD
location: class Ideone
Main.java:16: error: cannot find symbol
JavaRDD<String> words = sc.parallelize(data,1);
^
symbol: variable sc
location: class Ideone
Main.java:18: error: cannot find symbol
JavaPairRDD<Int, String> withKeys = words.keyBy((w) -> w.length);
^
symbol: class JavaPairRDD
location: class Ideone
Main.java:18: error: cannot find symbol
JavaPairRDD<Int, String> withKeys = words.keyBy((w) -> w.length);
^
symbol: class Int
location: class Ideone
7 errors