Description
spark.sql( """ |CREATE TABLE `tab1` |(`custom_fields` ARRAY<STRUCT<`id`: BIGINT, `value`: STRING>>) |USING parquet """.stripMargin) spark.sql( """ |INSERT INTO `tab1` |SELECT ARRAY(named_struct('id', 1, 'value', 'a'), named_struct('id', 2, 'value', 'b')) """.stripMargin) spark.sql("SELECT custom_fields.id, custom_fields.value FROM tab1").show()
The returned result is wrong:
Row(Array(2, 2), Array("b", "b"))