cal");
>
> JavaSparkContext *context* = *new* JavaSparkContext(conf);
>
> JavaRDD file = context.textFile("Input/SampleTextFile.txt");
>
> file.saveAsTextFile("file:///Output/WordCount.txt");
>
> JavaRDD words = file.flatMap(*WORDS_EXTRACTOR*);
>
>
ORDS_REDUCER*);
counter.foreach(System.*out*::println);
counter.saveAsTextFile("file:///Output/WordCount.txt");
}
}
*Exception in thread "main" java.lang.IncompatibleClassChangeError:
Implementing class*
at java.lang.ClassLoader.defineClass1(*Native Method*)
at java.lang.ClassLoader.d
