Use the when() and otherwise() functions. For example: import org.apache.spark.sql.functions._
val rows = Seq(("bob", 1), ("lucy", 2), ("pat", 3)).toDF("name", "genderCode") rows.show +----+----------+ |name|genderCode| +----+----------+ | bob| 1| |lucy| 2| | pat| 3| +----+----------+ rows .withColumn("genderString", when('genderCode === 1, "male").otherwise(when('genderCode === 2, "female").otherwise("unknown"))) .show +----+----------+------------+ |name|genderCode|genderString| +----+----------+------------+ | bob| 1| male| |lucy| 2| female| | pat| 3| unknown| +----+----------+------------+ On Sun, Nov 27, 2016 at 10:45 PM, Hitesh Goyal <hitesh.go...@nlpcaptcha.com> wrote: > Hi team, > > I am using Apache spark 1.6.1 version. In this I am writing Spark SQL > queries. I found 2 ways of writing SQL queries. One is by simple SQL syntax > and other is by using spark Dataframe functions. > > I need to execute if conditions by using dataframe functions. Please specify > how can I do that. > > > > Regards, > > Hitesh Goyal > > Simpli5d Technologies > > Cont No.: 9996588220 > > --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org