單項(xiàng)選擇題在Spark應(yīng)用開(kāi)發(fā)中,以下哪項(xiàng)的代碼能正確進(jìn)行單詞統(tǒng)計(jì)?()

A.valcounts=textFile.map(line=>line.split(“”)).map(-rd=>(word,1)).reduceByKey(_+_)
B.valcounts=textFile.flatMap(line=>line.split(“”)).map(word=>(word,1)).reduceByKey(_+_)
C.valcounts=textFile.map(line=>line.split(“”)).map(word=>(word,1)).groupByKey(_+_)
D.valcounts=textFile.flatMap(line=>line.split(“”)).map(word=>(word,1)).groupByKey(_+_)


您可能感興趣的試卷

你可能感興趣的試題

4.多項(xiàng)選擇題Fusionlnsight HD關(guān)于Oozie的作業(yè)操作命令,下列哪幾項(xiàng)敘述是正確的?()

A.submit命令可以讓作業(yè)的狀態(tài)變?yōu)镻REP
B.statr命令可以讓PREP狀態(tài)的作業(yè)變?yōu)镽UNNING
C.run命令可以讓作業(yè)狀態(tài)變?yōu)镽unning
D.kill命令可以作用在PREP/SUSPEND/RUNNING狀態(tài)的作業(yè)上

5.多項(xiàng)選擇題Redis不適用與下面那些場(chǎng)景?()

A.復(fù)雜事物操作
B.計(jì)算器應(yīng)用:例如統(tǒng)計(jì)某個(gè)網(wǎng)站的登錄人數(shù)
C.一條消息被多個(gè)消費(fèi)者同時(shí)消費(fèi)且保證消息被所有訂閱者成功消費(fèi)的消息隊(duì)
D.取最新N個(gè)數(shù)據(jù):例如對(duì)某條微博,獲取最新的10個(gè)評(píng)論

最新試題

FusionLnsigh HD,Oozie支持HDFS Action。()

題型:判斷題

以下業(yè)務(wù)應(yīng)用中,哪個(gè)不是Hive適用的場(chǎng)景?()

題型:?jiǎn)雾?xiàng)選擇題

Fusionlnsight HD大數(shù)據(jù)平臺(tái)提供了哪些分布式計(jì)算框架?()

題型:多項(xiàng)選擇題

Redis不適用與下面那些場(chǎng)景?()

題型:多項(xiàng)選擇題

在通過(guò)Fusionlnsight manager界面創(chuàng)建用戶時(shí),想要該用戶對(duì)所有Topic具有讀寫權(quán)限,但不具有常見(jiàn)Topic的權(quán)限,應(yīng)該加入Kafka服務(wù)的那個(gè)組?()

題型:?jiǎn)雾?xiàng)選擇題

由于Spark是基于內(nèi)存的計(jì)算引擎,因此,一個(gè)Spark應(yīng)用可以處理的數(shù)據(jù)量不能超過(guò)分給這個(gè)Spark應(yīng)用的內(nèi)存總和。()

題型:判斷題

在HBase表設(shè)計(jì)中,對(duì)于多項(xiàng)業(yè)務(wù)共用rowkey,導(dǎo)致數(shù)據(jù)訪問(wèn)矛盾的情況,可以有哪些應(yīng)對(duì)策略?()

題型:多項(xiàng)選擇題

在Solr的應(yīng)用查詢場(chǎng)景中,當(dāng)對(duì)查詢結(jié)果深度翻頁(yè)時(shí),需使用游標(biāo)進(jìn)行深度翻頁(yè)。下面對(duì)游標(biāo)說(shuō)法正確的是?()

題型:多項(xiàng)選擇題

Oozie的workflow.xml文件是工作流配置文件。()

題型:判斷題

關(guān)于Redis特點(diǎn),下面敘述正確的是?()

題型:多項(xiàng)選擇題