File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 729729 ["special string" ],
730730 Record (** {"special#string#field" : "special string" }), # type: ignore
731731 "special%23string%23field=special%20string" ,
732- f"""CREATE TABLE { identifier } (
733- `special#string#field` string
734- )
735- USING iceberg
736- PARTITIONED BY (
737- identity(`special#string#field`)
738- )
739- """ ,
740- f"""INSERT INTO { identifier }
741- VALUES
742- ('special string')
743- """ ,
732+ # Spark currently writes differently to PyIceberg w.r.t special column name sanitization so justification
733+ # (comparing expected value with Spark behavior) would fail: PyIceberg produces
734+ # Record[special_x23string_x23field='special string'], not Record[special#string#field='special string'].
735+ None ,
736+ None ,
737+ # f"""CREATE TABLE {identifier} (
738+ # `special#string#field` string
739+ # )
740+ # USING iceberg
741+ # PARTITIONED BY (
742+ # identity(`special#string#field`)
743+ # )
744+ # """,
745+ # f"""INSERT INTO {identifier}
746+ # VALUES
747+ # ('special string')
748+ # """,
744749 ),
745750 ],
746751)
You can’t perform that action at this time.
0 commit comments