下列不可以直接作为spatkStreaming数据源的是（）。

单项选择题下列关于累加器描述不正确的是（）。

A.实现所有分片处理时更新共享变量的功能。
B.工作节点上的任务不能访问累加器的值。
C.累加器是一个只读变量。
D.累加器中的共享变量会发往每一个Executor。

单项选择题下列关于rdd分区描述错误的是（）。

A.range
B.range robin
C.hash
D.自定义

单项选择题下列关于spark的cache算子默认缓存机制描述错误的是（）。

A.多次使用同一个RDD ，可以将该RDD缓存起来。
B.缓存的计算结果，可以在后期得到重用。
C.重用计算结果的前提是当前进程JVM不能停止工作。
D.将数据持久化到硬盘，使用时再加载的策略。

单项选择题下列关于spark 的local模式描述错误的是（）。

A.local[*]表示直接使用最大cpu核数。
B.不需要启动master和worker守护进程。
C.driver程序在应用程序结束后就会终止。
D.SparkSubmit进程只充当客户提交任务的Client进程。

单项选择题以下不支持用来编写spark程序的语言是（）。

A.Java
B.Python
C.Scala
D.C#

单项选择题下面哪个算子是Transformation算子？（）

A.collect
B.reduce
C.reduceByKey
D.countByKey

单项选择题spark读取一个200M的文件，生成的RDD会有几个分区？（）

A.1
B.2
C.3
D.4

单项选择题对Spark中RDD的描述，错误的是：（）。

A.RDD默认存储到内存中，内存不足时也会存储到磁盘中
B.RDD表示一批元素的集合
C.RDD中的数据是被分区的
D.RDD中的数据不会丢失

单项选择题spark的master和worker的作用错误的是？（）

A.master负责分配job
B.worker执行job
C.spark的计算是在内存中进行
D.spark的计算是在硬盘中进行

单项选择题哪个不是kafka的组件？（）

A.生产者
B.消费者
C.reduceByKey
D.kafka集群