bigquery

package

Go to main page

Versions in this module

v0

v0.34.0

Dec 5, 2018

v0.33.1

Nov 15, 2018

Changes in this version

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

+ type Inserter struct

+ IgnoreUnknownValues bool

+ SkipInvalidRows bool

+ TableTemplateSuffix string

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

type Schema

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

type Table

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

type TableMetadataToUpdate

+ EncryptionConfig *EncryptionConfig

+ TimePartitioning *TimePartitioning

type TimePartitioning

+ RequirePartitionFilter bool

v0.33.0

Nov 13, 2018

v0.32.0

Oct 31, 2018

v0.31.0

Oct 23, 2018

v0.30.0

Oct 8, 2018

v0.29.0

Oct 3, 2018

v0.28.0

Sep 17, 2018

v0.27.0

Sep 4, 2018

v0.26.0

Aug 7, 2018

Changes in this version

+ const NumericPrecisionDigits

+ const NumericScaleDigits

+ func CivilDateTimeString(dt civil.DateTime) string

+ func CivilTimeString(t civil.Time) string

+ func NumericString(r *big.Rat) string

+ func Seed(s int64)

+ 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 Client

+ Location string

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

+ type Clustering struct

+ Fields []string

type CopyConfig

+ DestinationEncryptionConfig *EncryptionConfig

+ Labels map[string]string

type DataFormat

+ const Bigtable

+ const GoogleSheets

+ const ORC

+ const Parquet

type Dataset

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

type DatasetMetadata

+ Access []*AccessEntry

type DatasetMetadataToUpdate

+ Access []*AccessEntry

+ type EncryptionConfig struct

+ KMSKeyName string

+ type EntityType int

+ const DomainEntity

+ const GroupEmailEntity

+ const SpecialGroupEntity

+ const UserEmailEntity

+ const ViewEntity

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 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 FieldType

+ const NumericFieldType

type GCSReference

+ URIs []string

+ type GoogleSheetsOptions struct

+ SkipLeadingRows int64

type Job

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

+ func (j *Job) Email() string

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

+ func (j *Job) Location() string

+ type JobConfig interface

+ type JobIDConfig struct

+ AddJobIDSuffix bool

+ JobID string

+ Location string

type JobIterator

+ MaxCreationTime time.Time

+ MinCreationTime time.Time

type LoadConfig

+ Clustering *Clustering

+ DestinationEncryptionConfig *EncryptionConfig

+ Labels map[string]string

+ SchemaUpdateOptions []string

+ TimePartitioning *TimePartitioning

+ type NullBool struct

+ Bool bool

+ Valid bool

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

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

+ func (n NullBool) String() string

+ type NullDate struct

+ Date civil.Date

+ Valid bool

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

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

+ func (n NullDate) String() string

+ type NullDateTime struct

+ DateTime civil.DateTime

+ Valid bool

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

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

+ func (n NullDateTime) String() string

+ type NullFloat64 struct

+ Float64 float64

+ Valid bool

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

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

+ func (n NullFloat64) String() string

+ type NullInt64 struct

+ Int64 int64

+ Valid bool

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

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

+ func (n NullInt64) String() string

+ type NullString struct

+ StringVal string

+ Valid bool

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

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

+ func (n NullString) String() string

+ type NullTime struct

+ Time civil.Time

+ Valid bool

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

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

+ func (n NullTime) String() string

+ type NullTimestamp struct

+ Timestamp time.Time

+ Valid bool

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

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

+ func (n NullTimestamp) String() string

type QueryConfig

+ Clustering *Clustering

+ DestinationEncryptionConfig *EncryptionConfig

+ DryRun bool

+ Labels map[string]string

+ SchemaUpdateOptions []string

+ TimePartitioning *TimePartitioning

type QueryStatistics

+ DDLOperationPerformed string

+ DDLTargetTable *Table

+ SlotMillis int64

+ Timeline []*QueryTimelineSample

+ type QueryTimelineSample struct

+ ActiveUnits int64

+ CompletedUnits int64

+ Elapsed time.Duration

+ PendingUnits int64

+ SlotMillis int64

type RowIterator

+ TotalRows uint64

type TableMetadata

+ Clustering *Clustering

+ EncryptionConfig *EncryptionConfig

+ 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)

type TimePartitioning

+ Field string

v0.25.0

Jul 12, 2018

v0.24.0

Jun 20, 2018

