@@ -19,7 +19,6 @@ class CreateClusterIdentity(SQLHandler):
1919 CREATE CLUSTER IDENTITY
2020 catalog
2121 storage
22- [ description ]
2322 ;
2423
2524 # Catolog
@@ -32,9 +31,6 @@ class CreateClusterIdentity(SQLHandler):
3231 _link_config = S3 CONFIG '<link-config>'
3332 _link_creds = CREDENTIALS '<link-creds>'
3433
35- # Description
36- description = DESCRIPTION '<description>'
37-
3834 Description
3935 -----------
4036 Create a cluster identity for allowing the export service to access
@@ -49,17 +45,28 @@ class CreateClusterIdentity(SQLHandler):
4945
5046 Remarks
5147 -------
52- * ``CATALOG`` specifies the name of a catalog profile.
53- * ``LINK`` indicates the name of a link for accessing storage.
48+ * ``FROM <table>`` specifies the SingleStore table to export. The same name will
49+ be used for the exported table.
50+ * ``CATALOG`` specifies the details of the catalog to connect to.
51+ * ``LINK`` specifies the details of the data storage to connect to.
5452
5553 Example
5654 -------
5755 The following statement creates a cluster identity for the catalog
5856 and link::
5957
6058 CREATE CLUSTER IDENTITY
61- CATALOG ...
62- LINK ...
59+ CATALOG CONFIG '{
60+ "type": "GLUE",
61+ "table_format": "ICEBERG",
62+ "id": "13983498723498",
63+ "region": "us-east-1"
64+ }'
65+ LINK S3 CONFIG '{
66+ "region": "us-east-1",
67+ "endpoint_url": "s3://bucket-name"
68+
69+ }'
6370 ;
6471
6572 """
@@ -102,16 +109,11 @@ class CreateExport(SQLHandler):
102109 from_table
103110 catalog
104111 storage
105- [ properties ]
106- [ description ]
107112 ;
108113
109114 # From table
110115 from_table = FROM <table>
111116
112- # Properties
113- properties = PROPERTIES '<table-properties>'
114-
115117 # Catolog
116118 catalog = CATALOG [ _catalog_config ] [ _catalog_creds ]
117119 _catalog_config = CONFIG '<catalog-config>'
@@ -122,9 +124,6 @@ class CreateExport(SQLHandler):
122124 _link_config = S3 CONFIG '<link-config>'
123125 _link_creds = CREDENTIALS '<link-creds>'
124126
125- # Description
126- description = DESCRIPTION '<description>'
127-
128127 Description
129128 -----------
130129 Create an export configuration.
@@ -133,15 +132,13 @@ class CreateExport(SQLHandler):
133132 ---------
134133 * ``<catalog-config>`` and ``<catalog-creds>``: The catalog configuration.
135134 * ``<link-config>`` and ``<link-creds>``: The storage link configuration.
136- * ``<table-properties>``: Table properties as a JSON object.
137- * ``<description>``: Description of export.
138135
139136 Remarks
140137 -------
141138 * ``FROM <table>`` specifies the SingleStore table to export. The same name will
142139 be used for the exported table.
143- * ``CATALOG`` specifies the name of a catalog profile .
144- * ``LINK`` indicates the name of a link for accessing storage .
140+ * ``CATALOG`` specifies the details of the catalog to connect to .
141+ * ``LINK`` specifies the details of the data storage to connect to .
145142
146143 Examples
147144 --------
@@ -161,12 +158,7 @@ class CreateExport(SQLHandler):
161158 "endpoint_url": "s3://bucket-name"
162159
163160 }'
164- PROPERTIES '{
165- "write.update.mode": "copy-on-write",
166- "write.format.default": "parquet",
167- "write.parquet.row-group-size-bytes": 50000000,
168- "write.target-file-size-bytes": 100000000
169- }';
161+ ;
170162
171163 """ # noqa
172164
@@ -186,9 +178,6 @@ def run(self, params: Dict[str, Any]) -> Optional[FusionSQLResult]:
186178 storage_config = json .loads (params ['storage' ].get ('link_config' , '{}' ) or '{}' )
187179 storage_creds = json .loads (params ['storage' ].get ('link_creds' , '{}' ) or '{}' )
188180
189- # Properties
190- # properties = json.loads(params['properties'] or '{}')
191-
192181 wsg = get_workspace_group ({})
193182
194183 if from_database is None :
0 commit comments