相关考题
-
单项选择题
在Spark中，假设lines是一个DStream对象，以下哪个语句可以周期统计这个流上的单词数？（）
A.lines.flatMap（_.split”””））.map（word=>（word，1））.reduce（_+_）.print（）
B.lines.flatMap（_.split”””））.map（word=>（word，word.length（）））.reduceByKey（_+_）.print（）
C.lines.flatMap（_.split”””））.map（word=>（word，1））.reduceByKey（_+_）.print（）
D.lines.flatMap（_.split”””））.flatMap（word=>（word，1））.groupByKey（_+_）.print（） -
单项选择题
在Fusioninsight HD集群中，Flume不支持将采集数据写入到集群中哪个服务？（）
A.HDFS
B.HBase
C.Kafka
D.Redis -
多项选择题
Spark应用程序有哪几种参数设置方法？（）
A.在应用的配置文件Spark-defaults.conf中进行配置
B.在提交应用时，通过--conf 进行设置
C.在应用的代码里面，通过SparkContext的setProperty方法进行设置
D.在应用的代码里面，通过SparkerConf对象进行设置
