2016-11-28 43 views
0

我对这些是办法看到,已以星火shell环境被创建为[238]星火匿名函数字节码

org.apache.spark.rdd.RDD[String] = MapPartitionsRDD[238]匿名类的字节码好奇。

+0

为什么您需要字节码?你想达到什么目的? –

+0

原因主要是好奇心。在Spark Web UI上检查DAGScheduler有时会给我一个3个匿名类的链,只是为了一个简单的'.map'。我觉得列出这些匿名课程没有提供任何细节是没用的。 –

回答

0

MapPartitionsRDD[238]意味着这是在此上下文中创建的第239个RDD(从0开始)。这并不意味着创建了匿名类。

SparkContext保存关于此上下文中RDD数量的信息