spark sql有没有类似mysql里的case when?怎么用?
1个回答
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()
spark sql有没有类似mysql里的case when?怎么用?
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()