云計(jì)算
本篇文章給大家分享的是有關(guān)spark api編程中怎么以本地模式進(jìn)行spark api實(shí)戰(zhàn)map、filter，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。
首先以spark的本地模式測(cè)試spark api，以local的方式運(yùn)行spark-shell：
下面看下 filter操作：
我們用最正宗的scala函數(shù)式編程的風(fēng)格：
從結(jié)果 可以看出來，與之前那種分步奏方式結(jié)果是一樣的
但采用這種方式，即是復(fù)合scala風(fēng)格的寫法，也是符合spark的應(yīng)用程序風(fēng)格的寫法，在spark的編程中，大多數(shù)功能的實(shí)現(xiàn)都是只要一行代碼即可完成。
以上就是spark api編程中怎么以本地模式進(jìn)行spark api實(shí)戰(zhàn)map、filter，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見到或用到的。希望你能通過這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注箭頭云行業(yè)資訊頻道。