catalog

catalog/iceberg

Iceberg catalog domain — manage Iceberg databases and tables.

setProvider()

Replaces the active Iceberg catalog provider.

createDatabase(name, location)

Creates an Iceberg database in the catalog.

Param	Description
name	Database name
location	S3 URI for the database location

Example

const { catalog } = require("@beem/sdk");

const db = await catalog.iceberg.createDatabase("analytics", "s3://my-lake/analytics/");

getDatabase()

Retrieves database metadata.

listDatabases()

Lists all databases in the catalog.

deleteDatabase()

Deletes a database from the catalog.

createTable(database)

Creates an Iceberg table in the specified database.

Param	Description
database	Database name

Example

const { catalog } = require("@beem/sdk");

const table = await catalog.iceberg.createTable("analytics", {
  name: "events",
  columns: [
    { name: "id", type: "string" },
    { name: "timestamp", type: "timestamptz" },
    { name: "payload", type: "string" },
  ],
});

getTable()

Retrieves table metadata.

listTables()

Lists all tables in a database.

deleteTable()

Deletes a table from the catalog.

provision()

Provisions Iceberg infrastructure from a config object (idempotent).