你可能感興趣的試題

Spark Streaming中批處理時(shí)間間隔是指（）

A.系統(tǒng)將獲取到的數(shù)據(jù)流封裝成一個(gè)RDD的時(shí)間間隔
B.系統(tǒng)對(duì)數(shù)據(jù)流進(jìn)行統(tǒng)計(jì)分析的時(shí)間間隔
C.系統(tǒng)對(duì)數(shù)據(jù)流進(jìn)行統(tǒng)計(jì)分析的頻率
D.系統(tǒng)作業(yè)處理的周期

單項(xiàng)選擇題

下列哪個(gè)操作能夠?qū)崿F(xiàn)“基于窗口將DStream[（K，V）]中的值V按鍵K使用聚合函數(shù)func聚合得到新的DStream”（）

A.count
B.reduceByKeyAndWidow
C.countByValue
D.reduceByKey

在Spark中，DAGScheduler的輸出形式為（）

你可能感興趣的試題

Spark Streaming中批處理時(shí)間間隔是指（）

下列哪個(gè)操作能夠?qū)崿F(xiàn)“基于窗口將DStream[（K，V）]中的值V按鍵K使用聚合函數(shù)func聚合得到新的DStream”（）

在Spark中，DAGScheduler的輸出形式為（）