bigquery

Documentation

Index

• Constants
• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) DatasetExists(ref *DatasetReference) (bool, error)
  • func (c *Client) EnsureTableExists(ref *TableReference, partition bool) error
  • func (c *Client) LoadTable(spec *LoadSpec) error
• type DatasetReference
• type LoadCompleted
• type LoadSpec
• type TableReference
  • func NewTableReference(projectId, dataset, table string) *TableReference
  • func (ref *TableReference) DatasetReference() *DatasetReference
  • func (ref *TableReference) String() string
  • func (ref *TableReference) ToGoogleReference() *bq.TableReference
  • func (ref *TableReference) ToUndecoratedGoogleReference() *bq.TableReference

Constants

const StateDone = "DONE"

Types

type Client

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

func NewClient

func NewClient() (*Client, error)

func (*Client) DatasetExists

func (c *Client) DatasetExists(ref *DatasetReference) (bool, error)

func (*Client) EnsureTableExists

func (c *Client) EnsureTableExists(ref *TableReference, partition bool) error

func (*Client) LoadTable

func (c *Client) LoadTable(spec *LoadSpec) error

type DatasetReference

type DatasetReference struct {
	ProjectID string
	DatasetID string
}

type LoadCompleted

type LoadCompleted struct {
	Error error
}

type LoadSpec

type LoadSpec struct {
	TableReference *TableReference
	BucketName     string
	ObjectPrefix   string
	Overwrite      bool
	Schema         *bq.TableSchema
	Partitioned    bool
}

type TableReference

type TableReference struct {
	ProjectID    string
	DatasetID    string
	TableID      string
	DayPartition *time.Time
}

func NewTableReference

func NewTableReference(projectId, dataset, table string) *TableReference

func (*TableReference) DatasetReference

func (ref *TableReference) DatasetReference() *DatasetReference

func (*TableReference) String

func (ref *TableReference) String() string

func (*TableReference) ToGoogleReference

func (ref *TableReference) ToGoogleReference() *bq.TableReference

func (*TableReference) ToUndecoratedGoogleReference

func (ref *TableReference) ToUndecoratedGoogleReference() *bq.TableReference