package catalog

Import Path
	github.com/polarsignals/iceberg-go/catalog (on go.dev)

Dependency Relation
	imports 13 packages, and imported by one package

Involved Source Files bucket.go catalog.go hdfs.go
Package-Level Type Names (total 4)
/* sort by: | */
Catalog for iceberg table operations like create, drop, load, list and others. CatalogType returns the type of the catalog. CreateNamespace tells the catalog to create a new namespace with the given properties CreateTable tells the catalog to create a new table with the given schema and properties DropNamespace tells the catalog to drop the namespace and all tables in that namespace DropTable tells the catalog to drop the table entirely ListNamespaces returns the list of available namespaces, optionally filtering by a parent namespace ListTables returns a list of table identifiers in the catalog, with the returned identifiers containing the information required to load the table via that catalog. LoadNamespaceProperties returns the current properties in the catalog for a given namespace LoadTable loads a table from the catalog and returns a Table with the metadata. RenameTable tells the catalog to rename a given table by the identifiers provided, and then loads and returns the destination table UpdateNamespaceProperties allows removing, adding, and/or updating properties of a namespace func NewHDFS(uri string, bucket objstore.Bucket) Catalog func github.com/polarsignals/frostdb/storage.NewIceberg(uri string, ctlg Catalog, bucket objstore.Bucket, options ...storage.IcebergOption) (*storage.Iceberg, error)
func Catalog.CatalogType() CatalogType const DynamoDB const Glue const Hadoop const Hive const REST const SQL
Missing []string Removed []string Updated []string func Catalog.UpdateNamespaceProperties(ctx context.Context, namespace table.Identifier, removals []string, updates iceberg.Properties) (PropertiesUpdateSummary, error)
func WithPartitionSpec(spec iceberg.PartitionSpec) TableOption func Catalog.CreateTable(ctx context.Context, location string, schema *iceberg.Schema, props iceberg.Properties, options ...TableOption) (table.Table, error)
Package-Level Functions (total 5)
func NewHDFS(uri string, bucket objstore.Bucket) Catalog
NewIcebucket creates a new icebucket with the given prefix and bucket. The warehouseURI is used to strip the full path of the data warehouse from the object name.
Package-Level Variables (total 4)
ErrNoSuchTable is returned when a table does not exist in the catalog.
Package-Level Constants (total 6)
const DynamoDB CatalogType = "dynamodb"
const Glue CatalogType = "glue"
const Hadoop CatalogType = "hadoop"
const Hive CatalogType = "hive"
const REST CatalogType = "rest"
const SQL CatalogType = "sql"