Spark的延迟执行再理解

首先,大家可以猜测下如下代码的执行结果,是否会报错? val df = Seq((0, "ben", "student"),(1, "jim", "teacher")).toDF("id", "name", "job") val df2 = df.select("id", "name") val df3 = df2.filter("job = 'teacher'") // 是否会报错? df3.
相关文章
相关标签/搜索