Documentation
¶
Index ¶
- func CreateStagedTable(ctx context.Context, catprops iceberg.Properties, ...) (table.StagedTable, error)
- func CreateViewMetadata(ctx context.Context, catalogName string, nsIdent []string, ...) (metadataLocation string, err error)
- func GetMetadataLoc(location string, newVersion uint) string
- func LoadViewMetadata(ctx context.Context, props iceberg.Properties, metadataLocation string, ...) (_ map[string]interface{}, err error)
- func ParseMetadataVersion(location string) int
- func ResolveTableLocation(ctx context.Context, loc, dbname, tablename string, ...) (string, error)
- func UpdateAndStageTable(ctx context.Context, current *table.Table, ident table.Identifier, ...) (*table.StagedTable, error)
- func UpdateTableMetadata(base table.Metadata, updates []table.Update, metadataLoc string) (table.Metadata, error)
- func WriteMetadata(ctx context.Context, metadata table.Metadata, loc string, ...) error
- func WriteTableMetadata(metadata table.Metadata, fs io.WriteFileIO, loc string) error
- type GetNamespacePropsFn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateStagedTable ¶ added in v0.3.0
func CreateStagedTable(ctx context.Context, catprops iceberg.Properties, nspropsFn GetNamespacePropsFn, ident table.Identifier, sc *iceberg.Schema, opts ...catalog.CreateTableOpt) (table.StagedTable, error)
func CreateViewMetadata ¶ added in v0.4.0
func GetMetadataLoc ¶
func LoadViewMetadata ¶ added in v0.4.0
func ParseMetadataVersion ¶
func ResolveTableLocation ¶ added in v0.3.0
func ResolveTableLocation(ctx context.Context, loc, dbname, tablename string, catprops iceberg.Properties, nsprops GetNamespacePropsFn) (string, error)
func UpdateAndStageTable ¶ added in v0.3.0
func UpdateAndStageTable(ctx context.Context, current *table.Table, ident table.Identifier, reqs []table.Requirement, updates []table.Update, cat table.CatalogIO) (*table.StagedTable, error)
func UpdateTableMetadata ¶
func WriteMetadata ¶
func WriteTableMetadata ¶ added in v0.3.0
Types ¶
type GetNamespacePropsFn ¶ added in v0.3.0
type GetNamespacePropsFn func(context.Context, table.Identifier) (iceberg.Properties, error)
Click to show internal directories.
Click to hide internal directories.