Sppary Array example

sparkcodegeeks · sparkcodegeeks · commit 1acd8f48d783 · 2020-07-14T21:00:03.000-07:00
diff --git a/src/main/scala/com/sparkbyexamples/spark/dataframe/functions/collection/ArrayOfString.scala b/src/main/scala/com/sparkbyexamples/spark/dataframe/functions/collection/ArrayOfString.scala
@@ -42,4 +42,9 @@ object ArrayOfString extends App{
 
   df3.toDF("Name","Languages","currentState")
      .show(false)
+
+  df.createOrReplaceTempView("ARRAY_STRING")
+  spark.sql("select name, concat_ws(',',languagesAtSchool) as languagesAtSchool," +
+    " currentState from ARRAY_STRING")
+    .show(false)
 }

Original file line number	Diff line number	Diff line change
`@@ -42,4 +42,9 @@ object ArrayOfString extends App{`
`42`	`42`
`43`	`43`	`df3.toDF("Name","Languages","currentState")`
`44`	`44`	`.show(false)`
	`45`	`+`
	`46`	`+ df.createOrReplaceTempView("ARRAY_STRING")`
	`47`	`+ spark.sql("select name, concat_ws(',',languagesAtSchool) as languagesAtSchool," +`
	`48`	`+ " currentState from ARRAY_STRING")`
	`49`	`+ .show(false)`
`45`	`50`	`}`