Spark API編程動(dòng)手實(shí)戰(zhàn)-01-以本地模式進(jìn)行Spark API實(shí)戰(zhàn)map、filter和collect

首先以spark的本地模式測試spark API，以local的方式運(yùn)行spark-shell：

先從parallelize入手吧：

map操作后結(jié)果：

下面看下 filter操作：

filter履行結(jié)果：

我們用最正宗的scala函數(shù)式編程的風(fēng)格：

履行結(jié)果：

從結(jié)果 可以看出來，與之前那種分步奏方式結(jié)果是1樣的

但采取這類方式，即是復(fù)合scala風(fēng)格的寫法，也是符合spark的利用程序風(fēng)格的寫法，在spark的編程中，大多數(shù)功能的實(shí)現(xiàn)都是只要1行代碼便可完成。

生活不易，碼農(nóng)辛苦
如果您覺得本網(wǎng)站對您的學(xué)習(xí)有所幫助,可以手機(jī)掃描二維碼進(jìn)行捐贈(zèng)