关于 RDD.cache() 持久化是否需要接受返回值的疑问？

问题描述：

视频中老师有说到 .cache() 必须要有一个引用接收，如果没有定义 cache() 方法返回的值的话，cache 是无效的，但是我在实际代码测试中发现，好像不需要接收返回值，是可以 rdd.cache() 直接调用的

老师视频中的意思是必须：val rdd = sc.parallelize(1 to 10).map(...).cache()

我的意思是可以：val rdd = sc.parallelize(1 to 10).map(...)

                           rdd.cache()

实测代码如下

val sparkConf = new SparkConf()
  .setMaster("local")
  .setAppName(this.getClass.getName)
val sc = new SparkContext(sparkConf)

val rdd = sc.parallelize(1 to 5).map(i => {
  println("正在 map i " + i)
  i * 2
})

rdd.cache()

rdd.foreach(i => print(i))
println("cached 上面是第一次打印（map 函数会执行，会打印 正在 map i）==============")
rdd.foreach(i => print(i))
println("cached 上面是第二次打印，rdd 已经被缓存了，map 函数不会被执行==============")

rdd.unpersist()

rdd.foreach(i => print(i))
println("unpersist 上面是第三次，清空了缓存，所以 map 函数又会执行，会打印 正在 map i）==============")

sc.stop()

日志输出

正在 map i 1
正在 map i 2
正在 map i 3
正在 map i 4
正在 map i 5
246810
cached 上面是第一次打印（map 函数会执行，会打印 正在 map i）==============
246810
cached 上面是第二次打印，rdd 已经被缓存了，map 函数不会被执行==============
正在 map i 1
正在 map i 2
正在 map i 3
正在 map i 4
正在 map i 5
246810
unpersist 上面是第三次，清空了缓存，所以 map 函数又会执行，会打印 正在 map i）==============