第五章_Spark核心编程_Rdd_行动算子_save oprator

本文主要是介绍第五章_Spark核心编程_Rdd_行动算子_save oprator，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

1.定义

  /*
* 1.定义
*     def saveAsTextFile(path: String): Unit
*     def saveAsObjectFile(path: String): Unit
*     def saveAsSequenceFile(
*             path: String,
*             codec: Option[Class[_ <: CompressionCodec]] = None): Unit
* 2.功能
*     将数据保存到不同格式的文件中
* 3.note
*     saveAsTextFile : 保存文本文件
*     saveAsObjectFile : 保存对象序列化字节文件
*     saveAsSequenceFile : 保存SequenceFile文件
* */

2.示例

  object saveTest extends App {

    val sparkconf: SparkConf = new SparkConf().setMaster("local").setAppName("distinctTest")

    val sc: SparkContext = new SparkContext(sparkconf)

    private val rdd = sc.makeRDD(List((1,"x"),(1,"x"),(2,"x"),(2,"x"),(2,"x")), 2)

    rdd.saveAsTextFile("Spark_319/src/output/01")
    rdd.saveAsObjectFile("Spark_319/src/output/02")
    rdd.saveAsSequenceFile("Spark_319/src/output/03")

    sc.stop()
  }

这篇关于第五章_Spark核心编程_Rdd_行动算子_save oprator的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！