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

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

Overview

Eval results

Files

BigLake API

Name: tessl/golang-cloud-google-com--go--bigquery
Author: tessl

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{},
})

Install with Tessl CLI

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