bigquery

Nov 13, 2018

Changes in this version

+ type Inserter struct

+ IgnoreUnknownValues bool

+ SkipInvalidRows bool

+ TableTemplateSuffix string

+ func (u *Inserter) Put(ctx context.Context, src interface{}) (err error)

type Table

+ func (t *Table) Inserter() *Inserter

Oct 31, 2018

Changes in this version

+ var NeverExpire = time.Time{}.Add(-1)

Sep 4, 2018

Changes in this version

type Schema

+ func SchemaFromJSON(schemaJSON []byte) (Schema, error)

type TableMetadataToUpdate

+ EncryptionConfig *EncryptionConfig

+ TimePartitioning *TimePartitioning

type TimePartitioning

+ RequirePartitionFilter bool

Aug 7, 2018

Changes in this version

+ type Clustering struct

+ Fields []string

type Job

+ func (j *Job) Email() string

type JobIterator

+ MaxCreationTime time.Time

+ MinCreationTime time.Time

type LoadConfig

+ Clustering *Clustering

type QueryConfig

+ Clustering *Clustering

type TableMetadata

+ Clustering *Clustering

Jul 12, 2018

Changes in this version

+ func Seed(s int64)

Jun 20, 2018

Changes in this version

+ const NumericPrecisionDigits

+ const NumericScaleDigits

+ func NumericString(r *big.Rat) string

type DataFormat

+ const ORC

type FieldType

+ const NumericFieldType

May 18, 2018

Changes in this version

type QueryStatistics

+ DDLOperationPerformed string

+ DDLTargetTable *Table

May 9, 2018

Changes in this version

type DataFormat

+ const Parquet

type Dataset

+ func (d *Dataset) DeleteWithContents(ctx context.Context) (err error)

type ExplainQueryStage

+ CompletedParallelInputs int64

+ ComputeAvg time.Duration

+ ComputeMax time.Duration

+ EndTime time.Time

+ InputStages []int64

+ ParallelInputs int64

+ ReadAvg time.Duration

+ ReadMax time.Duration

+ ShuffleOutputBytes int64

+ ShuffleOutputBytesSpilled int64

+ StartTime time.Time

+ WaitAvg time.Duration

+ WaitMax time.Duration

+ WriteAvg time.Duration

+ WriteMax time.Duration

type QueryConfig

+ SchemaUpdateOptions []string

type QueryStatistics

+ SlotMillis int64

+ Timeline []*QueryTimelineSample

+ type QueryTimelineSample struct

+ ActiveUnits int64

+ CompletedUnits int64

+ Elapsed time.Duration

+ PendingUnits int64

+ SlotMillis int64

Mar 22, 2018

Changes in this version

type Client

+ Location string

+ func (c *Client) JobFromIDLocation(ctx context.Context, id, location string) (*Job, error)

type Job

+ func (j *Job) Location() string

type JobIDConfig

+ Location string

type LoadConfig

+ SchemaUpdateOptions []string

Feb 27, 2018

Changes in this version

type CopyConfig

+ DestinationEncryptionConfig *EncryptionConfig

+ type EncryptionConfig struct

+ KMSKeyName string

type LoadConfig

+ DestinationEncryptionConfig *EncryptionConfig

type NullBool

+ func (n *NullBool) UnmarshalJSON(b []byte) error

type NullDate

+ func (n *NullDate) UnmarshalJSON(b []byte) error

type NullDateTime

+ func (n *NullDateTime) UnmarshalJSON(b []byte) error

type NullFloat64

+ func (n *NullFloat64) UnmarshalJSON(b []byte) error

type NullInt64

+ func (n *NullInt64) UnmarshalJSON(b []byte) error

type NullString

+ func (n *NullString) UnmarshalJSON(b []byte) error

type NullTime

+ func (n *NullTime) UnmarshalJSON(b []byte) error

type NullTimestamp

+ func (n *NullTimestamp) UnmarshalJSON(b []byte) error

type QueryConfig

+ DestinationEncryptionConfig *EncryptionConfig

type TableMetadata

+ EncryptionConfig *EncryptionConfig

