亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

spark簡單例子

發布時間:2020-09-15 22:40:43 來源:網絡 閱讀:495 作者:supersyd 欄目:大數據

一、統計指定索引的每個值有多少個:

var textFile = sc.textFile("/xxxx_orgn/p1_day=20170609/*.txt");

var pairRdd=textFile.filter(x=>x.split("\\|",-1).length>68).map{x=>val data=x.split("\\|",-1)(67); (data,1)}

var result=pairRdd.reduceByKey((sum,x)=>sum+x)

result.collect.foreach(println)


二、統計數據列數

var textFile = sc.textFile("/xxxx_orgn/p1_day=20170609/*.txt"); 

var pairRdd=textFile.map{x=>val data=x.split("\\|",-1).length; (data,1)}

var result=pairRdd.reduceByKey((sum,x)=>sum+x)

result.collect.foreach(println)


向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

富川| 渝中区| 安远县| 肃北| 汝州市| 奇台县| 西贡区| 观塘区| 西安市| 玛曲县| 井冈山市| 文登市| 阳泉市| 绥阳县| 理塘县| 长丰县| 那曲县| 大兴区| 射洪县| 德钦县| 华蓥市| 富民县| 石屏县| 秀山| 平塘县| 灵宝市| 孟津县| 兴国县| 虹口区| 和顺县| 乌鲁木齐市| 丹棱县| 武夷山市| 朝阳区| 阿克陶县| 剑河县| 沙坪坝区| 读书| 凤山县| 万荣县| 天等县|