https://community.cloudera.com/t5/Archives-of-Support-Questions/Is-Case-Statement-in-query-of-Spark-Sql-Ver-2-0-above-is/m-p/113580#M46825 <P>Works for me</P><PRE>print(s"Spark ${spark.version}") val df = spark.createDataFrame(Seq(( 2, 9), ( 1, 5),( 1, 1),( 1, 2),( 2, 8))) .toDF("y", "x") df.createOrReplaceTempView("test") spark.sql("select CASE WHEN y = 2 THEN 'A' ELSE 'B' END AS flag, x from test").show</PRE><P>Returns</P><PRE>Spark 2.0.0 df: org.apache.spark.sql.DataFrame = [y: int, x: int] +----+---+ |flag| x| +----+---+ | A| 9| | B| 5| | B| 1| | B| 2| | A| 8| +----+---+</PRE> Mon, 21 Nov 2016 19:54:30 GMT bwalter1 2016-11-21T19:54:30Z https://community.cloudera.com/t5/Archives-of-Support-Questions/Is-Case-Statement-in-query-of-Spark-Sql-Ver-2-0-above-is/m-p/113579#M46824 Mon, 21 Nov 2016 19:21:35 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Is-Case-Statement-in-query-of-Spark-Sql-Ver-2-0-above-is/m-p/113579#M46824 skatkar 2016-11-21T19:21:35Z https://community.cloudera.com/t5/Archives-of-Support-Questions/Is-Case-Statement-in-query-of-Spark-Sql-Ver-2-0-above-is/m-p/113580#M46825 <P>Works for me</P><PRE>print(s"Spark ${spark.version}") val df = spark.createDataFrame(Seq(( 2, 9), ( 1, 5),( 1, 1),( 1, 2),( 2, 8))) .toDF("y", "x") df.createOrReplaceTempView("test") spark.sql("select CASE WHEN y = 2 THEN 'A' ELSE 'B' END AS flag, x from test").show</PRE><P>Returns</P><PRE>Spark 2.0.0 df: org.apache.spark.sql.DataFrame = [y: int, x: int] +----+---+ |flag| x| +----+---+ | A| 9| | B| 5| | B| 1| | B| 2| | A| 8| +----+---+</PRE> Mon, 21 Nov 2016 19:54:30 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Is-Case-Statement-in-query-of-Spark-Sql-Ver-2-0-above-is/m-p/113580#M46825 bwalter1 2016-11-21T19:54:30Z