feat(iceberg): add license for iceberg sink with glue (#18187)

src/connector/src/sink/iceberg/mod.rs

@@ -204,7 +204,7 @@ impl IcebergConfig {
         Ok(config)
     }
 
-    fn catalog_type(&self) -> &str {
+    pub fn catalog_type(&self) -> &str {
         self.catalog_type.as_deref().unwrap_or("storage")
     }
 
@@ -737,6 +737,11 @@ impl Sink for IcebergSink {
     }
 
     async fn validate(&self) -> Result<()> {
+        if "glue".eq_ignore_ascii_case(self.config.catalog_type()) {
+            risingwave_common::license::Feature::IcebergSinkWithGlue
+                .check_available()
+                .map_err(|e| anyhow::anyhow!(e))?;
+        }
         let _ = self.create_and_validate_table().await?;
         Ok(())
     }

src/license/src/feature.rs

@@ -56,6 +56,7 @@ macro_rules! for_all_features {
             { SqlServerSink,        Paid,       "Sink data from RisingWave to SQL Server." },
             { SqlServerCdcSource,   Paid,       "CDC source connector for Sql Server." },
             { CdcAutoSchemaChange,  Paid,       "Auto replicate upstream DDL to CDC Table." },
+            { IcebergSinkWithGlue,  Paid,       "Delivering data to Iceberg with Glue catalog." },
         }
     };
 }