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（_+_）
您可能感興趣的試卷
你可能感興趣的試題
A.taildir
B.Log4j
C.JMS
D.Thrift
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è)上
A.復(fù)雜事物操作
B.計(jì)算器應(yīng)用：例如統(tǒng)計(jì)某個網(wǎng)站的登錄人數(shù)
C.一條消息被多個消費(fèi)者同時消費(fèi)且保證消息被所有訂閱者成功消費(fèi)的消息隊(duì)
D.取最新N個數(shù)據(jù)：例如對某條微博，獲取最新的10個評論
最新試題
FusionlnsightHD系統(tǒng)中，關(guān)于HIve的JDBC接口類型，以下哪種敘述是正確的？（）
關(guān)于Redis特點(diǎn)，下面敘述正確的是？（）
FusionLnsigh HD，Oozie支持HDFS Action。（）
在HBase表設(shè)計(jì)中，對于多項(xiàng)業(yè)務(wù)共用rowkey，導(dǎo)致數(shù)據(jù)訪問矛盾的情況，可以有哪些應(yīng)對策略？（）
關(guān)于Kafka的Producer，如下說法正確的是？（）
FusionLnsigt HD用戶想通過HBase shell操作來查詢某個HBase表中的內(nèi)容，這中場景下推薦管理員給這個用戶分配一個機(jī)機(jī)賬號。（）
在Kafka中，如下關(guān)于Producer發(fā)送數(shù)據(jù)的說法錯誤的是？（）
Spark Streaming可以從Kafka接收數(shù)據(jù)并進(jìn)行計(jì)算，計(jì)算結(jié)果只能存入HDFS，不能再寫回Kafka。（）
關(guān)于Kafka的特點(diǎn)如下᧿述正確的是？（）
Fusionlnsight HD中，一個部署在Tomcat上的應(yīng)用，需訪問HBase服務(wù)，這種場景下推薦使用機(jī)機(jī)賬號。（）