Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidProjectName = errors.New("Invalid project name") ErrInvalidDatasetName = errors.New("Invalid dataset name") ErrInvalidTableName = errors.New("Invalid table name") ErrInvalidFQTable = errors.New("Invalid fully qualified table name") )
These errors are self-explanatory.
Functions ¶
func Customize ¶
Customize recursively traverses a schema, substituting any fields that have a matching name in the provided map.
func PrettyPrint ¶
PrettyPrint generates a formatted json representation of a Schema. It simplifies the schema by removing zero valued fields, and compacting each field record onto a single line. Intended for diagnostics and debugging. Not suitable for production use.
Types ¶
type PDT ¶
PDT contains a bigquery project, dataset, and table name.
func ParsePDT ¶
ParsePDT parses and validates a fully qualified bigquery table name of the form project.dataset.table. None of the elements needs to exist, but all must conform to the corresponding naming restrictions.
func (PDT) CreateTable ¶
func (pdt PDT) CreateTable(ctx context.Context, client *bigquery.Client, schema bigquery.Schema, description string, partitioning *bigquery.TimePartitioning, clustering *bigquery.Clustering) error
CreateTable will create a new table, or fail if the table already exists. It will also set appropriate time-partitioning field and clustering fields if non-nil arguments are provided. Returns error if the dataset does not already exist, or if other errors are encountered.
Source Files