v0.23.0

May 18, 2018

v0.22.0

May 9, 2018

v0.21.0

Apr 9, 2018

v0.20.0

Mar 22, 2018

v0.19.0

Feb 27, 2018

v0.18.0

Jan 19, 2018

v0.17.0

Dec 11, 2017

v0.16.0

Nov 1, 2017

v0.15.0

Oct 3, 2017

Changes in this version

type Client

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

type CopyConfig

+ AddJobIDSuffix bool

type Dataset

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

type DatasetIterator

+ ProjectID string

type DatasetMetadata

+ ETag string

+ FullID string

+ type DatasetMetadataToUpdate struct

+ DefaultTableExpiration optional.Duration

+ Description optional.String

+ Name optional.String

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

+ func (dm *DatasetMetadataToUpdate) SetLabel(name, value 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

+ UseLegacySQL bool

type State

+ const StateUnspecified

type TableMetadata

+ ETag string

+ FullID string

+ UseLegacySQL bool

+ UseStandardSQL bool

+ ViewQuery string

type TableMetadataToUpdate

+ ExpirationTime time.Time

v0.14.0

Sep 27, 2017

v0.13.0

Sep 11, 2017

v0.12.0

Aug 22, 2017

v0.11.0

Jul 31, 2017

v0.10.0

Jun 30, 2017

v0.9.0

Jun 21, 2017

v0.8.0

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

v0.7.0

Mar 10, 2017

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

+ const DateFieldType

+ const DateTimeFieldType

+ const TimeFieldType

+ type FileConfig struct

+ AllowJaggedRows bool

+ AllowQuotedNewlines bool

+ AutoDetect 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 Job

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

+ type LoadSource interface

type QueryConfig

+ Parameters []QueryParameter

+ type QueryParameter struct

+ Name string

+ Value interface{}

+ type ReaderSource struct

+ func NewReaderSource(r io.Reader) *ReaderSource

+ type StructSaver struct

+ InsertID string

+ Schema Schema

+ Struct interface{}

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

type Table

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

type TableMetadata

+ TimePartitioning *TimePartitioning

type TableMetadataToUpdate

+ Schema Schema

+ type TimePartitioning struct

+ Expiration time.Duration

type Uploader

+ IgnoreUnknownValues bool

+ SkipInvalidRows bool

+ TableTemplateSuffix string

v0.6.0

Dec 10, 2016

v0.5.0

Nov 30, 2016

v0.4.0

Nov 1, 2016

v0.3.0

Oct 14, 2016

Changes in this version

+ const Scope

+ type Client struct

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

+ func (c *Client) Close() 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) 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) 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) Query(q string) *Query

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

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

+ type Compression string

+ const Gzip

+ const None

+ 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 CreateTableOption interface

+ func TableExpiration(exp time.Time) CreateTableOption

+ func UseStandardSQL() 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)

+ 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 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 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 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

+ AllowJaggedRows bool

+ AllowQuotedNewlines bool

+ Compression Compression

+ DestinationFormat DataFormat

+ Encoding Encoding

+ FieldDelimiter string

+ ForceZeroQuote bool

+ IgnoreUnknownValues bool

+ MaxBadRecords int64

+ Quote string

+ Schema Schema

+ 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) Cancel(ctx context.Context) error

+ func (j *Job) ID() string

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

+ 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 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 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 MaxBillingTier(tier int) Option

+ func MaxBytesBilled(bytes int64) Option

+ func QueryUseStandardSQL() Option

+ func WriteDisposition(disp TableWriteDisposition) Option

+ type PutMultiError []RowInsertionError

+ func (pme PutMultiError) Error() string

+ type Query struct

+ DefaultDatasetID string

+ DefaultProjectID string

+ Q string

+ TableDefinitions map[string]ExternalData

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

+ 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

+ const BatchPriority

+ const InteractivePriority

+ 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 RowIterator struct

+ StartIndex uint64

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

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

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

+ 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) CopierFrom(srcs ...*Table) *Copier

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

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

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

+ func (t *Table) FullyQualifiedName() string

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

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

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

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

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

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

+ type TableCreateDisposition string

+ const CreateIfNeeded

+ const CreateNever

+ type TableIterator struct

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

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

+ 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 TableMetadataToUpdate struct

+ Description optional.String

+ Name optional.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)

v0.2.0

Oct 3, 2016

v0.1.0

Aug 3, 2016

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL