Skip to content

Commit

Permalink
Add create namespace/database commands
Browse files Browse the repository at this point in the history
  • Loading branch information
pratyakshsharma committed Sep 29, 2023
1 parent f31729c commit e5bc8d3
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 0 deletions.
2 changes: 2 additions & 0 deletions site/docs/tools/iceberg/flink.md
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,8 @@ The following properties are **required** in Flink when creating the Nessie Cata
To create tables in Flink that are managed by Nessie/Iceberg, you will need to specify the catalog name in addition to the database whenever you issue `CREATE TABLE` statement, e.g:

```sql
CREATE DATABASE `<catalog_name>`.`<database_name>`;

CREATE TABLE `<catalog_name>`.`<database_name>`.`<table_name>` (
id BIGINT COMMENT 'unique id',
data STRING
Expand Down
2 changes: 2 additions & 0 deletions site/docs/tools/iceberg/spark.md
Original file line number Diff line number Diff line change
Expand Up @@ -258,6 +258,8 @@ Spark3 table creation/insertion is as follows:
```
=== "SQL"
``` sql
CREATE NAMESPACE nessie.testing;

CREATE TABLE nessie.testing.city (
C_CITYKEY BIGINT, C_NAME STRING, N_NATIONKEY BIGINT, C_COMMENT STRING
) USING iceberg PARTITIONED BY (N_NATIONKEY)
Expand Down

0 comments on commit e5bc8d3

Please sign in to comment.