feat: add snapshot update

Author: zhjwpku

src/iceberg/table.cc

@@ -46,6 +46,8 @@ Table::Table(TableIdentifier identifier, std::shared_ptr<TableMetadata> metadata
 
 const std::string& Table::uuid() const { return metadata_->table_uuid; }
 
+int8_t Table::format_version() const { return metadata_->format_version; }
+
 Status Table::Refresh() {
   if (!catalog_) {
     return NotSupported("Refresh is not supported for table without a catalog");

src/iceberg/table.h

@@ -48,46 +48,52 @@ class ICEBERG_EXPORT Table {
         std::string metadata_location, std::shared_ptr<FileIO> io,
         std::shared_ptr<Catalog> catalog);
 
-  /// \brief Return the identifier of this table
+  /// \brief Returns the identifier of this table
   const TableIdentifier& name() const { return identifier_; }
 
+  /// \brief Returns the metadata of this table
+  const std::shared_ptr<TableMetadata>& metadata() const { return metadata_; }
+
   /// \brief Returns the UUID of the table
   const std::string& uuid() const;
 
+  /// \brief Returns the format version of the table
+  int8_t format_version() const;
+
   /// \brief Refresh the current table metadata
   Status Refresh();
 
-  /// \brief Return the schema for this table, return NotFoundError if not found
+  /// \brief Returns the schema for this table, return NotFoundError if not found
   Result<std::shared_ptr<Schema>> schema() const;
 
-  /// \brief Return a map of schema for this table
+  /// \brief Returns a map of schema for this table
   Result<
       std::reference_wrapper<const std::unordered_map<int32_t, std::shared_ptr<Schema>>>>
   schemas() const;
 
-  /// \brief Return the partition spec for this table, return NotFoundError if not found
+  /// \brief Returns the partition spec for this table, return NotFoundError if not found
   Result<std::shared_ptr<PartitionSpec>> spec() const;
 
-  /// \brief Return a map of partition specs for this table
+  /// \brief Returns a map of partition specs for this table
   Result<std::reference_wrapper<
       const std::unordered_map<int32_t, std::shared_ptr<PartitionSpec>>>>
   specs() const;
 
-  /// \brief Return the sort order for this table, return NotFoundError if not found
+  /// \brief Returns the sort order for this table, return NotFoundError if not found
   Result<std::shared_ptr<SortOrder>> sort_order() const;
 
-  /// \brief Return a map of sort order IDs to sort orders for this table
+  /// \brief Returns a map of sort order IDs to sort orders for this table
   Result<std::reference_wrapper<
       const std::unordered_map<int32_t, std::shared_ptr<SortOrder>>>>
   sort_orders() const;
 
-  /// \brief Return a map of string properties for this table
+  /// \brief Returns a map of string properties for this table
   const TableProperties& properties() const;
 
-  /// \brief Return the table's base location
+  /// \brief Returns the table's base location
   const std::string& location() const;
 
-  /// \brief Return the table's current snapshot, return NotFoundError if not found
+  /// \brief Returns the table's current snapshot, return NotFoundError if not found
   Result<std::shared_ptr<Snapshot>> current_snapshot() const;
 
   /// \brief Get the snapshot of this table with the given id
@@ -124,6 +130,9 @@ class ICEBERG_EXPORT Table {
   /// \brief Returns a FileIO to read and write table data and metadata files
   const std::shared_ptr<FileIO>& io() const;
 
+  /// \brief Returns the catalog that this table belongs to
+  const std::shared_ptr<Catalog>& catalog() const;
+
  private:
   const TableIdentifier identifier_;
   std::shared_ptr<TableMetadata> metadata_;

src/iceberg/table_properties.h

@@ -244,6 +244,9 @@ class ICEBERG_EXPORT TableProperties : public ConfigBase<TableProperties> {
   inline static Entry<int64_t> kDeleteTargetFileSizeBytes{
       "write.delete.target-file-size-bytes", int64_t{64} * 1024 * 1024};  // 64 MB
 
+  inline static Entry<bool> kSnapshotIdInheritanceEnabled{
+      "compatibility.snapshot-id-inheritance.enabled", false};
+
   // Garbage collection properties
 
   inline static Entry<bool> kGcEnabled{"gc.enabled", true};