diff --git a/src/main/scala/com/github/mrpowers/spark/daria/sql/transformations.scala b/src/main/scala/com/github/mrpowers/spark/daria/sql/transformations.scala index e441fab4..64f0cc2e 100644 --- a/src/main/scala/com/github/mrpowers/spark/daria/sql/transformations.scala +++ b/src/main/scala/com/github/mrpowers/spark/daria/sql/transformations.scala @@ -331,7 +331,8 @@ object transformations { outputColName, get_json_object( col(colName), - path) + path + ) ) } diff --git a/src/test/scala/com/github/mrpowers/spark/daria/sql/TransformationsTest.scala b/src/test/scala/com/github/mrpowers/spark/daria/sql/TransformationsTest.scala index f6fe21c7..d661eeac 100644 --- a/src/test/scala/com/github/mrpowers/spark/daria/sql/TransformationsTest.scala +++ b/src/test/scala/com/github/mrpowers/spark/daria/sql/TransformationsTest.scala @@ -621,23 +621,23 @@ object TransformationsTest extends TestSuite with DataFrameComparer with ColumnC 'getJsonObject - { val bart = """ - |{ - | "name": "Bart cool", - | "info": { - | "age": 25, - | "gender": "male" - | } - |} + |{ + | "name": "Bart cool", + | "info": { + | "age": 25, + | "gender": "male" + | } + |} """.stripMargin val lisa = """ - |{ - | "name": "Lisa frost", - | "info": { - | "age": 27, - | "gender": "female" - | } - |} + |{ + | "name": "Lisa frost", + | "info": { + | "age": 27, + | "gender": "female" + | } + |} """.stripMargin val sourceDF = spark.createDF(