2. 科技
    3. Spark SQL的selectExpr用法

    Spark SQL的selectExpr用法

    科技2022-07-11  118

    转载：http://ddrv.cn/a/248617

    两者等价,可看作把sql语句直接拿来使用

    df1.selectExpr("*","(DEST_COUNTRY_NAME = ORIGIN_COUNTRY_NAME) as withincountry").show(5) spark.sql("select * , (DEST_COUNTRY_NAME = ORIGIN_COUNTRY_NAME) as withincountry from dfTable limit 5")
    Processed: 0.009, SQL: 8