Skip to content

Commit f171784

Browse files
committed
Try and break up long 'Row' stmnt
1 parent 92036da commit f171784

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/main/scala/com/high-performance-spark-examples/dataframe/HappyPandas.scala

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -149,7 +149,12 @@ object HappyPandas {
149149
val pandaInfo = pandaPlace.explode(pandaPlace("pandas")){
150150
case Row(pandas: Seq[Row]) =>
151151
pandas.map{
152-
case Row(id: Long, zip: String, pt: String, happy: Boolean, attrs: Seq[Double]) =>
152+
case (Row(
153+
id: Long,
154+
zip: String,
155+
pt: String,
156+
happy: Boolean,
157+
attrs: Seq[Double])) =>
153158
RawPanda(id, zip, pt, happy, attrs.toArray)
154159
}}
155160
pandaInfo.select(

0 commit comments

Comments
 (0)