單項(xiàng)選擇題關(guān)于DStream窗口操作函數(shù),以下說(shuō)法錯(cuò)誤的是()

A.window()返回基于源DStream的窗口進(jìn)行批計(jì)算后的一個(gè)新的Dstream
B.countByWindow()返回基于滑動(dòng)窗口的DStream中的元素?cái)?shù)
C.reduceByWindow()做聚合操作并返回一個(gè)新的Dstream
D.以上說(shuō)法都不對(duì)


您可能感興趣的試卷

你可能感興趣的試題

2.單項(xiàng)選擇題DStream的輸出操作,不包括()

A.foreachRDD(func)
B.print()
C.flatMap(func)
D.saveAsTextFiles(prefix)

3.單項(xiàng)選擇題Kafka的消息壓縮算法可以選擇的方式是()

A.GZIP
B.Snappy
C.LZ4
D.所有以上

4.單項(xiàng)選擇題Kafka的消費(fèi)者在處理消息時(shí)可以選擇的模式是()

A.單線程模式
B.多線程模式
C.分布式模式
D.并行模式

5.單項(xiàng)選擇題Kafka的生產(chǎn)者在發(fā)送消息時(shí)可以選擇的傳遞方式是()

A.同步傳遞
B.異步傳遞
C.并行傳遞
D.串行傳遞