diff --git a/core/src/main/scala/com/github/mrpowers/spark/daria/sql/types/StructTypeHelpers.scala b/core/src/main/scala/com/github/mrpowers/spark/daria/sql/types/StructTypeHelpers.scala index dee701e..d51d049 100644 --- a/core/src/main/scala/com/github/mrpowers/spark/daria/sql/types/StructTypeHelpers.scala +++ b/core/src/main/scala/com/github/mrpowers/spark/daria/sql/types/StructTypeHelpers.scala @@ -57,7 +57,7 @@ object StructTypeHelpers { ).as(field.name) ): _* ).as(childFieldName) - case ArrayType(innerType, _) => + case ArrayType(innerType, _) => transform(parentCol, childCol => childFieldToCol(innerType, childFieldName, childCol)).as(childFieldName) case _ if firstLevel => parentCol case _ if !firstLevel => parentCol(childFieldName)