Returns an array of abstract pathnames denoting the files in the directory denoted by this abstract pathname.
Deletes the file or directory denoted by this abstract pathname. If this pathname denotes a directory, then the directory must be empty in order to be deleted.
Tests whether the file or directory denoted by this abstract pathname exists.
Read a text file from HDFS, a local file system (available on all nodes), or any Hadoop-supported file system URI, and return it as an RDD of Strings.
Merge the values for each key using an associative reduce function. This will also perform the merging locally on each mapper before sending results to a reducer, similarly to a "combiner" in MapReduce. Output will be hash-partitioned with the existing partitioner/ parallelism level.
Save this RDD as a text file, using string representations of elements.
Applies a function f to all elements of this RDD.
Return a new RDD by applying a function to all elements of this RDD.
Return a new RDD by first applying a function to all elements of this RDD, and then flattening the results.
· JDK 1.7 or higher
· Scala 2.10.3
CSV file name : employeeData.csv