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.復雜事物操作
B.計算器應用：例如統(tǒng)計某個網站的登錄人數
C.一條消息被多個消費者同時消費且保證消息被所有訂閱者成功消費的消息隊
D.取最新N個數據：例如對某條微博，獲取最新的10個評論
最新試題
Spark Streaming可以從Kafka接收數據并進行計算，計算結果只能存入HDFS，不能再寫回Kafka。（）
在Kafka中，關于Consumer說法正確的是（）。
關于Redis特點，下面敘述正確的是？（）
Fusionlnsight HD關于Oozie的作業(yè)操作命令，下列哪幾項敘述是正確的？（）
FusionlnsightHD系統(tǒng)中，關于HIve的JDBC接口類型，以下哪種敘述是正確的？（）
FusionLnsigt HD用戶想通過HBase shell操作來查詢某個HBase表中的內容，這中場景下推薦管理員給這個用戶分配一個機機賬號。（）
在Solr的應用查詢場景中，當對查詢結果深度翻頁時，需使用游標進行深度翻頁。下面對游標說法正確的是？（）
在通過Fusionlnsight manager界面創(chuàng)建用戶時，想要該用戶對所有Topic具有讀寫權限，但不具有常見Topic的權限，應該加入Kafka服務的那個組？（）
Fusionlnsight HD中，Streaming的特點？（）
用戶要開發(fā)一個應用去訪問HBase服務，先申請了一個機機賬號teste1，并給它設置訪問HBase服務的權限：然后下載該賬戶的keytab文件，并使用該賬號運行應用。后續(xù)此應用增加業(yè)務需求，需訪問Hive服務，那么在給tested用戶補充授予了訪問Hive組件權限后，需重新下載該用戶的keytab文件。（）