操作过程:
val playCount = spark.sql(sqlPlay) //.cache() val preview=playCount.filter("item_type like '%-P'") val record1=playCount.except(preview) 上面这句从一个对象获取另外一批的df 使用except方法就报错,改为下面这样就通过了 //val record=playCount.filter("item_type in ('FTD','RTD')")
操作过程:
val playCount = spark.sql(sqlPlay) //.cache() val preview=playCount.filter("item_type like '%-P'") val record1=playCount.except(preview) 上面这句从一个对象获取另外一批的df 使用except方法就报错,改为下面这样就通过了 //val record=playCount.filter("item_type in ('FTD','RTD')")