bqext

Dec 14, 2017

Changes in this version

type Dataset

+ func (dsExt *Dataset) DestQuery(query string, dest *bigquery.Table, disposition bigquery.TableWriteDisposition) *bigquery.Query

Dec 14, 2017

Changes in this version

type Dataset

+ func (dsExt *Dataset) Dedup_Alpha(src string, dedupOn string, destTable *bigquery.Table) (*bigquery.JobStatus, error)

+ func (dsExt *Dataset) ExecDestQuery(query string, disposition bigquery.TableWriteDisposition, ...) (*bigquery.JobStatus, error)

Dec 13, 2017

Changes in this version

+ type Dataset struct

+ BqClient *bigquery.Client

+ Dataset *bigquery.Dataset

+ func NewDataset(project, dataset string, clientOpts ...option.ClientOption) (Dataset, error)

+ func (dsExt *Dataset) Dedup(src string, dedupOn string, overwrite bool, project, dataset, table string) (*bigquery.JobStatus, error)

+ func (dsExt *Dataset) DestinationQuery(query string, dest *bigquery.Table) *bigquery.Query

+ func (dsExt *Dataset) QueryAndParse(q string, structPtr interface{}) error

+ func (dsExt *Dataset) ResultQuery(query string, dryRun bool) *bigquery.Query

+ func (dsExt Dataset) GetPartitionInfo(table string, partition string) (PartitionInfo, error)

+ type PartitionInfo struct

+ CreationTime time.Time

+ LastModified time.Time

+ PartitionID string

Dec 11, 2017

Changes in this version

+ type Table struct

+ BqClient *bigquery.Client

+ Dataset *bigquery.Dataset

+ func NewTable(project, dataset string, clientOpts ...option.ClientOption) (Table, error)

+ func (util *Table) QueryAndParse(q string, structPtr interface{}) error

+ func (util *Table) ResultQuery(query string, dryRun bool) *bigquery.Query