spark sql里怎么用case when?

  统计/机器学习 Python sql    浏览次数:2683        分享
0

spark sql有没有类似mysql里的case when?怎么用?

 

古力夬   2019-12-23 15:17



   1个回答 
2

spark里可以用when和otherwise的组合,比如在pyspark里

from pyspark.sql import functions as F
df.select(F.col('score'), F.when(F.col('age') > 4, 1).when(F.col('age') < 3, -1).otherwise(0)).show()


SofaSofa数据科学社区DS面试题库 DS面经

我小宋   2019-12-26 10:13



  相关主题

pyspark里转成整数型报错TypeError: unexpected type:   1回答

spark里怎么refresh表?   3回答

怎么对pyspark.sql.dataframe按照某一列降序排列?   1回答

返回pyspark dataframe的行数?   1回答

pyspark返回每个分组某个值最大的行   1回答

pyspark里如何进行SELECT DISTINCT操作?   1回答

得到一个pyspark.sql.dataframe中所有列的名称   2回答

pyspark里怎么把类似‘yyyy-mm-dd‘的字符串转成星期几的形式?   1回答

怎么用pyspark取出hive表里的json串中某一个key的值?   1回答

pyspark里怎么把一列日期转成是全年的第几周?   2回答

怎么对pyspark dataframe里的空缺值填值?   1回答

如何对pyspark dataframe删除一列   3回答



回答问题时需要注意什么?

我们谢绝在回答前讲“生动”的故事。

我们谢绝“这么简单,你自己想”、“书上有的,你认真看”这类的回答;如果你认为对方的提问方式或者内容不妥,你可以直接忽略该问题,不用进行任何作答,甚至可以对该问题投反对票。

我们谢绝答非所问。

我们谢绝自己不会、硬要回答。

我们感激每一个用户在编写答案时的努力与付出!