Jan 19, 2018

Changes in this version

+ type NullBool struct

+ Bool bool

+ Valid bool

+ func (n NullBool) MarshalJSON() ([]byte, error)

+ func (n NullBool) String() string

+ type NullDate struct

+ Date civil.Date

+ Valid bool

+ func (n NullDate) MarshalJSON() ([]byte, error)

+ func (n NullDate) String() string

+ type NullDateTime struct

+ DateTime civil.DateTime

+ Valid bool

+ func (n NullDateTime) MarshalJSON() ([]byte, error)

+ func (n NullDateTime) String() string

+ type NullFloat64 struct

+ Float64 float64

+ Valid bool

+ func (n NullFloat64) MarshalJSON() ([]byte, error)

+ func (n NullFloat64) String() string

+ type NullInt64 struct

+ Int64 int64

+ Valid bool

+ func (n NullInt64) MarshalJSON() ([]byte, error)

+ func (n NullInt64) String() string

+ type NullString struct

+ StringVal string

+ Valid bool

+ func (n NullString) MarshalJSON() ([]byte, error)

+ func (n NullString) String() string

+ type NullTime struct

+ Time civil.Time

+ Valid bool

+ func (n NullTime) MarshalJSON() ([]byte, error)

+ func (n NullTime) String() string

+ type NullTimestamp struct

+ Timestamp time.Time

+ Valid bool

+ func (n NullTimestamp) MarshalJSON() ([]byte, error)

+ func (n NullTimestamp) String() string

type QueryConfig

+ TimePartitioning *TimePartitioning

type RowIterator

+ TotalRows uint64

Dec 11, 2017

Changes in this version

type TimePartitioning

+ Field string

Nov 1, 2017

Changes in this version

+ func CivilDateTimeString(dt civil.DateTime) string

+ func CivilTimeString(t civil.Time) string

+ type AccessEntry struct

+ Entity string

+ EntityType EntityType

+ Role AccessRole

+ View *Table

+ type AccessRole string

+ const OwnerRole

+ const ReaderRole

+ const WriterRole

+ type BigtableColumn struct

+ Encoding string

+ FieldName string

+ OnlyReadLatest bool

+ Qualifier string

+ Type string

+ type BigtableColumnFamily struct

+ Columns []*BigtableColumn

+ Encoding string

+ FamilyID string

+ OnlyReadLatest bool

+ Type string

+ type BigtableOptions struct

+ ColumnFamilies []*BigtableColumnFamily

+ IgnoreUnspecifiedColumnFamilies bool

+ ReadRowkeyAsString bool

+ type CSVOptions struct

+ AllowJaggedRows bool

+ AllowQuotedNewlines bool

+ Encoding Encoding

+ FieldDelimiter string

+ ForceZeroQuote bool

+ Quote string

+ SkipLeadingRows int64

type CopyConfig

+ Labels map[string]string

type DataFormat

+ const Bigtable

+ const GoogleSheets

type DatasetMetadata

+ Access []*AccessEntry

type DatasetMetadataToUpdate

+ Access []*AccessEntry

+ type EntityType int

+ const DomainEntity

+ const GroupEmailEntity

+ const SpecialGroupEntity

+ const UserEmailEntity

+ const ViewEntity

+ type ExternalDataConfig struct

+ AutoDetect bool

+ Compression Compression

+ IgnoreUnknownValues bool

+ MaxBadRecords int64

+ Options ExternalDataConfigOptions

+ Schema Schema

+ SourceFormat DataFormat

+ SourceURIs []string

+ type ExternalDataConfigOptions interface

type ExtractConfig

+ Labels map[string]string

type GCSReference

+ URIs []string

+ type GoogleSheetsOptions struct

+ SkipLeadingRows int64

type Job

+ func (j *Job) Config() (JobConfig, error)

+ func (j *Job) LastStatus() *JobStatus

+ type JobConfig interface

+ type JobIDConfig struct

+ AddJobIDSuffix bool

+ JobID string

type LoadConfig

+ Labels map[string]string

+ TimePartitioning *TimePartitioning

