How to run the code:
- SM_Terasort.java: compile:
javac SM_Terasort.javarun:
java -Xms8192m -Xmx10240m SM_Terasortnote: here the size for xms and xmx means the size of initial heap size and maximum heap size for jvm. This should be determined according to the configure file. If you configure larger chunk size, then this number should be increased to make sure one chunk can be sucessfully loaded into memory.
- Hadoop_Terasort.java: compile:
/home/ubuntu/hadoop/bin/hadoop com.sun.tools.javac.Main Hadoop_Terasort.java
jar cf Hadoop_Terasort.jar *.classrun:
/home/ubuntu/hadoop/bin/hadoop jar Hadoop_Terasort.jar Hadoop_Terasort /sortdata/sorttxt /sortdata/output- Spark_Terasort.scala: compile: directly run Spark Shell, no need to compile
run:
/home/ubuntu/spark/bin/spark-shell