or run

tessl search

Version

Workspace: tessl
Visibility: Public
Created: 6 days ago
Last updated: about 16 hours ago
Describes: pkg:golang/cloud.google.com/go/bigquery@v1.72.0

tessl/golang-cloud-google-com--go--bigquery

tessl install tessl/golang-cloud-google-com--go--bigquery@1.72.0

Google Cloud BigQuery client library providing comprehensive Go APIs for querying, loading data, managing datasets and tables, streaming inserts, and accessing BigQuery's ecosystem of services including Storage, Analytics Hub, Data Transfer, and Migration APIs

BigLake API

The BigLake API provides unified analytics for data stored in BigQuery and open-source table formats like Apache Iceberg, Delta Lake, and Hudi.

Package Import

import "cloud.google.com/go/bigquery/biglake/apiv1"
import "cloud.google.com/go/bigquery/biglake/apiv1/biglakepb"

Client Creation

func NewMetastoreServiceClient(ctx context.Context, opts ...option.ClientOption) (*MetastoreServiceClient, error)

type MetastoreServiceClient struct{}

func (c *MetastoreServiceClient) Close() error

Catalogs

func (c *MetastoreServiceClient) CreateCatalog(ctx context.Context, req *biglakepb.CreateCatalogRequest, opts ...gax.CallOption) (*biglakepb.Catalog, error)
func (c *MetastoreServiceClient) DeleteCatalog(ctx context.Context, req *biglakepb.DeleteCatalogRequest, opts ...gax.CallOption) (*biglakepb.Catalog, error)
func (c *MetastoreServiceClient) GetCatalog(ctx context.Context, req *biglakepb.GetCatalogRequest, opts ...gax.CallOption) (*biglakepb.Catalog, error)
func (c *MetastoreServiceClient) ListCatalogs(ctx context.Context, req *biglakepb.ListCatalogsRequest, opts ...gax.CallOption) *CatalogIterator

Databases

func (c *MetastoreServiceClient) CreateDatabase(ctx context.Context, req *biglakepb.CreateDatabaseRequest, opts ...gax.CallOption) (*biglakepb.Database, error)
func (c *MetastoreServiceClient) DeleteDatabase(ctx context.Context, req *biglakepb.DeleteDatabaseRequest, opts ...gax.CallOption) (*biglakepb.Database, error)
func (c *MetastoreServiceClient) GetDatabase(ctx context.Context, req *biglakepb.GetDatabaseRequest, opts ...gax.CallOption) (*biglakepb.Database, error)
func (c *MetastoreServiceClient) ListDatabases(ctx context.Context, req *biglakepb.ListDatabasesRequest, opts ...gax.CallOption) *DatabaseIterator
func (c *MetastoreServiceClient) UpdateDatabase(ctx context.Context, req *biglakepb.UpdateDatabaseRequest, opts ...gax.CallOption) (*biglakepb.Database, error)

Tables

func (c *MetastoreServiceClient) CreateTable(ctx context.Context, req *biglakepb.CreateTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)
func (c *MetastoreServiceClient) DeleteTable(ctx context.Context, req *biglakepb.DeleteTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)
func (c *MetastoreServiceClient) GetTable(ctx context.Context, req *biglakepb.GetTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)
func (c *MetastoreServiceClient) ListTables(ctx context.Context, req *biglakepb.ListTablesRequest, opts ...gax.CallOption) *TableIterator
func (c *MetastoreServiceClient) RenameTable(ctx context.Context, req *biglakepb.RenameTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)
func (c *MetastoreServiceClient) UpdateTable(ctx context.Context, req *biglakepb.UpdateTableRequest, opts ...gax.CallOption) (*biglakepb.Table, error)

Example

import (
    "cloud.google.com/go/bigquery/biglake/apiv1"
    "cloud.google.com/go/bigquery/biglake/apiv1/biglakepb"
)

client, err := biglake.NewMetastoreServiceClient(ctx)
if err != nil {
    return err
}
defer client.Close()

// Create catalog
catalog, err := client.CreateCatalog(ctx, &biglakepb.CreateCatalogRequest{
    Parent: "projects/my-project/locations/us",
    CatalogId: "my_catalog",
    Catalog: &biglakepb.Catalog{},
})