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 ¶ 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 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)
Source Files
Click to show internal directories.
Click to hide internal directories.