线程“main”java.lang.IllegalArgumentException中出现异常：需求失败
在这里，我试图将时间戳动态地添加到数据帧中，
{“action”：“event”,“id”：1173,“lat”：0.0,“lon”：0.0,“rollid”：55,“event”：“type”,“ccd”：0,“fone”：“ione”,“version”：“10.1”,“item”：“shack”}
在上面传入的数据中，我试图用下面的代码附加时间戳
foreachRDD(rdd=>
74 {
75 val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
76 import sqlContext.implicits._
77 val dataframe =sqlContext.read.json(rdd.map(_._2)).toDF()
78 import org.apache.spark.sql.functions._
79 val newDF=dataframe.withColumn("Timestamp_val",current_timestamp())
80 newDF.show()
81 newDF.printSchema()
我哪里出了问题，请帮帮我。
共有1个答案
从stackoverflow聊天中了解到，
修好了，像这样。
df.withColumn("current_time",lit(CurrentDate))
作为。WithColumn（）中的第二个参数，将需要一个命名列和
val newDF=dataframe.withColumn("Timestamp_val",current_timestamp())
-
我在线程“main”java中遇到异常。错误：未解析编译。 我做错了什么？ 线程“main”中出现异常： java.lang.错误：未解决的编译问题： 对于类型在
-
我从GitHub克隆了我的项目，现在我无法运行我的项目。 我收到以下错误： 知道是什么导致了这个错误吗？ 编辑 我检查了这个问题Intellij在我发布到这里之前突然抛出ClassNotFoundException，它没有给我任何解决方案...为什么要将我的问题标记为重复，因为那个问题不能解决我的问题？
-
我得到了这个错误： 线程“main”Java.lang.NosuchFielderRror：calificacion.main处的num1异常(problema_3.Java：17） 在这个简单的终端Java程序上键入第一个值后： 另一方面，这一个运行良好，我使用相同的输入法在这两个： 提前道谢。
-
当我从nextInt（）获取输入时，扫描器会抛出异常，但是如果我从nextLine（）获取输入，然后将其解析为int，那么我的代码会正常运行。 如果可以将字符串输入解析为任何类型，为什么还要使用nextInt（）或nextDouble（）。
-
每当我运行这个函数时，函数与.nextint()中的
-
你好，我正在Lucene上工作，以索引我的数据库记录，但我无法解决这个错误。 错误：