spark action之saveastextfile

java

/** 
 *saveastextfile 把rdd中的数据保存到文件中,只能指定文件夹
 *@author Tele
 *
 */
public class SaveasTextFileDemo1 {
    private static SparkConf conf = new SparkConf().setMaster("local").setAppName("saveastextfiledemo1");
    private static JavaSparkContext jsc = new JavaSparkContext(conf);

    public static void main(String[] args) {
        List<Tuple2<String,Integer>> list = Arrays.asList(
                new Tuple2<String,Integer>("tele",100),
                new Tuple2<String,Integer>("tele",200),
                new Tuple2<String,Integer>("tele",300),
                new Tuple2<String,Integer>("yeye",50),
                new Tuple2<String,Integer>("yeye",10),
                new Tuple2<String,Integer>("yeye",70),
                new Tuple2<String,Integer>("wyc",10000)
                 );

        JavaPairRDD<String, Integer> rdd = jsc.parallelizePairs(list);
        
        //保存到本地
        rdd.saveAsTextFile("./src/main/resources/local");
        jsc.close();
    }    
}

scala

object SaveasTextFileDemo {
    def main(args: Array[String]): Unit = {
      val conf = new SparkConf().setMaster("local").setAppName("saveastextfiledemo");
      val sc = new SparkContext(conf);
      
      val arr = Array(("class1","tele"),("class1","yeye"),("class2","wyc"));
    
      val rdd = sc.parallelize(arr,1);
      
      rdd.saveAsTextFile("./src/main/resources/myfile")
      
    }
}