Closed
Description
Code to reproduce:
scala> case class Data(id: Long, name: String)
scala> case class Item(id: Long, data: Data)
scala> spark.sql("create table local.db.test_table(id long, data struct<id: long, name: string>) using iceberg partitioned by (identity(data.name))").show()
scala> spark.range(5).map(i => Item(i, Data(i, s"${i}"))).writeTo("local.db.test_table").append()
scala> spark.sql("select data.name from local.db.test_table").show()
+----+
|name|
+----+
|null|
|null|
|null|
|null|
|null|
+----+
Metadata
Metadata
Assignees
Labels
No labels
Activity