fork download

copy

/* 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
{
	public static void main (String[] args) throws java.lang.Exception
	{
		// 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());
	}
}

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

Standard output is empty