我正在尝试将一些计算列添加到SparkR数据框中,如下所示:(unix_timestamp$$anonfun$resolve$1.apply(DataFrame.scala:159)
at org.apache.spark.sql.DataFrame$$anonfun$resolve$1.apply(DataFrame.sca
expired")dateDiff是一个函数,用于计算partition_date和item_due_date之间的差异,后者是DF中的列如果是,如何将列值转换为字符串?(DataFrame.scala:2099)
at org.apache.spark.sql.DataFrame.head(DataFrame.
我正在尝试在sparkdataframe(scala)中进行过滤,以检查某列是否少于当天。CurrentDate))"message": "java.lang.RuntimeException: Unsupported literal type class org.apache.spark.sql.catalyst.expressions.CurrentDate
我正在尝试访问一个hive表,并从表/ dataframe中提取和转换某些列,然后将这些新列放到一个新的dataframe中。但是当我尝试运行它时,我会收到以下错误-
线程"main“中的异常:需求在org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveReferences(DataFrame.scala:133) at org.apache.spa