catalog

Documentation

Index

• Constants
• Variables
• func LoadCatalog(name string, uri string, props icegopher.Properties) (table.Catalog, error)
• func NamespaceFromIdent(ident table.Identifier) table.Identifier
• func NewRestCatalog(name, uri string, props icegopher.Properties) (table.Catalog, error)
• func TableNameFromIdent(ident table.Identifier) string
• func ToIdentifier(ident ...string) table.Identifier
• type CatalogType

Constants

const (
	KeyToken             = "token"
	KeyType              = "type"
	KeyIceberg           = "iceberg"
	KeyWarehouseLocation = "warehouse"
	KeyMetadataLocation  = "metadata_location"
	KeyCredential        = "credential"
)

Variables

var (
	ErrNoSuchNamespace        = errors.New("[Catalog] no such namespace")
	ErrNamespaceAlreadyExists = errors.New("[Catalog] namespace already exists")
	ErrRESTError              = errors.New("[Catalog] REST error")
	ErrNoSuchTable            = errors.New("[Catalog] no such table")
)

var (
	ErrBadRequest           = fmt.Errorf("%w: bad request", ErrRESTError)
	ErrForbidden            = fmt.Errorf("%w: forbidden", ErrRESTError)
	ErrUnauthorized         = fmt.Errorf("%w: unauthorized", ErrRESTError)
	ErrAuthorizationExpired = fmt.Errorf("%w: authorization expired", ErrRESTError)
	ErrServiceUnavailble    = fmt.Errorf("%w: service unavailable", ErrRESTError)
	ErrServerError          = fmt.Errorf("%w: server error", ErrRESTError)
	ErrCommitFailed         = fmt.Errorf("%w: commit failed, refresh and try again", ErrRESTError)
	ErrCommitStateUnknown   = fmt.Errorf("%w: commit failed due to unknown reason", ErrRESTError)
	ErrOAuthError           = fmt.Errorf("%w: oauth error", ErrRESTError)
)

Functions

func LoadCatalog

func LoadCatalog(name string, uri string, props icegopher.Properties) (table.Catalog, error)

func NamespaceFromIdent

func NamespaceFromIdent(ident table.Identifier) table.Identifier

func NewRestCatalog

func NewRestCatalog(name, uri string, props icegopher.Properties) (table.Catalog, error)

func TableNameFromIdent

func TableNameFromIdent(ident table.Identifier) string

func ToIdentifier

func ToIdentifier(ident ...string) table.Identifier

Types

type CatalogType

type CatalogType string

const (
	REST     CatalogType = "rest"
	HIVE     CatalogType = "hive"
	GLUE     CatalogType = "glue"
	DYNAMODB CatalogType = "dynamodb"
)