java - 线程“主”org.apache.spark.sql.AnalysisException 中的异常：无法解析列

Question

我有以下数据框：

+-------------+
|limit_speed  |
+-------------+
|30           |
|40           |
+-------------+

我做了以下代码：

Dataset<Row> data = df.withColumn("vtmp",lit(40));

我得到以下数据框：

+---------------+--------------+
|limit_speed    |vtmp          |
+---------------+--------------+
|30             |40            |
|40             |40            |
+---------------+--------------+

当我尝试以下代码时：

data.filter(col("vtmp").gt(col("limit_speed")));

我收到以下错误：

Exception in thread "main" org.apache.spark.sql.AnalysisException: cannot resolve '`vtmp`' given input columns:.........

谢谢

标签： javaapache-sparkfilter