zoukankan      html  css  js  c++  java
  • <console>:29: error: overloaded method value join with alternatives:(right: org.apache.spark.sql.Dataset[_],joinExprs: org.apache.spark.sql.Column)org.apache.spark.sql.DataFrame <and>

    在scala中执行如下代码,报 join 错误!!

    scala> val data = itemTotalTime.join(totalTime, "userId")
    

      错误日志如下:

    <console>:29: error: overloaded method value join with alternatives:
      
      (right: org.apache.spark.sql.Dataset[_],usingColumns: Seq[String])org.apache.spark.sql.DataFrame <and>
      (right: org.apache.spark.sql.Dataset[_],usingColumn: String)org.apache.spark.sql.DataFrame
     cannot be applied to (Unit, String)
               val data = itemTotalTime.join(totalTime, "userId")
                                        ^
    

      

    分析:应该是join的一边是DataFram 一边是Dataset 的原因,我把这两个 itemTotalTime、totalTime 都  .toDF 了一下就好了

    --------------------------------记录一下---------------------------------

  • 相关阅读:
    北京集训:20180325
    北京集训:20180323
    北京集训:20180321
    北京集训:20180320
    Bzoj5209[Tjoi2012]防御:姿势题
    北京集训:20180318
    北京集训:20180316
    北京集训:20180314
    北京集训:20180313
    Bzoj4818:生成函数 快速幂
  • 原文地址:https://www.cnblogs.com/singleYao/p/13912338.html
Copyright © 2011-2022 走看看