Documentation
¶
Index ¶
- func CreateStagedTable(ctx context.Context, catprops iceberg.Properties, ...) (table.StagedTable, 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 icebergio.WriteFileIO, loc string, ...) (err error)
- type GetNamespacePropsFn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateStagedTable ¶
func CreateStagedTable(ctx context.Context, catprops iceberg.Properties, nspropsFn GetNamespacePropsFn, ident table.Identifier, sc *iceberg.Schema, opts ...catalog.CreateTableOpt) (table.StagedTable, error)
func ParseMetadataVersion ¶
func ResolveTableLocation ¶
func ResolveTableLocation(ctx context.Context, loc, dbname, tablename string, catprops iceberg.Properties, nsprops GetNamespacePropsFn) (string, error)
func UpdateAndStageTable ¶
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 ¶
Types ¶
type GetNamespacePropsFn ¶
type GetNamespacePropsFn func(context.Context, table.Identifier) (iceberg.Properties, error)
Source Files
Click to show internal directories.
Click to hide internal directories.