单项选择题
()是用来统计DStream源的每个RDD中元素的个数。
A.countB.flatMapC.filterD.reduceByKey
单项选择题 ()是对DStream中符合条件(符合返回true,否则返回false)的流数据进行筛选并返回DStream类型。
单项选择题 ()是SparkStreaming提供的最基础的抽象。它表示一系列的数据流,这些数据流可能来自于原始的输入。
单项选择题 在使用SparkStreaming进行流处理之前需要进行初始化,必须创建一个()流上下文对象。