type QueryConfig

+ DryRun bool

+ Labels map[string]string

type TableMetadata

+ ExternalDataConfig *ExternalDataConfig

+ Labels map[string]string

type TableMetadataToUpdate

+ UseLegacySQL optional.Bool

+ ViewQuery optional.String

+ func (u *TableMetadataToUpdate) DeleteLabel(name string)

+ func (u *TableMetadataToUpdate) SetLabel(name, value string)

Sep 27, 2017

Changes in this version

type Client

+ func (c *Client) Jobs(ctx context.Context) *JobIterator

type CopyConfig

+ AddJobIDSuffix bool

type DatasetMetadata

+ FullID string

type ExtractConfig

+ AddJobIDSuffix bool

+ type JobInfo struct

+ Job *Job

+ Status *JobStatus

+ type JobIterator struct

+ AllUsers bool

+ ProjectID string

+ State State

+ func (it *JobIterator) Next() (JobInfo, error)

+ func (it *JobIterator) PageInfo() *iterator.PageInfo

type LoadConfig

+ AddJobIDSuffix bool

type QueryConfig

+ AddJobIDSuffix bool

type State

+ const StateUnspecified

type TableMetadata

+ FullID string

+ UseLegacySQL bool

+ UseStandardSQL bool

+ ViewQuery string

Sep 11, 2017

Changes in this version

type CreateTableOption

+ func UseLegacySQL() CreateTableOption

type DatasetIterator

+ ProjectID string

type DatasetMetadataToUpdate

+ func (dm *DatasetMetadataToUpdate) DeleteLabel(name string)

+ func (dm *DatasetMetadataToUpdate) SetLabel(name, value string)

type QueryConfig

+ UseLegacySQL bool

Aug 22, 2017

Changes in this version

type Dataset

+ func (d *Dataset) Update(ctx context.Context, dm DatasetMetadataToUpdate, etag string) (*DatasetMetadata, error)

type DatasetMetadata

+ ETag string

+ type DatasetMetadataToUpdate struct

+ DefaultTableExpiration optional.Duration

+ Description optional.String

+ Name optional.String

type TableMetadata

+ ETag string

type TableMetadataToUpdate

+ ExpirationTime time.Time

Jun 14, 2017

Changes in this version

+ type ExplainQueryStage struct

+ ComputeRatioAvg float64

+ ComputeRatioMax float64

+ ID int64

+ Name string

+ ReadRatioAvg float64

+ ReadRatioMax float64

+ RecordsRead int64

+ RecordsWritten int64

+ Status string

+ Steps []*ExplainQueryStep

+ WaitRatioAvg float64

+ WaitRatioMax float64

+ WriteRatioAvg float64

+ WriteRatioMax float64

+ type ExplainQueryStep struct

+ Kind string

+ Substeps []string

+ type ExtractStatistics struct

+ DestinationURIFileCounts []int64

+ type JobStatistics struct

+ CreationTime time.Time

+ Details Statistics

+ EndTime time.Time

+ StartTime time.Time

+ TotalBytesProcessed int64

type JobStatus

+ Statistics *JobStatistics

+ type LoadStatistics struct

+ InputFileBytes int64

+ InputFiles int64

+ OutputBytes int64

+ OutputRows int64

+ type QueryStatistics struct

+ BillingTier int64

+ CacheHit bool

+ NumDMLAffectedRows int64

+ QueryPlan []*ExplainQueryStage

+ ReferencedTables []*Table

+ Schema Schema

+ StatementType string

+ TotalBytesBilled int64

+ TotalBytesProcessed int64

+ UndeclaredQueryParameterNames []string

+ type Statistics interface

+ type StreamingBuffer struct

+ EstimatedBytes uint64

+ EstimatedRows uint64

+ OldestEntryTime time.Time

type TableMetadata

+ StreamingBuffer *StreamingBuffer

type TableType

+ const ExternalTable

Mar 10, 2017

Changes in this version

type FileConfig

+ AutoDetect bool

type TableMetadata

+ TimePartitioning *TimePartitioning

