[Bug]: IcebergIO support name-based mapping for a schema

[regadas]

What happened?

Reading an Iceberg Table it's expected that the underlying data files contain field id's information. However this info might not be present when data files are managed/written by external systems.

To support this use case Iceberg Table spec has a property schema.name-mapping.default with a JSON name mapping containing a list of field mapping objects.

PR #33315 adds NameMapping read support

I spotted this, because I was getting the following error

org.apache.beam.sdk.util.UserCodeException: java.lang.NullPointerException: Cannot invoke "org.apache.parquet.schema.Type$ID.intValue()" because the return value of "org.apache.parquet.schema.Type.getId()" is null

Issue Priority

Priority: 2 (default / most bugs should be filed as P2)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Infrastructure
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner