internal

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 CreateStagedTableWithNamespaceKey ¶ added in v0.7.0

func CreateStagedTableWithNamespaceKey(
	ctx context.Context,
	catprops iceberg.Properties,
	nspropsFn GetNamespacePropsFn,
	ident table.Identifier,
	namespaceKey string,
	sc *iceberg.Schema,
	opts ...catalog.CreateTableOpt,
) (table.StagedTable, error)

CreateStagedTableWithNamespaceKey creates a staged table using namespaceKey in its default warehouse location while retaining ident's namespace components for namespace property lookup.

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 ResolveTableLocationWithNamespace ¶ added in v0.7.0

func ResolveTableLocationWithNamespace(
	ctx context.Context,
	loc string,
	namespace table.Identifier,
	namespaceKey, tablename string,
	catprops iceberg.Properties,
	nsprops GetNamespacePropsFn,
) (string, error)

ResolveTableLocationWithNamespace keeps namespace property lookup component-aware while allowing catalogs to provide a distinct key for the default warehouse path.

func UpdateAndStageTable ¶ added in v0.3.0

func UpdateAndStageTable(ctx context.Context, catprops iceberg.Properties, 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, tbl *table.Table) error

func WriteTableMetadata ¶ added in v0.3.0

func WriteTableMetadata(metadata table.Metadata, fs icebergio.WriteFileIO, loc string, compression string) (err error)