+ type TimePartitioning struct

+ Expiration time.Duration

Dec 10, 2016

Changes in this version

type FieldType

+ const DateFieldType

+ const DateTimeFieldType

+ const TimeFieldType

+ type StructSaver struct

+ InsertID string

+ Schema Schema

+ Struct interface{}

+ func (ss *StructSaver) Save() (row map[string]Value, insertID string, err error)

Nov 30, 2016

Changes in this version

type Dataset

+ DatasetID string

+ ProjectID string

+ func (d *Dataset) Delete(ctx context.Context) error

+ func (d *Dataset) Metadata(ctx context.Context) (*DatasetMetadata, error)

+ type DatasetMetadata struct

+ CreationTime time.Time

+ DefaultTableExpiration time.Duration

+ Description string

+ ID string

+ Labels map[string]string

+ LastModifiedTime time.Time

+ Location string

+ Name string

type FieldType

+ const BytesFieldType

type Job

+ func (j *Job) Wait(ctx context.Context) (*JobStatus, error)

type QueryConfig

+ Parameters []QueryParameter

+ type QueryParameter struct

+ Name string

+ Value interface{}

type TableMetadataToUpdate

+ Schema Schema

Nov 1, 2016

Changes in this version

+ type FileConfig struct

+ AllowJaggedRows bool

+ AllowQuotedNewlines bool

+ Encoding Encoding

+ FieldDelimiter string

+ ForceZeroQuote bool

+ IgnoreUnknownValues bool

+ MaxBadRecords int64

+ Quote string

+ Schema Schema

+ SkipLeadingRows int64

+ SourceFormat DataFormat

type GCSReference

+ func NewGCSReference(uri ...string) *GCSReference

+ type LoadSource interface

+ type ReaderSource struct

+ func NewReaderSource(r io.Reader) *ReaderSource

type Table

+ func (t *Table) Uploader() *Uploader

type Uploader

+ IgnoreUnknownValues bool

+ SkipInvalidRows bool

+ TableTemplateSuffix string

Oct 14, 2016

Changes in this version

+ type Copier struct

+ func (c *Copier) Run(ctx context.Context) (*Job, error)

+ type CopyConfig struct

+ CreateDisposition TableCreateDisposition

+ Dst *Table

+ JobID string

+ Srcs []*Table

+ WriteDisposition TableWriteDisposition

+ type ExternalData interface

+ type ExtractConfig struct

+ DisableHeader bool

+ Dst *GCSReference

+ JobID string

+ Src *Table

+ type Extractor struct

+ func (e *Extractor) Run(ctx context.Context) (*Job, error)

+ type LoadConfig struct

+ CreateDisposition TableCreateDisposition

+ Dst *Table

+ JobID string

+ Src *GCSReference

+ WriteDisposition TableWriteDisposition

+ type Loader struct

+ func (l *Loader) Run(ctx context.Context) (*Job, error)

type Query

+ TableDefinitions map[string]ExternalData

+ func (q *Query) Run(ctx context.Context) (*Job, error)

+ type QueryConfig struct

+ AllowLargeResults bool

+ CreateDisposition TableCreateDisposition

+ DefaultDatasetID string

+ DefaultProjectID string

+ DisableFlattenedResults bool

+ DisableQueryCache bool

+ Dst *Table

+ JobID string

+ MaxBillingTier int

+ MaxBytesBilled int64

+ Priority QueryPriority

+ Q string

+ TableDefinitions map[string]ExternalData

+ UseStandardSQL bool

+ WriteDisposition TableWriteDisposition

+ type QueryPriority string

+ type RowIterator struct

+ StartIndex uint64

+ func (it *RowIterator) Next(dst ValueLoader) error

+ func (it *RowIterator) PageInfo() *iterator.PageInfo

+ func (it *RowIterator) Schema() (Schema, error)

type Table

+ func (t *Table) CopierFrom(srcs ...*Table) *Copier

+ func (t *Table) ExtractorTo(dst *GCSReference) *Extractor

+ func (t *Table) LoaderFrom(src *GCSReference) *Loader

