[Iceberg] Random bugs in Iceberg Catalog model

[MingshiPeng]

Bugs

• https://github.com/ray-project/deltacat/blob/2.0/deltacat/storage/iceberg/model.py#L488-L489
  • obj -> obj.arrow
• https://github.com/ray-project/deltacat/blob/2.0/deltacat/storage/iceberg/model.py#L505-L507
  • linked_schema_id attribute not found

• deltacat/deltacat/storage/iceberg/model.py

  Line 346 in 5a56390

  fields = [PartitionKeyMapper.unmap(key, schema, case_sensitive) for key in obj]

  • obj -> obj.keys

• deltacat/deltacat/storage/iceberg/model.py

  Lines 600 to 618 in 5a56390

  	locator = TableLocatorMapper.map(obj.identifier)
  	return Table.of(
  	locator=locator,
  	description=None,
  	properties=None,
  	native_object=obj,
  	)
  	class TableVersionLocatorMapper(OneWayModelMapper[IcebergTable, TableVersionLocator]):
  	@staticmethod
  	def map(
  	obj: Optional[IcebergTable], timestamp: Optional[int] = None, **kwargs
  	) -> Optional[TableVersionLocator]:
  	if obj is None:
  	return None
  	table_version = _resolve_table_version(obj.metadata, timestamp)
  	return TableVersionLocator.of(
  	table_locator=TableLocatorMapper.map(obj.identifier),

  • obj.identifier -> obj.name()

• deltacat/deltacat/storage/iceberg/model.py

  Line 173 in 5a56390

  return next(schema for schema in meta.schemas if schema.id == schema_id)

  • schema.id -> schema.schema_id