Documentation
¶
Index ¶
- type Catalog
- func (c *Catalog) CatalogType() catalog.Type
- func (c *Catalog) CheckNamespaceExists(_ context.Context, ns table.Identifier) (bool, error)
- func (c *Catalog) CheckTableExists(_ context.Context, ident table.Identifier) (bool, error)
- func (c *Catalog) CommitTable(ctx context.Context, ident table.Identifier, reqs []table.Requirement, ...) (table.Metadata, string, error)
- func (c *Catalog) CreateNamespace(_ context.Context, ns table.Identifier, props iceberg.Properties) error
- func (c *Catalog) CreateTable(ctx context.Context, ident table.Identifier, sc *iceberg.Schema, ...) (*table.Table, error)
- func (c *Catalog) DropNamespace(_ context.Context, ns table.Identifier) error
- func (c *Catalog) DropTable(_ context.Context, ident table.Identifier) error
- func (c *Catalog) ListNamespaces(_ context.Context, parent table.Identifier) ([]table.Identifier, error)
- func (c *Catalog) ListTables(_ context.Context, ns table.Identifier) iter.Seq2[table.Identifier, error]
- func (c *Catalog) LoadNamespaceProperties(_ context.Context, ns table.Identifier) (iceberg.Properties, error)
- func (c *Catalog) LoadTable(ctx context.Context, ident table.Identifier) (*table.Table, error)
- func (c *Catalog) RenameTable(_ context.Context, _, _ table.Identifier) (*table.Table, error)
- func (c *Catalog) UpdateNamespaceProperties(_ context.Context, _ table.Identifier, _ []string, _ iceberg.Properties) (catalog.PropertiesUpdateSummary, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Catalog ¶
type Catalog struct {
// contains filtered or unexported fields
}
Catalog is a filesystem-based Iceberg catalog that requires no external metastore. All state lives on disk as directories and versioned JSON metadata files. Currently only local filesystem paths are supported.
func NewCatalog ¶
func NewCatalog(name, warehouse string, props iceberg.Properties) (*Catalog, error)
NewCatalog creates a new Hadoop catalog rooted at the given warehouse path. Currently only local filesystem paths are supported. The warehouse directory is not created on construction; it is created implicitly by the first CreateNamespace call.
func (*Catalog) CatalogType ¶
func (*Catalog) CheckNamespaceExists ¶
func (*Catalog) CheckTableExists ¶
func (*Catalog) CommitTable ¶
func (*Catalog) CreateNamespace ¶
func (c *Catalog) CreateNamespace(_ context.Context, ns table.Identifier, props iceberg.Properties) error
func (*Catalog) CreateTable ¶
func (*Catalog) DropNamespace ¶
func (*Catalog) ListNamespaces ¶
func (c *Catalog) ListNamespaces(_ context.Context, parent table.Identifier) ([]table.Identifier, error)
func (*Catalog) ListTables ¶
func (c *Catalog) ListTables(_ context.Context, ns table.Identifier) iter.Seq2[table.Identifier, error]
func (*Catalog) LoadNamespaceProperties ¶
func (c *Catalog) LoadNamespaceProperties(_ context.Context, ns table.Identifier) (iceberg.Properties, error)
LoadNamespaceProperties returns a synthetic "location" property for the namespace. This is a Go-only convenience — the Hadoop catalog does not persist user-defined namespace properties.
func (*Catalog) RenameTable ¶
func (*Catalog) UpdateNamespaceProperties ¶
func (c *Catalog) UpdateNamespaceProperties(_ context.Context, _ table.Identifier, _ []string, _ iceberg.Properties) (catalog.PropertiesUpdateSummary, error)
Source Files
Click to show internal directories.
Click to hide internal directories.