+ func (t *Table) Update(ctx context.Context, tm TableMetadataToUpdate) (*TableMetadata, error)

+ type TableMetadataToUpdate struct

+ Description optional.String

+ Name optional.String

Oct 3, 2016

Changes in this version

type Client

+ func (c *Client) Close() error

+ func (c *Client) DatasetInProject(projectID, datasetID string) *Dataset

+ func (c *Client) Datasets(ctx context.Context) *DatasetIterator

+ func (c *Client) DatasetsInProject(ctx context.Context, projectID string) *DatasetIterator

+ func (c *Client) Query(q string) *Query

+ func (c *Client) Table(projectID, datasetID, tableID string) *Table

type CreateTableOption

+ func UseStandardSQL() CreateTableOption

type Dataset

+ func (d *Dataset) Table(tableID string) *Table

+ func (d *Dataset) Tables(ctx context.Context) *TableIterator

+ type DatasetIterator struct

+ Filter string

+ ListHidden bool

+ func (it *DatasetIterator) Next() (*Dataset, error)

+ func (it *DatasetIterator) PageInfo() *iterator.PageInfo

type GCSReference

+ AllowJaggedRows bool

+ AllowQuotedNewlines bool

+ IgnoreUnknownValues bool

+ MaxBadRecords int64

+ Schema Schema

type Job

+ func (j *Job) Cancel(ctx context.Context) error

+ func (j *Job) Read(_ context.Context, options ...ReadOption) (*Iterator, error)

type Option

+ func MaxBillingTier(tier int) Option

+ func MaxBytesBilled(bytes int64) Option

+ func QueryUseStandardSQL() Option

type Query

+ func (q *Query) Read(ctx context.Context, options ...ReadOption) (*Iterator, error)

type Table

+ func (t *Table) Create(ctx context.Context, options ...CreateTableOption) error

+ func (t *Table) Read(_ context.Context, options ...ReadOption) (*Iterator, error)

+ type TableIterator struct

+ func (it *TableIterator) Next() (*Table, error)

+ func (it *TableIterator) PageInfo() *iterator.PageInfo

Aug 3, 2016

Changes in this version

+ const BatchPriority

+ const InteractivePriority

+ const Scope

+ type Client struct

+ func NewClient(ctx context.Context, projectID string, opts ...option.ClientOption) (*Client, error)

+ func (c *Client) Copy(ctx context.Context, dst Destination, src Source, options ...Option) (*Job, error)

+ func (c *Client) CreateTable(ctx context.Context, projectID, datasetID, tableID string, ...) (*Table, error)

+ func (c *Client) Dataset(id string) *Dataset

+ func (c *Client) JobFromID(ctx context.Context, id string) (*Job, error)

+ func (c *Client) NewGCSReference(uri ...string) *GCSReference

+ func (c *Client) OpenTable(projectID, datasetID, tableID string) *Table

+ func (c *Client) Read(ctx context.Context, src ReadSource, options ...ReadOption) (*Iterator, error)

+ type Compression string

+ const Gzip

+ const None

+ type CreateTableOption interface

+ func TableExpiration(exp time.Time) CreateTableOption

+ func ViewQuery(query string) CreateTableOption

+ type DataFormat string

+ const Avro

+ const CSV

+ const DatastoreBackup

+ const JSON

+ type Dataset struct

+ func (d *Dataset) Create(ctx context.Context) error

+ func (d *Dataset) ListTables(ctx context.Context) ([]*Table, error)

+ type Destination interface

+ type Encoding string

+ const ISO_8859_1

+ const UTF_8

+ type Error struct

+ Location string

+ Message string

+ Reason string

+ func (e Error) Error() string

+ type FieldSchema struct

+ Description string

+ Name string

+ Repeated bool

+ Required bool

+ Schema Schema

+ Type FieldType

+ type FieldType string

+ const BooleanFieldType

+ const FloatFieldType

+ const IntegerFieldType

+ const RecordFieldType

+ const StringFieldType

+ const TimestampFieldType

+ type GCSReference struct

+ Compression Compression

+ DestinationFormat DataFormat

