This is an automated email from the ASF dual-hosted git repository.

fanng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gravitino.git


The following commit(s) were added to refs/heads/main by this push:
     new b1e1c9ecd9 [#9704] improvement(docs): Add the Flink using IRC 
documents (#9705)
b1e1c9ecd9 is described below

commit b1e1c9ecd93ea269d61ee1ceb511249748f865c0
Author: roryqi <[email protected]>
AuthorDate: Thu Jan 15 16:46:02 2026 +0800

    [#9704] improvement(docs): Add the Flink using IRC documents (#9705)
    
    ### What changes were proposed in this pull request?
    
    Add the Flink using IRC documents
    
    ### Why are the changes needed?
    
    Fix: #9704
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    Just documents.
---
 docs/iceberg-rest-service.md | 31 +++++++++++++++++++++++++++++++
 1 file changed, 31 insertions(+)

diff --git a/docs/iceberg-rest-service.md b/docs/iceberg-rest-service.md
index 816c48cd5c..308fcf357f 100644
--- a/docs/iceberg-rest-service.md
+++ b/docs/iceberg-rest-service.md
@@ -561,6 +561,37 @@ INSERT INTO dml.test VALUES (1), (2);
 SELECT * FROM dml.test;
 ```
 
+## Apache Flink Integration
+
+You can use Apache Flink to connect to the Gravitino Iceberg REST catalog 
service. Below is an example of how to create a catalog and access tables using 
Flink SQL:
+
+```
+CREATE CATALOG my_catalog WITH (
+  'type' = 'iceberg',
+  'catalog-type' = 'rest',
+  'uri' = 'http://localhost:9001/iceberg/',
+  'header.X-Iceberg-Access-Delegation' = 'vended-credentials',
+  'rest.auth.type' = 'basic',
+  'rest.auth.basic.username' = 'manager',
+  'rest.auth.basic.password' = 'mock'
+);
+```
+
+After creating the catalog, you can use standard Flink SQL commands to explore 
and manage your Iceberg tables:
+
+```
+USE CATALOG my_catalog;
+SHOW DATABASES;
+USE default;
+SHOW TABLES;
+CREATE TABLE `my_catalog`.`default`.`sample`  (
+     id BIGINT COMMENT 'unique id',
+     data STRING
+);
+INSERT INTO `my_catalog`.`default`.`sample` VALUES (1, 'a');
+SELECT * FROM `my_catalog`.`default`.`sample`;
+```
+
 ## Exploring the Apache Gravitino Iceberg REST catalog service with Trino
 
 ### Deploying Trino with Apache Iceberg support

Reply via email to