internal

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

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 CreateViewMetadata(
	ctx context.Context,
	catalogName string,
	nsIdent []string,
	schema *iceberg.Schema,
	viewSQL string,
	loc string,
	props iceberg.Properties,
) (metadataLocation string, err error)

func GetMetadataLoc

func GetMetadataLoc(location string, newVersion uint) string

func LoadViewMetadata added in v0.4.0

func LoadViewMetadata(ctx context.Context,
	props iceberg.Properties,
	metadataLocation string,
	viewName string,
	namespace string,
) (_ map[string]interface{}, err error)

func ParseMetadataVersion

func ParseMetadataVersion(location string) int

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 UpdateTableMetadata(base table.Metadata, updates []table.Update, metadataLoc string) (table.Metadata, error)

func WriteMetadata

func WriteMetadata(ctx context.Context, metadata table.Metadata, loc string, props iceberg.Properties) error

func WriteTableMetadata added in v0.3.0

func WriteTableMetadata(metadata table.Metadata, fs io.WriteFileIO, loc string) error

Types

type GetNamespacePropsFn added in v0.3.0

type GetNamespacePropsFn func(context.Context, table.Identifier) (iceberg.Properties, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL