Spark scala api(一)RDD编程

基础 初始化spark val conf = new SparkConf().setAppName("wordcount") val sc = new SparkContext(conf) 转化操做和行动操做的区别在于spark计算rdd的方式不一样,只有在第一次在一个行动操做中用到转化操做中的rdd时,才会真正计算这些rdd。web 建立rdd // 驱动器程序对一个集合进行并行化 val li
相关文章
相关标签/搜索