单项选择题
A.支持微批次处理B.默认使用微批次模式处理流数据C.数据抽象为DStreamD.基本思想是将流式数据相像成一张不断增长的表
以下哪个函数不可以传入updateStateByKey 算子?()A.lambda values,last :...
单项选择题以下哪个函数不可以传入updateStateByKey 算子?()
A.lambda values,last :sum(values)+(last or 0)B.lambda values :sum(values)C.lambda values,last=0:sum(values)+lastD.lambda values,last :sum(values)
读取本地或HDFS 上的文本文件,可以使用sparkContext 中的()方法。A.readTextB.ge...
单项选择题读取本地或HDFS 上的文本文件,可以使用sparkContext 中的()方法。
A.readTextB.getTextC.textReadD.textFile
在SparkSQL 中,当执行结构化API 时,Catalyst 优化器主要在哪个阶段发挥作用?()A.Par...
单项选择题在SparkSQL 中,当执行结构化API 时,Catalyst 优化器主要在哪个阶段发挥作用?()
A.Parsed Logical PlanB.Analyzed Logical PlanC.Optimized Logical PlanD.Physical Plan