将名称设置为RDD的优点

Sha*_*shi 5 scala apache-spark

有可用于为RDD分配名称的API.

例如

val y = sc.parallelize(List(1,2,3))
y.setName("New Name")
Run Code Online (Sandbox Code Playgroud)

它的优点是什么?在Spark中可以使用此功能的任何特定原因?

提前致谢.

Mar*_*ier 11

缓存它时,您可以在"存储"选项卡上的Spark Web UI中看到该名称.