+ Encoding Encoding

+ FieldDelimiter string

+ ForceZeroQuote bool

+ Quote string

+ SkipLeadingRows int64

+ SourceFormat DataFormat

+ type Iterator struct

+ func (it *Iterator) Err() error

+ func (it *Iterator) Get(dst interface{}) error

+ func (it *Iterator) Next(ctx context.Context) bool

+ func (it *Iterator) Schema() (Schema, error)

+ type Job struct

+ func (j *Job) ID() string

+ func (j *Job) Status(ctx context.Context) (*JobStatus, error)

+ type JobStatus struct

+ Errors []*Error

+ State State

+ func (s *JobStatus) Done() bool

+ func (s *JobStatus) Err() error

+ type MultiError []error

+ func (m MultiError) Error() string

+ type Option interface

+ func AllowJaggedRows() Option

+ func AllowLargeResults() Option

+ func AllowQuotedNewlines() Option

+ func CreateDisposition(disp TableCreateDisposition) Option

+ func DestinationSchema(schema Schema) Option

+ func DisableFlattenedResults() Option

+ func DisableHeader() Option

+ func DisableQueryCache() Option

+ func IgnoreUnknownValues() Option

+ func JobID(ID string) Option

+ func JobPriority(priority string) Option

+ func MaxBadRecords(n int64) Option

+ func WriteDisposition(disp TableWriteDisposition) Option

+ type PutMultiError []RowInsertionError

+ func (pme PutMultiError) Error() string

+ type Query struct

+ DefaultDatasetID string

+ DefaultProjectID string

+ Q string

+ type ReadOption interface

+ func RecordsPerRequest(n int64) ReadOption

+ func StartIndex(i uint64) ReadOption

+ type ReadSource interface

+ type RowInsertionError struct

+ Errors MultiError

+ InsertID string

+ RowIndex int

+ func (e *RowInsertionError) Error() string

+ type Schema []*FieldSchema

+ func InferSchema(st interface{}) (Schema, error)

+ type Source interface

+ type State int

+ const Done

+ const Pending

+ const Running

+ type Table struct

+ DatasetID string

+ ProjectID string

+ TableID string

+ func (t *Table) Delete(ctx context.Context) error

+ func (t *Table) FullyQualifiedName() string

+ func (t *Table) Metadata(ctx context.Context) (*TableMetadata, error)

+ func (t *Table) NewUploader(opts ...UploadOption) *Uploader

+ func (t *Table) Patch() *TableMetadataPatch

+ type TableCreateDisposition string

+ const CreateIfNeeded

+ const CreateNever

+ type TableMetadata struct

+ CreationTime time.Time

+ Description string

+ ExpirationTime time.Time

+ ID string

+ LastModifiedTime time.Time

+ Name string

+ NumBytes int64

+ NumRows uint64

+ Schema Schema

+ Type TableType

+ View string

+ type TableMetadataPatch struct

+ func (p *TableMetadataPatch) Apply(ctx context.Context) (*TableMetadata, error)

+ func (p *TableMetadataPatch) Description(desc string)

+ func (p *TableMetadataPatch) Name(name string)

+ type TableType string

+ const RegularTable

+ const ViewTable

+ type TableWriteDisposition string

+ const WriteAppend

+ const WriteEmpty

+ const WriteTruncate

+ type Tables []*Table

+ type UploadOption interface

+ func SkipInvalidRows() UploadOption

+ func TableTemplateSuffix(suffix string) UploadOption

+ func UploadIgnoreUnknownValues() UploadOption

+ type Uploader struct

+ func (u *Uploader) Put(ctx context.Context, src interface{}) error

+ type Value interface

+ type ValueList []Value

+ func (vs *ValueList) Load(v []Value) error

+ type ValueLoader interface

+ Load func(v []Value) error

+ type ValueSaver interface

+ Save func() (row map[string]Value, insertID string, err error)

+ type ValuesSaver struct

+ InsertID string

+ Row []Value

+ Schema Schema

+ func (vls *ValuesSaver) Save() (map[string]Value, string, error)