Win7 Eclipse 搭建spark java1.8編譯環(huán)境,JavaRDD的helloworld例子

Win7 Eclipse 搭建spark java1.8編譯環(huán)境,JavaRDD的helloworld例子：
馬克- to-win：馬克 java社區(qū)：防盜版實名手機尾號： 73203。
馬克-to-win @ 馬克java社區(qū)：在eclipse oxygen上創(chuàng)建一個普通的java項目，然后把spark-assembly-1.6.1-hadoop2.6.0.jar這個包導進工程就ok了。

package com;
import java.util.Arrays;
import java.util.List;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaDoubleRDD;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.function.Function;
public class CollectTest {
    public static void main(String[] args) {
        SparkConf conf = new SparkConf().setAppName("testCollect馬克-to-win @ 馬克java社區(qū)：防盜版實名手機尾號：73203").setMaster("local");
        JavaSparkContext sc = new JavaSparkContext(conf);
        List<Double> list = Arrays.asList(1.0, 4.0, 3.0, 7.0,5.0);
        JavaDoubleRDD doubleRdd = sc.parallelizeDoubles(list, 2);
/*注意下面Function里面的兩個參數(shù)Double, Double，代表著call里面的輸入和返回兩個參數(shù)。*/      
        JavaRDD<Double> mapRdd = doubleRdd.map(new Function<Double, Double>() {
            public Double call(Double in) throws Exception {
                return in + 2;
            }
        });
        List<Double> douList = mapRdd.collect();
        for (Double d : douList) {
            System.out.println("d:" + d);
        }
    }
}


輸出結(jié)果：
d:3.0
d:6.0
d:5.0
d:9.0
d:7.0