bigquery

Documentation

Index

• Constants
• type DB
  • func Open(ctx context.Context, opt *types.BigQueryOpt) (*DB, error)
  • func (db *DB) CreateTable(ctx context.Context, opt offline.CreateTableOpt) error
  • func (db *DB) Export(ctx context.Context, opt offline.ExportOpt) (*types.ExportResult, error)
  • func (db *DB) Import(ctx context.Context, opt offline.ImportOpt) (int64, error)
  • func (db *DB) Join(ctx context.Context, opt offline.JoinOpt) (*types.JoinResult, error)
  • func (db *DB) Ping(ctx context.Context) error
  • func (db *DB) Push(ctx context.Context, opt offline.PushOpt) error
  • func (db *DB) Snapshot(ctx context.Context, opt offline.SnapshotOpt) error
  • func (db *DB) TableSchema(ctx context.Context, opt offline.TableSchemaOpt) (*types.DataTableSchema, error)

Constants

const (
	Backend = types.BackendBigQuery
)

const READ_JOIN_RESULT_QUERY = `` /* 474-byte string literal not displayed */

Types

type DB

type DB struct {
	*bigquery.Client
	// contains filtered or unexported fields
}

func Open

func Open(ctx context.Context, opt *types.BigQueryOpt) (*DB, error)

func (*DB) CreateTable

func (db *DB) CreateTable(ctx context.Context, opt offline.CreateTableOpt) error

func (*DB) Export

func (db *DB) Export(ctx context.Context, opt offline.ExportOpt) (*types.ExportResult, error)

func (*DB) Import

func (db *DB) Import(ctx context.Context, opt offline.ImportOpt) (int64, error)

func (*DB) Join

func (db *DB) Join(ctx context.Context, opt offline.JoinOpt) (*types.JoinResult, error)

func (*DB) Ping

func (db *DB) Ping(ctx context.Context) error

func (*DB) Push

func (db *DB) Push(ctx context.Context, opt offline.PushOpt) error

func (*DB) Snapshot

func (db *DB) Snapshot(ctx context.Context, opt offline.SnapshotOpt) error

func (*DB) TableSchema

func (db *DB) TableSchema(ctx context.Context, opt offline.TableSchemaOpt) (*types.DataTableSchema, error)