下面spark代码执行时,会读取几次file文件  &...
发布于 2022-03-03 16:53:17
下面spark代码执行时,会读取几次file文件
val raw = sc.textFile(file)
val pvLog = raw.filter(isPV(_))
val clLog = raw.filter(isCL(_))
val baseRDD = pvLog.union(clLog)
val baseRDD.count()
val raw = sc.textFile(file)
val pvLog = raw.filter(isPV(_))
val clLog = raw.filter(isCL(_))
val baseRDD = pvLog.union(clLog)
val baseRDD.count()
登录后免费查看答案
关注者
0
被浏览
39