import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.function.Function;
public class DataProcessingApp {
public static void main(String[] args) {
SparkConf conf = new SparkConf()
.setAppName("DataProcessingApp")
JavaSparkContext sc = new JavaSparkContext(conf);
JavaRDD<String> data = sc.textFile("path/to/input/file");
JavaRDD<String> processedData = data.map(new Function<String, String>() {
public String call(String line) throws Exception {
return line.toUpperCase();
}
});
processedData.saveAsTextFile("path/to/output/directory");
sc.stop();
}
}
