网友您好， 请在下方输入框内输入要搜索的题目：

题目内容 （请给出正确答案）
SparkStreming中()函数可以对源DStream中的每一个元素应用func方法进行计算,如果func函数返回结果为true,则保留该元素,否则丢弃该元素,返回一个新的Dstream。

A.union

B.map

C.flatMap

D.filter

参考答案

更多 “ SparkStreming中()函数可以对源DStream中的每一个元素应用func方法进行计算,如果func函数返回结果为true,则保留该元素,否则丢弃该元素,返回一个新的Dstream。 A.unionB.mapC.flatMapD.filter ” 相关考题
考题 SparkStreming中()函数可以对源DStream的每个元素通过函数func被映射出0或者更多的输出元素。 A.unionB.mapC.flatMapD.filter
查看答案
考题 SparkStreming中()函数可以通过对源DStream的每RDD应用RDD－to－RDD函数返回一个新的DStream,这可以用来在DStream做任意RDD操作。 A.transB.reduceC.joinD.cogroup
查看答案
考题 Dstream窗口操作中()方法基于滑动窗口对源DStream中的元素进行聚合操作,得到一个新的Dstream。 A.windowB.reduceByWindowC.reduceByKeyAndWindowD.countByWindow
查看答案
考题 SparkStreming中()函数当被调用的两个DStream分别含有K,V和K,W键值对时,返回一个K,Seq[V],Seq[W]类型的新的DStream。 A.unionB.reduceC.joinD.cogroup
查看答案
考题 SparkStreming中()函数当被调用类型分别为(K,V)和(K,W)键值对的2个DStream时,返回类型为(K,(V,W))键值对的一个新DStream。 A.unionB.reduceC.joinD.cogroup
查看答案
考题 PairRDD中groupBy(func)func返回key,传入的RDD的各个元素根据这个key进行分组。() 此题为判断题(对，错)。
查看答案
考题 下列关于常见的动作（Action）和转换（Transformation）操作的API解释错误的是A．count()：返回数据集中的元素个数B．filter(func)：筛选出满足函数func的元素，并返回一个新的数据集C．take(n)：返回数据集中的第n个元素D．map(func)：将每个元素传递到函数func中，并将结果返回为一个新的数据集
查看答案
考题 重复元素判定：编写一个函数，接受列表作为参数，如果一个元素在列表中出现了不止一次，则返回true，但不要改变原来列表的值。同时编写调用这个函数和测试结果的程序。
查看答案
考题 下列关于常见的动作（Action）和转换（Transformation）操作的API解释错误的是（)A．count()：返回数据集中的元素个数B．filter(func)：筛选出满足函数func的元素，并返回一个新的数据集C．take(n)：返回数据集中的第n个元素D．map(func)：将每个元素传递到函数func中，并将结果返回为一个新的数据集
查看答案
热门标签
最新试卷