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)計某個網站的登錄人數(shù)
C.一條消息被多個消費者同時消費且保證消息被所有訂閱者成功消費的消息隊
D.取最新N個數(shù)據(jù)：例如對某條微博，獲取最新的10個評論
最新試題
Fusionlnsigt HD的Hive組件可以運行在哪些分布式計算機框架上？（）
在HBase表設計中，對于多項業(yè)務共用rowkey，導致數(shù)據(jù)訪問矛盾的情況，可以有哪些應對策略？（）
Fusionlnsight HD中，一個部署在Tomcat上的應用，需訪問HBase服務，這種場景下推薦使用機機賬號。（）
Spark Streaming可以從Kafka接收數(shù)據(jù)并進行計算，計算結果只能存入HDFS，不能再寫回Kafka。（）
關于Redis特點，下面敘述正確的是？（）
用戶要開發(fā)一個應用去訪問HBase服務，先申請了一個機機賬號teste1，并給它設置訪問HBase服務的權限：然后下載該賬戶的keytab文件，并使用該賬號運行應用。后續(xù)此應用增加業(yè)務需求，需訪問Hive服務，那么在給tested用戶補充授予了訪問Hive組件權限后，需重新下載該用戶的keytab文件。（）
Fusionlnsight HD系統(tǒng)中，Solr示例工程solr-example\confisolr-confisolr.properties中ZK_URL和ZOOKEEPER_DEFAULT_SERVER_PRINCIPAL的值可以從下面哪個選項獲?。浚ǎ?/p>
Fiume支持實時采集數(shù)據(jù)的source類型是哪項？（）
在MapReduce應用程序開發(fā)中，setMapOutputCompressorClass類的作用是什么？（）
在Spark應用開發(fā)中，以下哪項的代碼能正確進行單詞統(tǒng)計？（）