[Learning Spark with Examples] Line Count With Filtering

In the last we saw the Line Count example, now lets add filtering to the example, to filter out empty lines. The code can be found here LineCountWithFiltering.java Lets look at the code public class LineCountWithFiltering { public static void main(String[] args) { SparkConf sparkConf = new SparkConf().setAppName("File Copy"); JavaSparkContext sparkContext = new JavaSparkContext(sparkConf); // […]

Continue reading