Spark scala api(一)RDD編程

基礎 初始化spark val conf = new SparkConf().setAppName("wordcount") val sc = new SparkContext(conf) 轉化操做和行動操做的區別在於spark計算rdd的方式不一樣,只有在第一次在一個行動操做中用到轉化操做中的rdd時,纔會真正計算這些rdd。web 建立rdd // 驅動器程序對一個集合進行並行化 val li
相關文章
相關標籤/搜索