单项选择题
()是把相同key的DStream聚合在一起。
A.countB.flatMapC.filterD.reduceByKey
单项选择题 ()是用来统计DStream源的每个RDD中元素的个数。
单项选择题 ()是对DStream中符合条件(符合返回true,否则返回false)的流数据进行筛选并返回DStream类型。
单项选择题 ()是SparkStreaming提供的最基础的抽象。它表示一系列的数据流,这些数据流可能来自于原始的输入。