bigquery

Documentation

Index

• func Atoi(s string) int
• func ParseFloat64(s string) float64
• func ValidateOptions(options *Options)
• type Connection
  • func NewConnection(opts *Options, configPath string) *Connection
  • func (conn *Connection) CreateDataset()
  • func (conn *Connection) CreateTable(fields []*bigquery.TableFieldSchema)
  • func (conn *Connection) DatasetName() string
  • func (conn *Connection) InsertRows(maps []map[string]interface{}, uniqueColumnName string)
  • func (conn *Connection) Query(sql, description string) []*bigquery.TableRow
• type Options

Functions

func Atoi

func Atoi(s string) int

func ParseFloat64

func ParseFloat64(s string) float64

func ValidateOptions

func ValidateOptions(options *Options)

Types

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(opts *Options, configPath string) *Connection

func (*Connection) CreateDataset

func (conn *Connection) CreateDataset()

func (*Connection) CreateTable

func (conn *Connection) CreateTable(fields []*bigquery.TableFieldSchema)

func (*Connection) DatasetName

func (conn *Connection) DatasetName() string

func (*Connection) InsertRows

func (conn *Connection) InsertRows(
	maps []map[string]interface{}, uniqueColumnName string)

func (*Connection) Query

func (conn *Connection) Query(sql, description string) []*bigquery.TableRow

type Options

type Options struct {
	GcloudPemPath   string
	GcloudProjectId string
	DatasetName     string
	TableName       string
	Endpoint        string
}