| Index: generated/googleapis/lib/bigquery/v2.dart
|
| diff --git a/generated/googleapis/lib/bigquery/v2.dart b/generated/googleapis/lib/bigquery/v2.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..74229c99e923cde88e304ea388a767430804ea63
|
| --- /dev/null
|
| +++ b/generated/googleapis/lib/bigquery/v2.dart
|
| @@ -0,0 +1,4061 @@
|
| +library googleapis.bigquery.v2;
|
| +
|
| +import "dart:core" as core;
|
| +import "dart:collection" as collection;
|
| +import "dart:async" as async;
|
| +import "dart:convert" as convert;
|
| +
|
| +import "package:crypto/crypto.dart" as crypto;
|
| +import 'package:http/http.dart' as http;
|
| +import '../src/common_internal.dart' as common_internal;
|
| +import '../common/common.dart' as common;
|
| +
|
| +export '../common/common.dart' show ApiRequestError;
|
| +export '../common/common.dart' show DetailedApiRequestError;
|
| +
|
| +/** A data platform for customers to create, manage, share and query data. */
|
| +class BigqueryApi {
|
| + /** View and manage your data in Google BigQuery */
|
| + static const BigqueryScope = "https://www.googleapis.com/auth/bigquery";
|
| +
|
| + /** Insert data into Google BigQuery */
|
| + static const BigqueryInsertdataScope = "https://www.googleapis.com/auth/bigquery.insertdata";
|
| +
|
| + /** View and manage your data across Google Cloud Platform services */
|
| + static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform";
|
| +
|
| + /** Manage your data and permissions in Google Cloud Storage */
|
| + static const DevstorageFullControlScope = "https://www.googleapis.com/auth/devstorage.full_control";
|
| +
|
| + /** View your data in Google Cloud Storage */
|
| + static const DevstorageReadOnlyScope = "https://www.googleapis.com/auth/devstorage.read_only";
|
| +
|
| + /** Manage your data in Google Cloud Storage */
|
| + static const DevstorageReadWriteScope = "https://www.googleapis.com/auth/devstorage.read_write";
|
| +
|
| +
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + DatasetsResourceApi get datasets => new DatasetsResourceApi(_requester);
|
| + JobsResourceApi get jobs => new JobsResourceApi(_requester);
|
| + ProjectsResourceApi get projects => new ProjectsResourceApi(_requester);
|
| + TabledataResourceApi get tabledata => new TabledataResourceApi(_requester);
|
| + TablesResourceApi get tables => new TablesResourceApi(_requester);
|
| +
|
| + BigqueryApi(http.Client client) :
|
| + _requester = new common_internal.ApiRequester(client, "https://www.googleapis.com/", "/bigquery/v2/");
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class DatasetsResourceApi {
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + DatasetsResourceApi(common_internal.ApiRequester client) :
|
| + _requester = client;
|
| +
|
| + /**
|
| + * Deletes the dataset specified by the datasetId value. Before you can delete
|
| + * a dataset, you must delete all its tables, either manually or by specifying
|
| + * deleteContents. Immediately after deletion, you can create another dataset
|
| + * with the same name.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the dataset being deleted
|
| + *
|
| + * [datasetId] - Dataset ID of dataset being deleted
|
| + *
|
| + * [deleteContents] - If True, delete all the tables in the dataset. If False
|
| + * and the dataset contains tables, the request will fail. Default is False
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future delete(core.String projectId, core.String datasetId, {core.bool deleteContents}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (deleteContents != null) {
|
| + _queryParams["deleteContents"] = ["${deleteContents}"];
|
| + }
|
| +
|
| + _downloadOptions = null;
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "DELETE",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => null);
|
| + }
|
| +
|
| + /**
|
| + * Returns the dataset specified by datasetID.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the requested dataset
|
| + *
|
| + * [datasetId] - Dataset ID of the requested dataset
|
| + *
|
| + * Completes with a [Dataset].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Dataset> get(core.String projectId, core.String datasetId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Dataset.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Creates a new empty dataset.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the new dataset
|
| + *
|
| + * Completes with a [Dataset].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Dataset> insert(Dataset request, core.String projectId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Dataset.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Lists all the datasets in the specified project to which the caller has
|
| + * read access; however, a project owner can list (but not necessarily get)
|
| + * all datasets in his project.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the datasets to be listed
|
| + *
|
| + * [all] - Whether to list all datasets, including hidden ones
|
| + *
|
| + * [maxResults] - The maximum number of results to return
|
| + *
|
| + * [pageToken] - Page token, returned by a previous call, to request the next
|
| + * page of results
|
| + *
|
| + * Completes with a [DatasetList].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<DatasetList> list(core.String projectId, {core.bool all, core.int maxResults, core.String pageToken}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (all != null) {
|
| + _queryParams["all"] = ["${all}"];
|
| + }
|
| + if (maxResults != null) {
|
| + _queryParams["maxResults"] = ["${maxResults}"];
|
| + }
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new DatasetList.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Updates information in an existing dataset. The update method replaces the
|
| + * entire dataset resource, whereas the patch method only replaces fields that
|
| + * are provided in the submitted dataset resource. This method supports patch
|
| + * semantics.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the dataset being updated
|
| + *
|
| + * [datasetId] - Dataset ID of the dataset being updated
|
| + *
|
| + * Completes with a [Dataset].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Dataset> patch(Dataset request, core.String projectId, core.String datasetId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "PATCH",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Dataset.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Updates information in an existing dataset. The update method replaces the
|
| + * entire dataset resource, whereas the patch method only replaces fields that
|
| + * are provided in the submitted dataset resource.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the dataset being updated
|
| + *
|
| + * [datasetId] - Dataset ID of the dataset being updated
|
| + *
|
| + * Completes with a [Dataset].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Dataset> update(Dataset request, core.String projectId, core.String datasetId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "PUT",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Dataset.fromJson(data));
|
| + }
|
| +
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobsResourceApi {
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + JobsResourceApi(common_internal.ApiRequester client) :
|
| + _requester = client;
|
| +
|
| + /**
|
| + * Retrieves the specified job by ID.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the requested job
|
| + *
|
| + * [jobId] - Job ID of the requested job
|
| + *
|
| + * Completes with a [Job].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Job> get(core.String projectId, core.String jobId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (jobId == null) {
|
| + throw new core.ArgumentError("Parameter jobId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Job.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Retrieves the results of a query job.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the query job
|
| + *
|
| + * [jobId] - Job ID of the query job
|
| + *
|
| + * [maxResults] - Maximum number of results to read
|
| + *
|
| + * [pageToken] - Page token, returned by a previous call, to request the next
|
| + * page of results
|
| + *
|
| + * [startIndex] - Zero-based index of the starting row
|
| + *
|
| + * [timeoutMs] - How long to wait for the query to complete, in milliseconds,
|
| + * before returning. Default is to return immediately. If the timeout passes
|
| + * before the job completes, the request will fail with a TIMEOUT error
|
| + *
|
| + * Completes with a [GetQueryResultsResponse].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<GetQueryResultsResponse> getQueryResults(core.String projectId, core.String jobId, {core.int maxResults, core.String pageToken, core.String startIndex, core.int timeoutMs}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (jobId == null) {
|
| + throw new core.ArgumentError("Parameter jobId is required.");
|
| + }
|
| + if (maxResults != null) {
|
| + _queryParams["maxResults"] = ["${maxResults}"];
|
| + }
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
| + if (startIndex != null) {
|
| + _queryParams["startIndex"] = [startIndex];
|
| + }
|
| + if (timeoutMs != null) {
|
| + _queryParams["timeoutMs"] = ["${timeoutMs}"];
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/queries/' + common_internal.Escaper.ecapeVariable('$jobId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new GetQueryResultsResponse.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Starts a new asynchronous job.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the project that will be billed for the job
|
| + *
|
| + * [uploadMedia] - The media to upload.
|
| + *
|
| + * [uploadOptions] - Options for the media upload. Streaming Media without the
|
| + * length being known ahead of time is only supported via resumable uploads.
|
| + *
|
| + * Completes with a [Job].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Job> insert(Job request, core.String projectId, {common.UploadOptions uploadOptions : common.UploadOptions.Default, common.Media uploadMedia}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| +
|
| + _uploadMedia = uploadMedia;
|
| + _uploadOptions = uploadOptions;
|
| +
|
| + if (_uploadMedia == null) {
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
|
| + } else if (_uploadOptions is common.ResumableUploadOptions) {
|
| + _url = '/resumable/upload/bigquery/v2/projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
|
| + } else {
|
| + _url = '/upload/bigquery/v2/projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
|
| + }
|
| +
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Job.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Lists all the Jobs in the specified project that were started by the user.
|
| + * The job list returns in reverse chronological order of when the jobs were
|
| + * created, starting with the most recent job created.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the jobs to list
|
| + *
|
| + * [allUsers] - Whether to display jobs owned by all users in the project.
|
| + * Default false
|
| + *
|
| + * [maxResults] - Maximum number of results to return
|
| + *
|
| + * [pageToken] - Page token, returned by a previous call, to request the next
|
| + * page of results
|
| + *
|
| + * [projection] - Restrict information returned to a set of selected fields
|
| + * Possible string values are:
|
| + * - "full" : Includes all job data
|
| + * - "minimal" : Does not include the job configuration
|
| + *
|
| + * [stateFilter] - Filter for job state
|
| + *
|
| + * Completes with a [JobList].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<JobList> list(core.String projectId, {core.bool allUsers, core.int maxResults, core.String pageToken, core.String projection, core.List<core.String> stateFilter}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (allUsers != null) {
|
| + _queryParams["allUsers"] = ["${allUsers}"];
|
| + }
|
| + if (maxResults != null) {
|
| + _queryParams["maxResults"] = ["${maxResults}"];
|
| + }
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
| + if (projection != null) {
|
| + _queryParams["projection"] = [projection];
|
| + }
|
| + if (stateFilter != null) {
|
| + _queryParams["stateFilter"] = stateFilter;
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new JobList.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Runs a BigQuery SQL query synchronously and returns query results if the
|
| + * query completes within a specified timeout.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the project billed for the query
|
| + *
|
| + * Completes with a [QueryResponse].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<QueryResponse> query(QueryRequest request, core.String projectId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/queries';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new QueryResponse.fromJson(data));
|
| + }
|
| +
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class ProjectsResourceApi {
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + ProjectsResourceApi(common_internal.ApiRequester client) :
|
| + _requester = client;
|
| +
|
| + /**
|
| + * Lists the projects to which you have at least read access.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [maxResults] - Maximum number of results to return
|
| + *
|
| + * [pageToken] - Page token, returned by a previous call, to request the next
|
| + * page of results
|
| + *
|
| + * Completes with a [ProjectList].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<ProjectList> list({core.int maxResults, core.String pageToken}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (maxResults != null) {
|
| + _queryParams["maxResults"] = ["${maxResults}"];
|
| + }
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
| +
|
| +
|
| + _url = 'projects';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new ProjectList.fromJson(data));
|
| + }
|
| +
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TabledataResourceApi {
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + TabledataResourceApi(common_internal.ApiRequester client) :
|
| + _requester = client;
|
| +
|
| + /**
|
| + * Streams data into BigQuery one record at a time without needing to run a
|
| + * load job.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the destination table.
|
| + *
|
| + * [datasetId] - Dataset ID of the destination table.
|
| + *
|
| + * [tableId] - Table ID of the destination table.
|
| + *
|
| + * Completes with a [TableDataInsertAllResponse].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<TableDataInsertAllResponse> insertAll(TableDataInsertAllRequest request, core.String projectId, core.String datasetId, core.String tableId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (tableId == null) {
|
| + throw new core.ArgumentError("Parameter tableId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables/' + common_internal.Escaper.ecapeVariable('$tableId') + '/insertAll';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new TableDataInsertAllResponse.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Retrieves table data from a specified set of rows.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the table to read
|
| + *
|
| + * [datasetId] - Dataset ID of the table to read
|
| + *
|
| + * [tableId] - Table ID of the table to read
|
| + *
|
| + * [maxResults] - Maximum number of results to return
|
| + *
|
| + * [pageToken] - Page token, returned by a previous call, identifying the
|
| + * result set
|
| + *
|
| + * [startIndex] - Zero-based index of the starting row to read
|
| + *
|
| + * Completes with a [TableDataList].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<TableDataList> list(core.String projectId, core.String datasetId, core.String tableId, {core.int maxResults, core.String pageToken, core.String startIndex}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (tableId == null) {
|
| + throw new core.ArgumentError("Parameter tableId is required.");
|
| + }
|
| + if (maxResults != null) {
|
| + _queryParams["maxResults"] = ["${maxResults}"];
|
| + }
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
| + if (startIndex != null) {
|
| + _queryParams["startIndex"] = [startIndex];
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables/' + common_internal.Escaper.ecapeVariable('$tableId') + '/data';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new TableDataList.fromJson(data));
|
| + }
|
| +
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TablesResourceApi {
|
| + final common_internal.ApiRequester _requester;
|
| +
|
| + TablesResourceApi(common_internal.ApiRequester client) :
|
| + _requester = client;
|
| +
|
| + /**
|
| + * Deletes the table specified by tableId from the dataset. If the table
|
| + * contains data, all the data will be deleted.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the table to delete
|
| + *
|
| + * [datasetId] - Dataset ID of the table to delete
|
| + *
|
| + * [tableId] - Table ID of the table to delete
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future delete(core.String projectId, core.String datasetId, core.String tableId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (tableId == null) {
|
| + throw new core.ArgumentError("Parameter tableId is required.");
|
| + }
|
| +
|
| + _downloadOptions = null;
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables/' + common_internal.Escaper.ecapeVariable('$tableId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "DELETE",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => null);
|
| + }
|
| +
|
| + /**
|
| + * Gets the specified table resource by table ID. This method does not return
|
| + * the data in the table, it only returns the table resource, which describes
|
| + * the structure of this table.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the requested table
|
| + *
|
| + * [datasetId] - Dataset ID of the requested table
|
| + *
|
| + * [tableId] - Table ID of the requested table
|
| + *
|
| + * Completes with a [Table].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Table> get(core.String projectId, core.String datasetId, core.String tableId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (tableId == null) {
|
| + throw new core.ArgumentError("Parameter tableId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables/' + common_internal.Escaper.ecapeVariable('$tableId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Table.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Creates a new, empty table in the dataset.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the new table
|
| + *
|
| + * [datasetId] - Dataset ID of the new table
|
| + *
|
| + * Completes with a [Table].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Table> insert(Table request, core.String projectId, core.String datasetId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "POST",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Table.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Lists all tables in the specified dataset.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the tables to list
|
| + *
|
| + * [datasetId] - Dataset ID of the tables to list
|
| + *
|
| + * [maxResults] - Maximum number of results to return
|
| + *
|
| + * [pageToken] - Page token, returned by a previous call, to request the next
|
| + * page of results
|
| + *
|
| + * Completes with a [TableList].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<TableList> list(core.String projectId, core.String datasetId, {core.int maxResults, core.String pageToken}) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (maxResults != null) {
|
| + _queryParams["maxResults"] = ["${maxResults}"];
|
| + }
|
| + if (pageToken != null) {
|
| + _queryParams["pageToken"] = [pageToken];
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new TableList.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Updates information in an existing table. The update method replaces the
|
| + * entire table resource, whereas the patch method only replaces fields that
|
| + * are provided in the submitted table resource. This method supports patch
|
| + * semantics.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the table to update
|
| + *
|
| + * [datasetId] - Dataset ID of the table to update
|
| + *
|
| + * [tableId] - Table ID of the table to update
|
| + *
|
| + * Completes with a [Table].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Table> patch(Table request, core.String projectId, core.String datasetId, core.String tableId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (tableId == null) {
|
| + throw new core.ArgumentError("Parameter tableId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables/' + common_internal.Escaper.ecapeVariable('$tableId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "PATCH",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Table.fromJson(data));
|
| + }
|
| +
|
| + /**
|
| + * Updates information in an existing table. The update method replaces the
|
| + * entire table resource, whereas the patch method only replaces fields that
|
| + * are provided in the submitted table resource.
|
| + *
|
| + * [request] - The metadata request object.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - Project ID of the table to update
|
| + *
|
| + * [datasetId] - Dataset ID of the table to update
|
| + *
|
| + * [tableId] - Table ID of the table to update
|
| + *
|
| + * Completes with a [Table].
|
| + *
|
| + * Completes with a [common.ApiRequestError] if the API endpoint returned an
|
| + * error.
|
| + *
|
| + * If the used [http.Client] completes with an error when making a REST call,
|
| + * this method will complete with the same error.
|
| + */
|
| + async.Future<Table> update(Table request, core.String projectId, core.String datasetId, core.String tableId) {
|
| + var _url = null;
|
| + var _queryParams = new core.Map();
|
| + var _uploadMedia = null;
|
| + var _uploadOptions = null;
|
| + var _downloadOptions = common.DownloadOptions.Metadata;
|
| + var _body = null;
|
| +
|
| + if (request != null) {
|
| + _body = convert.JSON.encode((request).toJson());
|
| + }
|
| + if (projectId == null) {
|
| + throw new core.ArgumentError("Parameter projectId is required.");
|
| + }
|
| + if (datasetId == null) {
|
| + throw new core.ArgumentError("Parameter datasetId is required.");
|
| + }
|
| + if (tableId == null) {
|
| + throw new core.ArgumentError("Parameter tableId is required.");
|
| + }
|
| +
|
| +
|
| + _url = 'projects/' + common_internal.Escaper.ecapeVariable('$projectId') + '/datasets/' + common_internal.Escaper.ecapeVariable('$datasetId') + '/tables/' + common_internal.Escaper.ecapeVariable('$tableId');
|
| +
|
| + var _response = _requester.request(_url,
|
| + "PUT",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new Table.fromJson(data));
|
| + }
|
| +
|
| +}
|
| +
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class DatasetAccess {
|
| + /**
|
| + * [Pick one] A domain to grant access to. Any users signed in with the domain
|
| + * specified will be granted the specified access. Example: "example.com".
|
| + */
|
| + core.String domain;
|
| +
|
| + /** [Pick one] An email address of a Google Group to grant access to. */
|
| + core.String groupByEmail;
|
| +
|
| + /**
|
| + * [Required] Describes the rights granted to the user specified by the other
|
| + * member of the access object. The following string values are supported:
|
| + * READER, WRITER, OWNER.
|
| + */
|
| + core.String role;
|
| +
|
| + /**
|
| + * [Pick one] A special group to grant access to. Possible values include:
|
| + * projectOwners: Owners of the enclosing project. projectReaders: Readers of
|
| + * the enclosing project. projectWriters: Writers of the enclosing project.
|
| + * allAuthenticatedUsers: All authenticated BigQuery users.
|
| + */
|
| + core.String specialGroup;
|
| +
|
| + /**
|
| + * [Pick one] An email address of a user to grant access to. For example:
|
| + * fred@example.com.
|
| + */
|
| + core.String userByEmail;
|
| +
|
| + /**
|
| + * [Pick one] A view from a different dataset to grant access to. Queries
|
| + * executed against that view will have read access to tables in this dataset.
|
| + * The role field is not required when this field is set. If that view is
|
| + * updated by any user, access to the view needs to be granted again via an
|
| + * update operation.
|
| + */
|
| + TableReference view;
|
| +
|
| +
|
| + DatasetAccess();
|
| +
|
| + DatasetAccess.fromJson(core.Map _json) {
|
| + if (_json.containsKey("domain")) {
|
| + domain = _json["domain"];
|
| + }
|
| + if (_json.containsKey("groupByEmail")) {
|
| + groupByEmail = _json["groupByEmail"];
|
| + }
|
| + if (_json.containsKey("role")) {
|
| + role = _json["role"];
|
| + }
|
| + if (_json.containsKey("specialGroup")) {
|
| + specialGroup = _json["specialGroup"];
|
| + }
|
| + if (_json.containsKey("userByEmail")) {
|
| + userByEmail = _json["userByEmail"];
|
| + }
|
| + if (_json.containsKey("view")) {
|
| + view = new TableReference.fromJson(_json["view"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (domain != null) {
|
| + _json["domain"] = domain;
|
| + }
|
| + if (groupByEmail != null) {
|
| + _json["groupByEmail"] = groupByEmail;
|
| + }
|
| + if (role != null) {
|
| + _json["role"] = role;
|
| + }
|
| + if (specialGroup != null) {
|
| + _json["specialGroup"] = specialGroup;
|
| + }
|
| + if (userByEmail != null) {
|
| + _json["userByEmail"] = userByEmail;
|
| + }
|
| + if (view != null) {
|
| + _json["view"] = (view).toJson();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class Dataset {
|
| + /**
|
| + * [Optional] An array of objects that define dataset access for one or more
|
| + * entities. You can set this property when inserting or updating a dataset in
|
| + * order to control who is allowed to access the data. If unspecified at
|
| + * dataset creation time, BigQuery adds default dataset access for the
|
| + * following entities: access.specialGroup: projectReaders; access.role:
|
| + * READER; access.specialGroup: projectWriters; access.role: WRITER;
|
| + * access.specialGroup: projectOwners; access.role: OWNER; access.userByEmail:
|
| + * [dataset creator email]; access.role: OWNER;
|
| + */
|
| + core.List<DatasetAccess> access;
|
| +
|
| + /**
|
| + * [Output-only] The time when this dataset was created, in milliseconds since
|
| + * the epoch.
|
| + */
|
| + core.String creationTime;
|
| +
|
| + /** [Required] A reference that identifies the dataset. */
|
| + DatasetReference datasetReference;
|
| +
|
| + /** [Optional] A user-friendly description of the dataset. */
|
| + core.String description;
|
| +
|
| + /** [Output-only] A hash of the resource. */
|
| + core.String etag;
|
| +
|
| + /** [Optional] A descriptive name for the dataset. */
|
| + core.String friendlyName;
|
| +
|
| + /**
|
| + * [Output-only] The fully-qualified unique name of the dataset in the format
|
| + * projectId:datasetId. The dataset name without the project name is given in
|
| + * the datasetId field. When creating a new dataset, leave this field blank,
|
| + * and instead specify the datasetId field.
|
| + */
|
| + core.String id;
|
| +
|
| + /** [Output-only] The resource type. */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * [Output-only] The date when this dataset or any of its tables was last
|
| + * modified, in milliseconds since the epoch.
|
| + */
|
| + core.String lastModifiedTime;
|
| +
|
| + /**
|
| + * [Output-only] A URL that can be used to access the resource again. You can
|
| + * use this URL in Get or Update requests to the resource.
|
| + */
|
| + core.String selfLink;
|
| +
|
| +
|
| + Dataset();
|
| +
|
| + Dataset.fromJson(core.Map _json) {
|
| + if (_json.containsKey("access")) {
|
| + access = _json["access"].map((value) => new DatasetAccess.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("creationTime")) {
|
| + creationTime = _json["creationTime"];
|
| + }
|
| + if (_json.containsKey("datasetReference")) {
|
| + datasetReference = new DatasetReference.fromJson(_json["datasetReference"]);
|
| + }
|
| + if (_json.containsKey("description")) {
|
| + description = _json["description"];
|
| + }
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("friendlyName")) {
|
| + friendlyName = _json["friendlyName"];
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("lastModifiedTime")) {
|
| + lastModifiedTime = _json["lastModifiedTime"];
|
| + }
|
| + if (_json.containsKey("selfLink")) {
|
| + selfLink = _json["selfLink"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (access != null) {
|
| + _json["access"] = access.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (creationTime != null) {
|
| + _json["creationTime"] = creationTime;
|
| + }
|
| + if (datasetReference != null) {
|
| + _json["datasetReference"] = (datasetReference).toJson();
|
| + }
|
| + if (description != null) {
|
| + _json["description"] = description;
|
| + }
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (friendlyName != null) {
|
| + _json["friendlyName"] = friendlyName;
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (lastModifiedTime != null) {
|
| + _json["lastModifiedTime"] = lastModifiedTime;
|
| + }
|
| + if (selfLink != null) {
|
| + _json["selfLink"] = selfLink;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class DatasetListDatasets {
|
| + /**
|
| + * The dataset reference. Use this property to access specific parts of the
|
| + * dataset's ID, such as project ID or dataset ID.
|
| + */
|
| + DatasetReference datasetReference;
|
| +
|
| + /** A descriptive name for the dataset, if one exists. */
|
| + core.String friendlyName;
|
| +
|
| + /** The fully-qualified, unique, opaque ID of the dataset. */
|
| + core.String id;
|
| +
|
| + /**
|
| + * The resource type. This property always returns the value
|
| + * "bigquery#dataset".
|
| + */
|
| + core.String kind;
|
| +
|
| +
|
| + DatasetListDatasets();
|
| +
|
| + DatasetListDatasets.fromJson(core.Map _json) {
|
| + if (_json.containsKey("datasetReference")) {
|
| + datasetReference = new DatasetReference.fromJson(_json["datasetReference"]);
|
| + }
|
| + if (_json.containsKey("friendlyName")) {
|
| + friendlyName = _json["friendlyName"];
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (datasetReference != null) {
|
| + _json["datasetReference"] = (datasetReference).toJson();
|
| + }
|
| + if (friendlyName != null) {
|
| + _json["friendlyName"] = friendlyName;
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class DatasetList {
|
| + /**
|
| + * An array of the dataset resources in the project. Each resource contains
|
| + * basic information. For full information about a particular dataset
|
| + * resource, use the Datasets: get method. This property is omitted when there
|
| + * are no datasets in the project.
|
| + */
|
| + core.List<DatasetListDatasets> datasets;
|
| +
|
| + /**
|
| + * A hash value of the results page. You can use this property to determine if
|
| + * the page has changed since the last request.
|
| + */
|
| + core.String etag;
|
| +
|
| + /**
|
| + * The list type. This property always returns the value
|
| + * "bigquery#datasetList".
|
| + */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * A token that can be used to request the next results page. This property is
|
| + * omitted on the final results page.
|
| + */
|
| + core.String nextPageToken;
|
| +
|
| +
|
| + DatasetList();
|
| +
|
| + DatasetList.fromJson(core.Map _json) {
|
| + if (_json.containsKey("datasets")) {
|
| + datasets = _json["datasets"].map((value) => new DatasetListDatasets.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("nextPageToken")) {
|
| + nextPageToken = _json["nextPageToken"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (datasets != null) {
|
| + _json["datasets"] = datasets.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (nextPageToken != null) {
|
| + _json["nextPageToken"] = nextPageToken;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class DatasetReference {
|
| + /** [Required] A unique ID for this dataset, without the project name. */
|
| + core.String datasetId;
|
| +
|
| + /** [Optional] The ID of the container project. */
|
| + core.String projectId;
|
| +
|
| +
|
| + DatasetReference();
|
| +
|
| + DatasetReference.fromJson(core.Map _json) {
|
| + if (_json.containsKey("datasetId")) {
|
| + datasetId = _json["datasetId"];
|
| + }
|
| + if (_json.containsKey("projectId")) {
|
| + projectId = _json["projectId"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (datasetId != null) {
|
| + _json["datasetId"] = datasetId;
|
| + }
|
| + if (projectId != null) {
|
| + _json["projectId"] = projectId;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class ErrorProto {
|
| + /**
|
| + * Debugging information. This property is internal to Google and should not
|
| + * be used.
|
| + */
|
| + core.String debugInfo;
|
| +
|
| + /** Specifies where the error occurred, if present. */
|
| + core.String location;
|
| +
|
| + /** A human-readable description of the error. */
|
| + core.String message;
|
| +
|
| + /** A short error code that summarizes the error. */
|
| + core.String reason;
|
| +
|
| +
|
| + ErrorProto();
|
| +
|
| + ErrorProto.fromJson(core.Map _json) {
|
| + if (_json.containsKey("debugInfo")) {
|
| + debugInfo = _json["debugInfo"];
|
| + }
|
| + if (_json.containsKey("location")) {
|
| + location = _json["location"];
|
| + }
|
| + if (_json.containsKey("message")) {
|
| + message = _json["message"];
|
| + }
|
| + if (_json.containsKey("reason")) {
|
| + reason = _json["reason"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (debugInfo != null) {
|
| + _json["debugInfo"] = debugInfo;
|
| + }
|
| + if (location != null) {
|
| + _json["location"] = location;
|
| + }
|
| + if (message != null) {
|
| + _json["message"] = message;
|
| + }
|
| + if (reason != null) {
|
| + _json["reason"] = reason;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class GetQueryResultsResponse {
|
| + /** Whether the query result was fetched from the query cache. */
|
| + core.bool cacheHit;
|
| +
|
| + /** A hash of this response. */
|
| + core.String etag;
|
| +
|
| + /**
|
| + * Whether the query has completed or not. If rows or totalRows are present,
|
| + * this will always be true. If this is false, totalRows will not be
|
| + * available.
|
| + */
|
| + core.bool jobComplete;
|
| +
|
| + /**
|
| + * Reference to the BigQuery Job that was created to run the query. This field
|
| + * will be present even if the original request timed out, in which case
|
| + * GetQueryResults can be used to read the results once the query has
|
| + * completed. Since this API only returns the first page of results,
|
| + * subsequent pages can be fetched via the same mechanism (GetQueryResults).
|
| + */
|
| + JobReference jobReference;
|
| +
|
| + /** The resource type of the response. */
|
| + core.String kind;
|
| +
|
| + /** A token used for paging results. */
|
| + core.String pageToken;
|
| +
|
| + /**
|
| + * An object with as many results as can be contained within the maximum
|
| + * permitted reply size. To get any additional rows, you can call
|
| + * GetQueryResults and specify the jobReference returned above. Present only
|
| + * when the query completes successfully.
|
| + */
|
| + core.List<TableRow> rows;
|
| +
|
| + /**
|
| + * The schema of the results. Present only when the query completes
|
| + * successfully.
|
| + */
|
| + TableSchema schema;
|
| +
|
| + /**
|
| + * The total number of rows in the complete query result set, which can be
|
| + * more than the number of rows in this single page of results. Present only
|
| + * when the query completes successfully.
|
| + */
|
| + core.String totalRows;
|
| +
|
| +
|
| + GetQueryResultsResponse();
|
| +
|
| + GetQueryResultsResponse.fromJson(core.Map _json) {
|
| + if (_json.containsKey("cacheHit")) {
|
| + cacheHit = _json["cacheHit"];
|
| + }
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("jobComplete")) {
|
| + jobComplete = _json["jobComplete"];
|
| + }
|
| + if (_json.containsKey("jobReference")) {
|
| + jobReference = new JobReference.fromJson(_json["jobReference"]);
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("pageToken")) {
|
| + pageToken = _json["pageToken"];
|
| + }
|
| + if (_json.containsKey("rows")) {
|
| + rows = _json["rows"].map((value) => new TableRow.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("schema")) {
|
| + schema = new TableSchema.fromJson(_json["schema"]);
|
| + }
|
| + if (_json.containsKey("totalRows")) {
|
| + totalRows = _json["totalRows"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (cacheHit != null) {
|
| + _json["cacheHit"] = cacheHit;
|
| + }
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (jobComplete != null) {
|
| + _json["jobComplete"] = jobComplete;
|
| + }
|
| + if (jobReference != null) {
|
| + _json["jobReference"] = (jobReference).toJson();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (pageToken != null) {
|
| + _json["pageToken"] = pageToken;
|
| + }
|
| + if (rows != null) {
|
| + _json["rows"] = rows.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (schema != null) {
|
| + _json["schema"] = (schema).toJson();
|
| + }
|
| + if (totalRows != null) {
|
| + _json["totalRows"] = totalRows;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class Job {
|
| + /** [Required] Describes the job configuration. */
|
| + JobConfiguration configuration;
|
| +
|
| + /** [Output-only] A hash of this resource. */
|
| + core.String etag;
|
| +
|
| + /** [Output-only] Opaque ID field of the job */
|
| + core.String id;
|
| +
|
| + /** [Optional] Reference describing the unique-per-user name of the job. */
|
| + JobReference jobReference;
|
| +
|
| + /** [Output-only] The type of the resource. */
|
| + core.String kind;
|
| +
|
| + /** [Output-only] A URL that can be used to access this resource again. */
|
| + core.String selfLink;
|
| +
|
| + /**
|
| + * [Output-only] Information about the job, including starting time and ending
|
| + * time of the job.
|
| + */
|
| + JobStatistics statistics;
|
| +
|
| + /**
|
| + * [Output-only] The status of this job. Examine this value when polling an
|
| + * asynchronous job to see if the job is complete.
|
| + */
|
| + JobStatus status;
|
| +
|
| +
|
| + Job();
|
| +
|
| + Job.fromJson(core.Map _json) {
|
| + if (_json.containsKey("configuration")) {
|
| + configuration = new JobConfiguration.fromJson(_json["configuration"]);
|
| + }
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("jobReference")) {
|
| + jobReference = new JobReference.fromJson(_json["jobReference"]);
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("selfLink")) {
|
| + selfLink = _json["selfLink"];
|
| + }
|
| + if (_json.containsKey("statistics")) {
|
| + statistics = new JobStatistics.fromJson(_json["statistics"]);
|
| + }
|
| + if (_json.containsKey("status")) {
|
| + status = new JobStatus.fromJson(_json["status"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (configuration != null) {
|
| + _json["configuration"] = (configuration).toJson();
|
| + }
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (jobReference != null) {
|
| + _json["jobReference"] = (jobReference).toJson();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (selfLink != null) {
|
| + _json["selfLink"] = selfLink;
|
| + }
|
| + if (statistics != null) {
|
| + _json["statistics"] = (statistics).toJson();
|
| + }
|
| + if (status != null) {
|
| + _json["status"] = (status).toJson();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobConfiguration {
|
| + /** [Pick one] Copies a table. */
|
| + JobConfigurationTableCopy copy;
|
| +
|
| + /**
|
| + * [Optional] If set, don't actually run this job. A valid query will return a
|
| + * mostly empty response with some processing statistics, while an invalid
|
| + * query will return the same error it would if it wasn't a dry run. Behavior
|
| + * of non-query jobs is undefined.
|
| + */
|
| + core.bool dryRun;
|
| +
|
| + /** [Pick one] Configures an extract job. */
|
| + JobConfigurationExtract extract;
|
| +
|
| + /** [Pick one] Configures a link job. */
|
| + JobConfigurationLink link;
|
| +
|
| + /** [Pick one] Configures a load job. */
|
| + JobConfigurationLoad load;
|
| +
|
| + /** [Pick one] Configures a query job. */
|
| + JobConfigurationQuery query;
|
| +
|
| +
|
| + JobConfiguration();
|
| +
|
| + JobConfiguration.fromJson(core.Map _json) {
|
| + if (_json.containsKey("copy")) {
|
| + copy = new JobConfigurationTableCopy.fromJson(_json["copy"]);
|
| + }
|
| + if (_json.containsKey("dryRun")) {
|
| + dryRun = _json["dryRun"];
|
| + }
|
| + if (_json.containsKey("extract")) {
|
| + extract = new JobConfigurationExtract.fromJson(_json["extract"]);
|
| + }
|
| + if (_json.containsKey("link")) {
|
| + link = new JobConfigurationLink.fromJson(_json["link"]);
|
| + }
|
| + if (_json.containsKey("load")) {
|
| + load = new JobConfigurationLoad.fromJson(_json["load"]);
|
| + }
|
| + if (_json.containsKey("query")) {
|
| + query = new JobConfigurationQuery.fromJson(_json["query"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (copy != null) {
|
| + _json["copy"] = (copy).toJson();
|
| + }
|
| + if (dryRun != null) {
|
| + _json["dryRun"] = dryRun;
|
| + }
|
| + if (extract != null) {
|
| + _json["extract"] = (extract).toJson();
|
| + }
|
| + if (link != null) {
|
| + _json["link"] = (link).toJson();
|
| + }
|
| + if (load != null) {
|
| + _json["load"] = (load).toJson();
|
| + }
|
| + if (query != null) {
|
| + _json["query"] = (query).toJson();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobConfigurationExtract {
|
| + /**
|
| + * [Optional] The compression type to use for exported files. Possible values
|
| + * include GZIP and NONE. The default value is NONE.
|
| + */
|
| + core.String compression;
|
| +
|
| + /**
|
| + * [Optional] The exported file format. Possible values include CSV,
|
| + * NEWLINE_DELIMITED_JSON and AVRO. The default value is CSV. Tables with
|
| + * nested or repeated fields cannot be exported as CSV.
|
| + */
|
| + core.String destinationFormat;
|
| +
|
| + /**
|
| + * [Pick one] DEPRECATED: Use destinationUris instead, passing only one URI as
|
| + * necessary. The fully-qualified Google Cloud Storage URI where the extracted
|
| + * table should be written.
|
| + */
|
| + core.String destinationUri;
|
| +
|
| + /**
|
| + * [Pick one] A list of fully-qualified Google Cloud Storage URIs where the
|
| + * extracted table should be written.
|
| + */
|
| + core.List<core.String> destinationUris;
|
| +
|
| + /**
|
| + * [Optional] Delimiter to use between fields in the exported data. Default is
|
| + * ','
|
| + */
|
| + core.String fieldDelimiter;
|
| +
|
| + /**
|
| + * [Optional] Whether to print out a header row in the results. Default is
|
| + * true.
|
| + */
|
| + core.bool printHeader;
|
| +
|
| + /** [Required] A reference to the table being exported. */
|
| + TableReference sourceTable;
|
| +
|
| +
|
| + JobConfigurationExtract();
|
| +
|
| + JobConfigurationExtract.fromJson(core.Map _json) {
|
| + if (_json.containsKey("compression")) {
|
| + compression = _json["compression"];
|
| + }
|
| + if (_json.containsKey("destinationFormat")) {
|
| + destinationFormat = _json["destinationFormat"];
|
| + }
|
| + if (_json.containsKey("destinationUri")) {
|
| + destinationUri = _json["destinationUri"];
|
| + }
|
| + if (_json.containsKey("destinationUris")) {
|
| + destinationUris = _json["destinationUris"];
|
| + }
|
| + if (_json.containsKey("fieldDelimiter")) {
|
| + fieldDelimiter = _json["fieldDelimiter"];
|
| + }
|
| + if (_json.containsKey("printHeader")) {
|
| + printHeader = _json["printHeader"];
|
| + }
|
| + if (_json.containsKey("sourceTable")) {
|
| + sourceTable = new TableReference.fromJson(_json["sourceTable"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (compression != null) {
|
| + _json["compression"] = compression;
|
| + }
|
| + if (destinationFormat != null) {
|
| + _json["destinationFormat"] = destinationFormat;
|
| + }
|
| + if (destinationUri != null) {
|
| + _json["destinationUri"] = destinationUri;
|
| + }
|
| + if (destinationUris != null) {
|
| + _json["destinationUris"] = destinationUris;
|
| + }
|
| + if (fieldDelimiter != null) {
|
| + _json["fieldDelimiter"] = fieldDelimiter;
|
| + }
|
| + if (printHeader != null) {
|
| + _json["printHeader"] = printHeader;
|
| + }
|
| + if (sourceTable != null) {
|
| + _json["sourceTable"] = (sourceTable).toJson();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobConfigurationLink {
|
| + /**
|
| + * [Optional] Specifies whether the job is allowed to create new tables. The
|
| + * following values are supported: CREATE_IF_NEEDED: If the table does not
|
| + * exist, BigQuery creates the table. CREATE_NEVER: The table must already
|
| + * exist. If it does not, a 'notFound' error is returned in the job result.
|
| + * The default value is CREATE_IF_NEEDED. Creation, truncation and append
|
| + * actions occur as one atomic update upon job completion.
|
| + */
|
| + core.String createDisposition;
|
| +
|
| + /** [Required] The destination table of the link job. */
|
| + TableReference destinationTable;
|
| +
|
| + /** [Required] URI of source table to link. */
|
| + core.List<core.String> sourceUri;
|
| +
|
| + /**
|
| + * [Optional] Specifies the action that occurs if the destination table
|
| + * already exists. The following values are supported: WRITE_TRUNCATE: If the
|
| + * table already exists, BigQuery overwrites the table data. WRITE_APPEND: If
|
| + * the table already exists, BigQuery appends the data to the table.
|
| + * WRITE_EMPTY: If the table already exists and contains data, a 'duplicate'
|
| + * error is returned in the job result. The default value is WRITE_EMPTY. Each
|
| + * action is atomic and only occurs if BigQuery is able to complete the job
|
| + * successfully. Creation, truncation and append actions occur as one atomic
|
| + * update upon job completion.
|
| + */
|
| + core.String writeDisposition;
|
| +
|
| +
|
| + JobConfigurationLink();
|
| +
|
| + JobConfigurationLink.fromJson(core.Map _json) {
|
| + if (_json.containsKey("createDisposition")) {
|
| + createDisposition = _json["createDisposition"];
|
| + }
|
| + if (_json.containsKey("destinationTable")) {
|
| + destinationTable = new TableReference.fromJson(_json["destinationTable"]);
|
| + }
|
| + if (_json.containsKey("sourceUri")) {
|
| + sourceUri = _json["sourceUri"];
|
| + }
|
| + if (_json.containsKey("writeDisposition")) {
|
| + writeDisposition = _json["writeDisposition"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (createDisposition != null) {
|
| + _json["createDisposition"] = createDisposition;
|
| + }
|
| + if (destinationTable != null) {
|
| + _json["destinationTable"] = (destinationTable).toJson();
|
| + }
|
| + if (sourceUri != null) {
|
| + _json["sourceUri"] = sourceUri;
|
| + }
|
| + if (writeDisposition != null) {
|
| + _json["writeDisposition"] = writeDisposition;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobConfigurationLoad {
|
| + /**
|
| + * [Optional] Accept rows that are missing trailing optional columns. The
|
| + * missing values are treated as nulls. Default is false which treats short
|
| + * rows as errors. Only applicable to CSV, ignored for other formats.
|
| + */
|
| + core.bool allowJaggedRows;
|
| +
|
| + /**
|
| + * Indicates if BigQuery should allow quoted data sections that contain
|
| + * newline characters in a CSV file. The default value is false.
|
| + */
|
| + core.bool allowQuotedNewlines;
|
| +
|
| + /**
|
| + * [Optional] Specifies whether the job is allowed to create new tables. The
|
| + * following values are supported: CREATE_IF_NEEDED: If the table does not
|
| + * exist, BigQuery creates the table. CREATE_NEVER: The table must already
|
| + * exist. If it does not, a 'notFound' error is returned in the job result.
|
| + * The default value is CREATE_IF_NEEDED. Creation, truncation and append
|
| + * actions occur as one atomic update upon job completion.
|
| + */
|
| + core.String createDisposition;
|
| +
|
| + /** [Required] The destination table to load the data into. */
|
| + TableReference destinationTable;
|
| +
|
| + /**
|
| + * [Optional] The character encoding of the data. The supported values are
|
| + * UTF-8 or ISO-8859-1. The default value is UTF-8. BigQuery decodes the data
|
| + * after the raw, binary data has been split using the values of the quote and
|
| + * fieldDelimiter properties.
|
| + */
|
| + core.String encoding;
|
| +
|
| + /**
|
| + * [Optional] The separator for fields in a CSV file. BigQuery converts the
|
| + * string to ISO-8859-1 encoding, and then uses the first byte of the encoded
|
| + * string to split the data in its raw, binary state. BigQuery also supports
|
| + * the escape sequence "\t" to specify a tab separator. The default value is a
|
| + * comma (',').
|
| + */
|
| + core.String fieldDelimiter;
|
| +
|
| + /**
|
| + * [Optional] Accept rows that contain values that do not match the schema.
|
| + * The unknown values are ignored. Default is false which treats unknown
|
| + * values as errors. For CSV this ignores extra values at the end of a line.
|
| + * For JSON this ignores named values that do not match any column name.
|
| + */
|
| + core.bool ignoreUnknownValues;
|
| +
|
| + /**
|
| + * [Optional] The maximum number of bad records that BigQuery can ignore when
|
| + * running the job. If the number of bad records exceeds this value, an
|
| + * 'invalid' error is returned in the job result and the job fails. The
|
| + * default value is 0, which requires that all records are valid.
|
| + */
|
| + core.int maxBadRecords;
|
| +
|
| + /**
|
| + * [Optional] The value that is used to quote data sections in a CSV file.
|
| + * BigQuery converts the string to ISO-8859-1 encoding, and then uses the
|
| + * first byte of the encoded string to split the data in its raw, binary
|
| + * state. The default value is a double-quote ('"'). If your data does not
|
| + * contain quoted sections, set the property value to an empty string. If your
|
| + * data contains quoted newline characters, you must also set the
|
| + * allowQuotedNewlines property to true.
|
| + */
|
| + core.String quote;
|
| +
|
| + /**
|
| + * [Optional] The schema for the destination table. The schema can be omitted
|
| + * if the destination table already exists or if the schema can be inferred
|
| + * from the loaded data.
|
| + */
|
| + TableSchema schema;
|
| +
|
| + /**
|
| + * [Deprecated] The inline schema. For CSV schemas, specify as
|
| + * "Field1:Type1[,Field2:Type2]*". For example, "foo:STRING, bar:INTEGER,
|
| + * baz:FLOAT".
|
| + */
|
| + core.String schemaInline;
|
| +
|
| + /** [Deprecated] The format of the schemaInline property. */
|
| + core.String schemaInlineFormat;
|
| +
|
| + /**
|
| + * [Optional] The number of rows at the top of a CSV file that BigQuery will
|
| + * skip when loading the data. The default value is 0. This property is useful
|
| + * if you have header rows in the file that should be skipped.
|
| + */
|
| + core.int skipLeadingRows;
|
| +
|
| + /**
|
| + * [Optional] The format of the data files. For CSV files, specify "CSV". For
|
| + * datastore backups, specify "DATASTORE_BACKUP". For newline-delimited JSON,
|
| + * specify "NEWLINE_DELIMITED_JSON". The default value is CSV.
|
| + */
|
| + core.String sourceFormat;
|
| +
|
| + /**
|
| + * [Required] The fully-qualified URIs that point to your data on Google Cloud
|
| + * Storage.
|
| + */
|
| + core.List<core.String> sourceUris;
|
| +
|
| + /**
|
| + * [Optional] Specifies the action that occurs if the destination table
|
| + * already exists. The following values are supported: WRITE_TRUNCATE: If the
|
| + * table already exists, BigQuery overwrites the table data. WRITE_APPEND: If
|
| + * the table already exists, BigQuery appends the data to the table.
|
| + * WRITE_EMPTY: If the table already exists and contains data, a 'duplicate'
|
| + * error is returned in the job result. The default value is WRITE_EMPTY. Each
|
| + * action is atomic and only occurs if BigQuery is able to complete the job
|
| + * successfully. Creation, truncation and append actions occur as one atomic
|
| + * update upon job completion.
|
| + */
|
| + core.String writeDisposition;
|
| +
|
| +
|
| + JobConfigurationLoad();
|
| +
|
| + JobConfigurationLoad.fromJson(core.Map _json) {
|
| + if (_json.containsKey("allowJaggedRows")) {
|
| + allowJaggedRows = _json["allowJaggedRows"];
|
| + }
|
| + if (_json.containsKey("allowQuotedNewlines")) {
|
| + allowQuotedNewlines = _json["allowQuotedNewlines"];
|
| + }
|
| + if (_json.containsKey("createDisposition")) {
|
| + createDisposition = _json["createDisposition"];
|
| + }
|
| + if (_json.containsKey("destinationTable")) {
|
| + destinationTable = new TableReference.fromJson(_json["destinationTable"]);
|
| + }
|
| + if (_json.containsKey("encoding")) {
|
| + encoding = _json["encoding"];
|
| + }
|
| + if (_json.containsKey("fieldDelimiter")) {
|
| + fieldDelimiter = _json["fieldDelimiter"];
|
| + }
|
| + if (_json.containsKey("ignoreUnknownValues")) {
|
| + ignoreUnknownValues = _json["ignoreUnknownValues"];
|
| + }
|
| + if (_json.containsKey("maxBadRecords")) {
|
| + maxBadRecords = _json["maxBadRecords"];
|
| + }
|
| + if (_json.containsKey("quote")) {
|
| + quote = _json["quote"];
|
| + }
|
| + if (_json.containsKey("schema")) {
|
| + schema = new TableSchema.fromJson(_json["schema"]);
|
| + }
|
| + if (_json.containsKey("schemaInline")) {
|
| + schemaInline = _json["schemaInline"];
|
| + }
|
| + if (_json.containsKey("schemaInlineFormat")) {
|
| + schemaInlineFormat = _json["schemaInlineFormat"];
|
| + }
|
| + if (_json.containsKey("skipLeadingRows")) {
|
| + skipLeadingRows = _json["skipLeadingRows"];
|
| + }
|
| + if (_json.containsKey("sourceFormat")) {
|
| + sourceFormat = _json["sourceFormat"];
|
| + }
|
| + if (_json.containsKey("sourceUris")) {
|
| + sourceUris = _json["sourceUris"];
|
| + }
|
| + if (_json.containsKey("writeDisposition")) {
|
| + writeDisposition = _json["writeDisposition"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (allowJaggedRows != null) {
|
| + _json["allowJaggedRows"] = allowJaggedRows;
|
| + }
|
| + if (allowQuotedNewlines != null) {
|
| + _json["allowQuotedNewlines"] = allowQuotedNewlines;
|
| + }
|
| + if (createDisposition != null) {
|
| + _json["createDisposition"] = createDisposition;
|
| + }
|
| + if (destinationTable != null) {
|
| + _json["destinationTable"] = (destinationTable).toJson();
|
| + }
|
| + if (encoding != null) {
|
| + _json["encoding"] = encoding;
|
| + }
|
| + if (fieldDelimiter != null) {
|
| + _json["fieldDelimiter"] = fieldDelimiter;
|
| + }
|
| + if (ignoreUnknownValues != null) {
|
| + _json["ignoreUnknownValues"] = ignoreUnknownValues;
|
| + }
|
| + if (maxBadRecords != null) {
|
| + _json["maxBadRecords"] = maxBadRecords;
|
| + }
|
| + if (quote != null) {
|
| + _json["quote"] = quote;
|
| + }
|
| + if (schema != null) {
|
| + _json["schema"] = (schema).toJson();
|
| + }
|
| + if (schemaInline != null) {
|
| + _json["schemaInline"] = schemaInline;
|
| + }
|
| + if (schemaInlineFormat != null) {
|
| + _json["schemaInlineFormat"] = schemaInlineFormat;
|
| + }
|
| + if (skipLeadingRows != null) {
|
| + _json["skipLeadingRows"] = skipLeadingRows;
|
| + }
|
| + if (sourceFormat != null) {
|
| + _json["sourceFormat"] = sourceFormat;
|
| + }
|
| + if (sourceUris != null) {
|
| + _json["sourceUris"] = sourceUris;
|
| + }
|
| + if (writeDisposition != null) {
|
| + _json["writeDisposition"] = writeDisposition;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobConfigurationQuery {
|
| + /**
|
| + * If true, allows the query to produce arbitrarily large result tables at a
|
| + * slight cost in performance. Requires destinationTable to be set.
|
| + */
|
| + core.bool allowLargeResults;
|
| +
|
| + /**
|
| + * [Optional] Specifies whether the job is allowed to create new tables. The
|
| + * following values are supported: CREATE_IF_NEEDED: If the table does not
|
| + * exist, BigQuery creates the table. CREATE_NEVER: The table must already
|
| + * exist. If it does not, a 'notFound' error is returned in the job result.
|
| + * The default value is CREATE_IF_NEEDED. Creation, truncation and append
|
| + * actions occur as one atomic update upon job completion.
|
| + */
|
| + core.String createDisposition;
|
| +
|
| + /**
|
| + * [Optional] Specifies the default dataset to use for unqualified table names
|
| + * in the query.
|
| + */
|
| + DatasetReference defaultDataset;
|
| +
|
| + /**
|
| + * [Optional] Describes the table where the query results should be stored. If
|
| + * not present, a new table will be created to store the results.
|
| + */
|
| + TableReference destinationTable;
|
| +
|
| + /**
|
| + * [Experimental] Flattens all nested and repeated fields in the query
|
| + * results. The default value is true. allowLargeResults must be true if this
|
| + * is set to false.
|
| + */
|
| + core.bool flattenResults;
|
| +
|
| + /** [Deprecated] This property is deprecated. */
|
| + core.bool preserveNulls;
|
| +
|
| + /**
|
| + * [Optional] Specifies a priority for the query. Possible values include
|
| + * INTERACTIVE and BATCH. The default value is INTERACTIVE.
|
| + */
|
| + core.String priority;
|
| +
|
| + /** [Required] BigQuery SQL query to execute. */
|
| + core.String query;
|
| +
|
| + /**
|
| + * [Optional] Whether to look for the result in the query cache. The query
|
| + * cache is a best-effort cache that will be flushed whenever tables in the
|
| + * query are modified. Moreover, the query cache is only available when a
|
| + * query does not have a destination table specified.
|
| + */
|
| + core.bool useQueryCache;
|
| +
|
| + /**
|
| + * [Optional] Specifies the action that occurs if the destination table
|
| + * already exists. The following values are supported: WRITE_TRUNCATE: If the
|
| + * table already exists, BigQuery overwrites the table data. WRITE_APPEND: If
|
| + * the table already exists, BigQuery appends the data to the table.
|
| + * WRITE_EMPTY: If the table already exists and contains data, a 'duplicate'
|
| + * error is returned in the job result. The default value is WRITE_EMPTY. Each
|
| + * action is atomic and only occurs if BigQuery is able to complete the job
|
| + * successfully. Creation, truncation and append actions occur as one atomic
|
| + * update upon job completion.
|
| + */
|
| + core.String writeDisposition;
|
| +
|
| +
|
| + JobConfigurationQuery();
|
| +
|
| + JobConfigurationQuery.fromJson(core.Map _json) {
|
| + if (_json.containsKey("allowLargeResults")) {
|
| + allowLargeResults = _json["allowLargeResults"];
|
| + }
|
| + if (_json.containsKey("createDisposition")) {
|
| + createDisposition = _json["createDisposition"];
|
| + }
|
| + if (_json.containsKey("defaultDataset")) {
|
| + defaultDataset = new DatasetReference.fromJson(_json["defaultDataset"]);
|
| + }
|
| + if (_json.containsKey("destinationTable")) {
|
| + destinationTable = new TableReference.fromJson(_json["destinationTable"]);
|
| + }
|
| + if (_json.containsKey("flattenResults")) {
|
| + flattenResults = _json["flattenResults"];
|
| + }
|
| + if (_json.containsKey("preserveNulls")) {
|
| + preserveNulls = _json["preserveNulls"];
|
| + }
|
| + if (_json.containsKey("priority")) {
|
| + priority = _json["priority"];
|
| + }
|
| + if (_json.containsKey("query")) {
|
| + query = _json["query"];
|
| + }
|
| + if (_json.containsKey("useQueryCache")) {
|
| + useQueryCache = _json["useQueryCache"];
|
| + }
|
| + if (_json.containsKey("writeDisposition")) {
|
| + writeDisposition = _json["writeDisposition"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (allowLargeResults != null) {
|
| + _json["allowLargeResults"] = allowLargeResults;
|
| + }
|
| + if (createDisposition != null) {
|
| + _json["createDisposition"] = createDisposition;
|
| + }
|
| + if (defaultDataset != null) {
|
| + _json["defaultDataset"] = (defaultDataset).toJson();
|
| + }
|
| + if (destinationTable != null) {
|
| + _json["destinationTable"] = (destinationTable).toJson();
|
| + }
|
| + if (flattenResults != null) {
|
| + _json["flattenResults"] = flattenResults;
|
| + }
|
| + if (preserveNulls != null) {
|
| + _json["preserveNulls"] = preserveNulls;
|
| + }
|
| + if (priority != null) {
|
| + _json["priority"] = priority;
|
| + }
|
| + if (query != null) {
|
| + _json["query"] = query;
|
| + }
|
| + if (useQueryCache != null) {
|
| + _json["useQueryCache"] = useQueryCache;
|
| + }
|
| + if (writeDisposition != null) {
|
| + _json["writeDisposition"] = writeDisposition;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobConfigurationTableCopy {
|
| + /**
|
| + * [Optional] Specifies whether the job is allowed to create new tables. The
|
| + * following values are supported: CREATE_IF_NEEDED: If the table does not
|
| + * exist, BigQuery creates the table. CREATE_NEVER: The table must already
|
| + * exist. If it does not, a 'notFound' error is returned in the job result.
|
| + * The default value is CREATE_IF_NEEDED. Creation, truncation and append
|
| + * actions occur as one atomic update upon job completion.
|
| + */
|
| + core.String createDisposition;
|
| +
|
| + /** [Required] The destination table */
|
| + TableReference destinationTable;
|
| +
|
| + /** [Pick one] Source table to copy. */
|
| + TableReference sourceTable;
|
| +
|
| + /** [Pick one] Source tables to copy. */
|
| + core.List<TableReference> sourceTables;
|
| +
|
| + /**
|
| + * [Optional] Specifies the action that occurs if the destination table
|
| + * already exists. The following values are supported: WRITE_TRUNCATE: If the
|
| + * table already exists, BigQuery overwrites the table data. WRITE_APPEND: If
|
| + * the table already exists, BigQuery appends the data to the table.
|
| + * WRITE_EMPTY: If the table already exists and contains data, a 'duplicate'
|
| + * error is returned in the job result. The default value is WRITE_EMPTY. Each
|
| + * action is atomic and only occurs if BigQuery is able to complete the job
|
| + * successfully. Creation, truncation and append actions occur as one atomic
|
| + * update upon job completion.
|
| + */
|
| + core.String writeDisposition;
|
| +
|
| +
|
| + JobConfigurationTableCopy();
|
| +
|
| + JobConfigurationTableCopy.fromJson(core.Map _json) {
|
| + if (_json.containsKey("createDisposition")) {
|
| + createDisposition = _json["createDisposition"];
|
| + }
|
| + if (_json.containsKey("destinationTable")) {
|
| + destinationTable = new TableReference.fromJson(_json["destinationTable"]);
|
| + }
|
| + if (_json.containsKey("sourceTable")) {
|
| + sourceTable = new TableReference.fromJson(_json["sourceTable"]);
|
| + }
|
| + if (_json.containsKey("sourceTables")) {
|
| + sourceTables = _json["sourceTables"].map((value) => new TableReference.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("writeDisposition")) {
|
| + writeDisposition = _json["writeDisposition"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (createDisposition != null) {
|
| + _json["createDisposition"] = createDisposition;
|
| + }
|
| + if (destinationTable != null) {
|
| + _json["destinationTable"] = (destinationTable).toJson();
|
| + }
|
| + if (sourceTable != null) {
|
| + _json["sourceTable"] = (sourceTable).toJson();
|
| + }
|
| + if (sourceTables != null) {
|
| + _json["sourceTables"] = sourceTables.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (writeDisposition != null) {
|
| + _json["writeDisposition"] = writeDisposition;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobListJobs {
|
| + /** [Full-projection-only] Specifies the job configuration. */
|
| + JobConfiguration configuration;
|
| +
|
| + /** A result object that will be present only if the job has failed. */
|
| + ErrorProto errorResult;
|
| +
|
| + /** Unique opaque ID of the job. */
|
| + core.String id;
|
| +
|
| + /** Job reference uniquely identifying the job. */
|
| + JobReference jobReference;
|
| +
|
| + /** The resource type. */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * Running state of the job. When the state is DONE, errorResult can be
|
| + * checked to determine whether the job succeeded or failed.
|
| + */
|
| + core.String state;
|
| +
|
| + /**
|
| + * [Output-only] Information about the job, including starting time and ending
|
| + * time of the job.
|
| + */
|
| + JobStatistics statistics;
|
| +
|
| + /** [Full-projection-only] Describes the state of the job. */
|
| + JobStatus status;
|
| +
|
| + /** [Full-projection-only] User who ran the job. */
|
| + core.String userEmail;
|
| +
|
| +
|
| + JobListJobs();
|
| +
|
| + JobListJobs.fromJson(core.Map _json) {
|
| + if (_json.containsKey("configuration")) {
|
| + configuration = new JobConfiguration.fromJson(_json["configuration"]);
|
| + }
|
| + if (_json.containsKey("errorResult")) {
|
| + errorResult = new ErrorProto.fromJson(_json["errorResult"]);
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("jobReference")) {
|
| + jobReference = new JobReference.fromJson(_json["jobReference"]);
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("state")) {
|
| + state = _json["state"];
|
| + }
|
| + if (_json.containsKey("statistics")) {
|
| + statistics = new JobStatistics.fromJson(_json["statistics"]);
|
| + }
|
| + if (_json.containsKey("status")) {
|
| + status = new JobStatus.fromJson(_json["status"]);
|
| + }
|
| + if (_json.containsKey("user_email")) {
|
| + userEmail = _json["user_email"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (configuration != null) {
|
| + _json["configuration"] = (configuration).toJson();
|
| + }
|
| + if (errorResult != null) {
|
| + _json["errorResult"] = (errorResult).toJson();
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (jobReference != null) {
|
| + _json["jobReference"] = (jobReference).toJson();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (state != null) {
|
| + _json["state"] = state;
|
| + }
|
| + if (statistics != null) {
|
| + _json["statistics"] = (statistics).toJson();
|
| + }
|
| + if (status != null) {
|
| + _json["status"] = (status).toJson();
|
| + }
|
| + if (userEmail != null) {
|
| + _json["user_email"] = userEmail;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobList {
|
| + /** A hash of this page of results. */
|
| + core.String etag;
|
| +
|
| + /** List of jobs that were requested. */
|
| + core.List<JobListJobs> jobs;
|
| +
|
| + /** The resource type of the response. */
|
| + core.String kind;
|
| +
|
| + /** A token to request the next page of results. */
|
| + core.String nextPageToken;
|
| +
|
| + /** Total number of jobs in this collection. */
|
| + core.int totalItems;
|
| +
|
| +
|
| + JobList();
|
| +
|
| + JobList.fromJson(core.Map _json) {
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("jobs")) {
|
| + jobs = _json["jobs"].map((value) => new JobListJobs.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("nextPageToken")) {
|
| + nextPageToken = _json["nextPageToken"];
|
| + }
|
| + if (_json.containsKey("totalItems")) {
|
| + totalItems = _json["totalItems"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (jobs != null) {
|
| + _json["jobs"] = jobs.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (nextPageToken != null) {
|
| + _json["nextPageToken"] = nextPageToken;
|
| + }
|
| + if (totalItems != null) {
|
| + _json["totalItems"] = totalItems;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobReference {
|
| + /** [Required] ID of the job. */
|
| + core.String jobId;
|
| +
|
| + /** [Required] Project ID being billed for the job. */
|
| + core.String projectId;
|
| +
|
| +
|
| + JobReference();
|
| +
|
| + JobReference.fromJson(core.Map _json) {
|
| + if (_json.containsKey("jobId")) {
|
| + jobId = _json["jobId"];
|
| + }
|
| + if (_json.containsKey("projectId")) {
|
| + projectId = _json["projectId"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (jobId != null) {
|
| + _json["jobId"] = jobId;
|
| + }
|
| + if (projectId != null) {
|
| + _json["projectId"] = projectId;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobStatistics {
|
| + /**
|
| + * [Output-only] Creation time of this job, in milliseconds since the epoch.
|
| + * This field will be present on all jobs.
|
| + */
|
| + core.String creationTime;
|
| +
|
| + /**
|
| + * [Output-only] End time of this job, in milliseconds since the epoch. This
|
| + * field will be present whenever a job is in the DONE state.
|
| + */
|
| + core.String endTime;
|
| +
|
| + /** [Output-only] Statistics for a load job. */
|
| + JobStatistics3 load;
|
| +
|
| + /** [Output-only] Statistics for a query job. */
|
| + JobStatistics2 query;
|
| +
|
| + /**
|
| + * [Output-only] Start time of this job, in milliseconds since the epoch. This
|
| + * field will be present when the job transitions from the PENDING state to
|
| + * either RUNNING or DONE.
|
| + */
|
| + core.String startTime;
|
| +
|
| + /**
|
| + * [Output-only] [Deprecated] Use the bytes processed in the query statistics
|
| + * instead.
|
| + */
|
| + core.String totalBytesProcessed;
|
| +
|
| +
|
| + JobStatistics();
|
| +
|
| + JobStatistics.fromJson(core.Map _json) {
|
| + if (_json.containsKey("creationTime")) {
|
| + creationTime = _json["creationTime"];
|
| + }
|
| + if (_json.containsKey("endTime")) {
|
| + endTime = _json["endTime"];
|
| + }
|
| + if (_json.containsKey("load")) {
|
| + load = new JobStatistics3.fromJson(_json["load"]);
|
| + }
|
| + if (_json.containsKey("query")) {
|
| + query = new JobStatistics2.fromJson(_json["query"]);
|
| + }
|
| + if (_json.containsKey("startTime")) {
|
| + startTime = _json["startTime"];
|
| + }
|
| + if (_json.containsKey("totalBytesProcessed")) {
|
| + totalBytesProcessed = _json["totalBytesProcessed"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (creationTime != null) {
|
| + _json["creationTime"] = creationTime;
|
| + }
|
| + if (endTime != null) {
|
| + _json["endTime"] = endTime;
|
| + }
|
| + if (load != null) {
|
| + _json["load"] = (load).toJson();
|
| + }
|
| + if (query != null) {
|
| + _json["query"] = (query).toJson();
|
| + }
|
| + if (startTime != null) {
|
| + _json["startTime"] = startTime;
|
| + }
|
| + if (totalBytesProcessed != null) {
|
| + _json["totalBytesProcessed"] = totalBytesProcessed;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobStatistics2 {
|
| + /**
|
| + * [Output-only] Whether the query result was fetched from the query cache.
|
| + */
|
| + core.bool cacheHit;
|
| +
|
| + /** [Output-only] Total bytes processed for this job. */
|
| + core.String totalBytesProcessed;
|
| +
|
| +
|
| + JobStatistics2();
|
| +
|
| + JobStatistics2.fromJson(core.Map _json) {
|
| + if (_json.containsKey("cacheHit")) {
|
| + cacheHit = _json["cacheHit"];
|
| + }
|
| + if (_json.containsKey("totalBytesProcessed")) {
|
| + totalBytesProcessed = _json["totalBytesProcessed"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (cacheHit != null) {
|
| + _json["cacheHit"] = cacheHit;
|
| + }
|
| + if (totalBytesProcessed != null) {
|
| + _json["totalBytesProcessed"] = totalBytesProcessed;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobStatistics3 {
|
| + /** [Output-only] Number of bytes of source data in a joad job. */
|
| + core.String inputFileBytes;
|
| +
|
| + /** [Output-only] Number of source files in a load job. */
|
| + core.String inputFiles;
|
| +
|
| + /**
|
| + * [Output-only] Size of the loaded data in bytes. Note that while an import
|
| + * job is in the running state, this value may change.
|
| + */
|
| + core.String outputBytes;
|
| +
|
| + /**
|
| + * [Output-only] Number of rows imported in a load job. Note that while an
|
| + * import job is in the running state, this value may change.
|
| + */
|
| + core.String outputRows;
|
| +
|
| +
|
| + JobStatistics3();
|
| +
|
| + JobStatistics3.fromJson(core.Map _json) {
|
| + if (_json.containsKey("inputFileBytes")) {
|
| + inputFileBytes = _json["inputFileBytes"];
|
| + }
|
| + if (_json.containsKey("inputFiles")) {
|
| + inputFiles = _json["inputFiles"];
|
| + }
|
| + if (_json.containsKey("outputBytes")) {
|
| + outputBytes = _json["outputBytes"];
|
| + }
|
| + if (_json.containsKey("outputRows")) {
|
| + outputRows = _json["outputRows"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (inputFileBytes != null) {
|
| + _json["inputFileBytes"] = inputFileBytes;
|
| + }
|
| + if (inputFiles != null) {
|
| + _json["inputFiles"] = inputFiles;
|
| + }
|
| + if (outputBytes != null) {
|
| + _json["outputBytes"] = outputBytes;
|
| + }
|
| + if (outputRows != null) {
|
| + _json["outputRows"] = outputRows;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class JobStatus {
|
| + /**
|
| + * [Output-only] Final error result of the job. If present, indicates that the
|
| + * job has completed and was unsuccessful.
|
| + */
|
| + ErrorProto errorResult;
|
| +
|
| + /**
|
| + * [Output-only] All errors encountered during the running of the job. Errors
|
| + * here do not necessarily mean that the job has completed or was
|
| + * unsuccessful.
|
| + */
|
| + core.List<ErrorProto> errors;
|
| +
|
| + /** [Output-only] Running state of the job. */
|
| + core.String state;
|
| +
|
| +
|
| + JobStatus();
|
| +
|
| + JobStatus.fromJson(core.Map _json) {
|
| + if (_json.containsKey("errorResult")) {
|
| + errorResult = new ErrorProto.fromJson(_json["errorResult"]);
|
| + }
|
| + if (_json.containsKey("errors")) {
|
| + errors = _json["errors"].map((value) => new ErrorProto.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("state")) {
|
| + state = _json["state"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (errorResult != null) {
|
| + _json["errorResult"] = (errorResult).toJson();
|
| + }
|
| + if (errors != null) {
|
| + _json["errors"] = errors.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (state != null) {
|
| + _json["state"] = state;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Represents a single JSON object. */
|
| +class JsonObject
|
| + extends collection.MapBase<core.String, core.Object> {
|
| + final core.Map _innerMap = {};
|
| +
|
| + JsonObject();
|
| +
|
| + JsonObject.fromJson(core.Map _json) {
|
| + _json.forEach((core.String key, value) {
|
| + this[key] = value;
|
| + });
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = {};
|
| + this.forEach((core.String key, value) {
|
| + _json[key] = value;
|
| + });
|
| + return _json;
|
| + }
|
| +
|
| + core.Object operator [](core.Object key)
|
| + => _innerMap[key];
|
| +
|
| + operator []=(core.String key, core.Object value) {
|
| + _innerMap[key] = value;
|
| + }
|
| +
|
| + void clear() {
|
| + _innerMap.clear();
|
| + }
|
| +
|
| + core.Iterable<core.String> get keys => _innerMap.keys;
|
| +
|
| + core.Object remove(core.Object key) => _innerMap.remove(key);
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class ProjectListProjects {
|
| + /** A descriptive name for this project. */
|
| + core.String friendlyName;
|
| +
|
| + /** An opaque ID of this project. */
|
| + core.String id;
|
| +
|
| + /** The resource type. */
|
| + core.String kind;
|
| +
|
| + /** The numeric ID of this project. */
|
| + core.String numericId;
|
| +
|
| + /** A unique reference to this project. */
|
| + ProjectReference projectReference;
|
| +
|
| +
|
| + ProjectListProjects();
|
| +
|
| + ProjectListProjects.fromJson(core.Map _json) {
|
| + if (_json.containsKey("friendlyName")) {
|
| + friendlyName = _json["friendlyName"];
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("numericId")) {
|
| + numericId = _json["numericId"];
|
| + }
|
| + if (_json.containsKey("projectReference")) {
|
| + projectReference = new ProjectReference.fromJson(_json["projectReference"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (friendlyName != null) {
|
| + _json["friendlyName"] = friendlyName;
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (numericId != null) {
|
| + _json["numericId"] = numericId;
|
| + }
|
| + if (projectReference != null) {
|
| + _json["projectReference"] = (projectReference).toJson();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class ProjectList {
|
| + /** A hash of the page of results */
|
| + core.String etag;
|
| +
|
| + /** The type of list. */
|
| + core.String kind;
|
| +
|
| + /** A token to request the next page of results. */
|
| + core.String nextPageToken;
|
| +
|
| + /** Projects to which you have at least READ access. */
|
| + core.List<ProjectListProjects> projects;
|
| +
|
| + /** The total number of projects in the list. */
|
| + core.int totalItems;
|
| +
|
| +
|
| + ProjectList();
|
| +
|
| + ProjectList.fromJson(core.Map _json) {
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("nextPageToken")) {
|
| + nextPageToken = _json["nextPageToken"];
|
| + }
|
| + if (_json.containsKey("projects")) {
|
| + projects = _json["projects"].map((value) => new ProjectListProjects.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("totalItems")) {
|
| + totalItems = _json["totalItems"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (nextPageToken != null) {
|
| + _json["nextPageToken"] = nextPageToken;
|
| + }
|
| + if (projects != null) {
|
| + _json["projects"] = projects.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (totalItems != null) {
|
| + _json["totalItems"] = totalItems;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class ProjectReference {
|
| + /**
|
| + * [Required] ID of the project. Can be either the numeric ID or the assigned
|
| + * ID of the project.
|
| + */
|
| + core.String projectId;
|
| +
|
| +
|
| + ProjectReference();
|
| +
|
| + ProjectReference.fromJson(core.Map _json) {
|
| + if (_json.containsKey("projectId")) {
|
| + projectId = _json["projectId"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (projectId != null) {
|
| + _json["projectId"] = projectId;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class QueryRequest {
|
| + /**
|
| + * [Optional] Specifies the default datasetId and projectId to assume for any
|
| + * unqualified table names in the query. If not set, all table names in the
|
| + * query string must be qualified in the format 'datasetId.tableId'.
|
| + */
|
| + DatasetReference defaultDataset;
|
| +
|
| + /**
|
| + * [Optional] If set, don't actually run the query. A valid query will return
|
| + * an empty response, while an invalid query will return the same error it
|
| + * would if it wasn't a dry run. The default value is false.
|
| + */
|
| + core.bool dryRun;
|
| +
|
| + /** The resource type of the request. */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * [Optional] The maximum number of rows of data to return per page of
|
| + * results. Setting this flag to a small value such as 1000 and then paging
|
| + * through results might improve reliability when the query result set is
|
| + * large. In addition to this limit, responses are also limited to 10 MB. By
|
| + * default, there is no maximum row count, and only the byte limit applies.
|
| + */
|
| + core.int maxResults;
|
| +
|
| + /** [Deprecated] This property is deprecated. */
|
| + core.bool preserveNulls;
|
| +
|
| + /**
|
| + * [Required] A query string, following the BigQuery query syntax, of the
|
| + * query to execute. Example: "SELECT count(f1) FROM
|
| + * [myProjectId:myDatasetId.myTableId]".
|
| + */
|
| + core.String query;
|
| +
|
| + /**
|
| + * [Optional] How long to wait for the query to complete, in milliseconds,
|
| + * before the request times out and returns. Note that this is only a timeout
|
| + * for the request, not the query. If the query takes longer to run than the
|
| + * timeout value, the call returns without any results and with the
|
| + * 'jobComplete' flag set to false. You can call GetQueryResults() to wait for
|
| + * the query to complete and read the results. The default value is 10000
|
| + * milliseconds (10 seconds).
|
| + */
|
| + core.int timeoutMs;
|
| +
|
| + /**
|
| + * [Optional] Whether to look for the result in the query cache. The query
|
| + * cache is a best-effort cache that will be flushed whenever tables in the
|
| + * query are modified. The default value is true.
|
| + */
|
| + core.bool useQueryCache;
|
| +
|
| +
|
| + QueryRequest();
|
| +
|
| + QueryRequest.fromJson(core.Map _json) {
|
| + if (_json.containsKey("defaultDataset")) {
|
| + defaultDataset = new DatasetReference.fromJson(_json["defaultDataset"]);
|
| + }
|
| + if (_json.containsKey("dryRun")) {
|
| + dryRun = _json["dryRun"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("maxResults")) {
|
| + maxResults = _json["maxResults"];
|
| + }
|
| + if (_json.containsKey("preserveNulls")) {
|
| + preserveNulls = _json["preserveNulls"];
|
| + }
|
| + if (_json.containsKey("query")) {
|
| + query = _json["query"];
|
| + }
|
| + if (_json.containsKey("timeoutMs")) {
|
| + timeoutMs = _json["timeoutMs"];
|
| + }
|
| + if (_json.containsKey("useQueryCache")) {
|
| + useQueryCache = _json["useQueryCache"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (defaultDataset != null) {
|
| + _json["defaultDataset"] = (defaultDataset).toJson();
|
| + }
|
| + if (dryRun != null) {
|
| + _json["dryRun"] = dryRun;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (maxResults != null) {
|
| + _json["maxResults"] = maxResults;
|
| + }
|
| + if (preserveNulls != null) {
|
| + _json["preserveNulls"] = preserveNulls;
|
| + }
|
| + if (query != null) {
|
| + _json["query"] = query;
|
| + }
|
| + if (timeoutMs != null) {
|
| + _json["timeoutMs"] = timeoutMs;
|
| + }
|
| + if (useQueryCache != null) {
|
| + _json["useQueryCache"] = useQueryCache;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class QueryResponse {
|
| + /** Whether the query result was fetched from the query cache. */
|
| + core.bool cacheHit;
|
| +
|
| + /**
|
| + * Whether the query has completed or not. If rows or totalRows are present,
|
| + * this will always be true. If this is false, totalRows will not be
|
| + * available.
|
| + */
|
| + core.bool jobComplete;
|
| +
|
| + /**
|
| + * Reference to the Job that was created to run the query. This field will be
|
| + * present even if the original request timed out, in which case
|
| + * GetQueryResults can be used to read the results once the query has
|
| + * completed. Since this API only returns the first page of results,
|
| + * subsequent pages can be fetched via the same mechanism (GetQueryResults).
|
| + */
|
| + JobReference jobReference;
|
| +
|
| + /** The resource type. */
|
| + core.String kind;
|
| +
|
| + /** A token used for paging results. */
|
| + core.String pageToken;
|
| +
|
| + /**
|
| + * An object with as many results as can be contained within the maximum
|
| + * permitted reply size. To get any additional rows, you can call
|
| + * GetQueryResults and specify the jobReference returned above.
|
| + */
|
| + core.List<TableRow> rows;
|
| +
|
| + /**
|
| + * The schema of the results. Present only when the query completes
|
| + * successfully.
|
| + */
|
| + TableSchema schema;
|
| +
|
| + /**
|
| + * The total number of bytes processed for this query. If this query was a dry
|
| + * run, this is the number of bytes that would be processed if the query were
|
| + * run.
|
| + */
|
| + core.String totalBytesProcessed;
|
| +
|
| + /**
|
| + * The total number of rows in the complete query result set, which can be
|
| + * more than the number of rows in this single page of results.
|
| + */
|
| + core.String totalRows;
|
| +
|
| +
|
| + QueryResponse();
|
| +
|
| + QueryResponse.fromJson(core.Map _json) {
|
| + if (_json.containsKey("cacheHit")) {
|
| + cacheHit = _json["cacheHit"];
|
| + }
|
| + if (_json.containsKey("jobComplete")) {
|
| + jobComplete = _json["jobComplete"];
|
| + }
|
| + if (_json.containsKey("jobReference")) {
|
| + jobReference = new JobReference.fromJson(_json["jobReference"]);
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("pageToken")) {
|
| + pageToken = _json["pageToken"];
|
| + }
|
| + if (_json.containsKey("rows")) {
|
| + rows = _json["rows"].map((value) => new TableRow.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("schema")) {
|
| + schema = new TableSchema.fromJson(_json["schema"]);
|
| + }
|
| + if (_json.containsKey("totalBytesProcessed")) {
|
| + totalBytesProcessed = _json["totalBytesProcessed"];
|
| + }
|
| + if (_json.containsKey("totalRows")) {
|
| + totalRows = _json["totalRows"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (cacheHit != null) {
|
| + _json["cacheHit"] = cacheHit;
|
| + }
|
| + if (jobComplete != null) {
|
| + _json["jobComplete"] = jobComplete;
|
| + }
|
| + if (jobReference != null) {
|
| + _json["jobReference"] = (jobReference).toJson();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (pageToken != null) {
|
| + _json["pageToken"] = pageToken;
|
| + }
|
| + if (rows != null) {
|
| + _json["rows"] = rows.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (schema != null) {
|
| + _json["schema"] = (schema).toJson();
|
| + }
|
| + if (totalBytesProcessed != null) {
|
| + _json["totalBytesProcessed"] = totalBytesProcessed;
|
| + }
|
| + if (totalRows != null) {
|
| + _json["totalRows"] = totalRows;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class Table {
|
| + /**
|
| + * [Output-only] The time when this table was created, in milliseconds since
|
| + * the epoch.
|
| + */
|
| + core.String creationTime;
|
| +
|
| + /** [Optional] A user-friendly description of this table. */
|
| + core.String description;
|
| +
|
| + /** [Output-only] A hash of this resource. */
|
| + core.String etag;
|
| +
|
| + /**
|
| + * [Optional] The time when this table expires, in milliseconds since the
|
| + * epoch. If not present, the table will persist indefinitely. Expired tables
|
| + * will be deleted and their storage reclaimed.
|
| + */
|
| + core.String expirationTime;
|
| +
|
| + /** [Optional] A descriptive name for this table. */
|
| + core.String friendlyName;
|
| +
|
| + /** [Output-only] An opaque ID uniquely identifying the table. */
|
| + core.String id;
|
| +
|
| + /** [Output-only] The type of the resource. */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * [Output-only] The time when this table was last modified, in milliseconds
|
| + * since the epoch.
|
| + */
|
| + core.String lastModifiedTime;
|
| +
|
| + /** [Output-only] The size of the table in bytes. */
|
| + core.String numBytes;
|
| +
|
| + /** [Output-only] The number of rows of data in this table. */
|
| + core.String numRows;
|
| +
|
| + /** [Optional] Describes the schema of this table. */
|
| + TableSchema schema;
|
| +
|
| + /** [Output-only] A URL that can be used to access this resource again. */
|
| + core.String selfLink;
|
| +
|
| + /** [Required] Reference describing the ID of this table. */
|
| + TableReference tableReference;
|
| +
|
| + /**
|
| + * [Output-only] Describes the table type. The following values are supported:
|
| + * TABLE: A normal BigQuery table. VIEW: A virtual table defined by a SQL
|
| + * query. The default value is TABLE.
|
| + */
|
| + core.String type;
|
| +
|
| + /** [Optional] The view definition. */
|
| + ViewDefinition view;
|
| +
|
| +
|
| + Table();
|
| +
|
| + Table.fromJson(core.Map _json) {
|
| + if (_json.containsKey("creationTime")) {
|
| + creationTime = _json["creationTime"];
|
| + }
|
| + if (_json.containsKey("description")) {
|
| + description = _json["description"];
|
| + }
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("expirationTime")) {
|
| + expirationTime = _json["expirationTime"];
|
| + }
|
| + if (_json.containsKey("friendlyName")) {
|
| + friendlyName = _json["friendlyName"];
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("lastModifiedTime")) {
|
| + lastModifiedTime = _json["lastModifiedTime"];
|
| + }
|
| + if (_json.containsKey("numBytes")) {
|
| + numBytes = _json["numBytes"];
|
| + }
|
| + if (_json.containsKey("numRows")) {
|
| + numRows = _json["numRows"];
|
| + }
|
| + if (_json.containsKey("schema")) {
|
| + schema = new TableSchema.fromJson(_json["schema"]);
|
| + }
|
| + if (_json.containsKey("selfLink")) {
|
| + selfLink = _json["selfLink"];
|
| + }
|
| + if (_json.containsKey("tableReference")) {
|
| + tableReference = new TableReference.fromJson(_json["tableReference"]);
|
| + }
|
| + if (_json.containsKey("type")) {
|
| + type = _json["type"];
|
| + }
|
| + if (_json.containsKey("view")) {
|
| + view = new ViewDefinition.fromJson(_json["view"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (creationTime != null) {
|
| + _json["creationTime"] = creationTime;
|
| + }
|
| + if (description != null) {
|
| + _json["description"] = description;
|
| + }
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (expirationTime != null) {
|
| + _json["expirationTime"] = expirationTime;
|
| + }
|
| + if (friendlyName != null) {
|
| + _json["friendlyName"] = friendlyName;
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (lastModifiedTime != null) {
|
| + _json["lastModifiedTime"] = lastModifiedTime;
|
| + }
|
| + if (numBytes != null) {
|
| + _json["numBytes"] = numBytes;
|
| + }
|
| + if (numRows != null) {
|
| + _json["numRows"] = numRows;
|
| + }
|
| + if (schema != null) {
|
| + _json["schema"] = (schema).toJson();
|
| + }
|
| + if (selfLink != null) {
|
| + _json["selfLink"] = selfLink;
|
| + }
|
| + if (tableReference != null) {
|
| + _json["tableReference"] = (tableReference).toJson();
|
| + }
|
| + if (type != null) {
|
| + _json["type"] = type;
|
| + }
|
| + if (view != null) {
|
| + _json["view"] = (view).toJson();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/**
|
| + * Represents a single cell in the result set. Users of the java client can
|
| + * detect whether their value result is null by calling
|
| + * 'com.google.api.client.util.Data.isNull(cell.getV())'.
|
| + */
|
| +class TableCell {
|
| + /**
|
| + * Not documented yet.
|
| + *
|
| + * The values for Object must be JSON objects. It can consist of `num`,
|
| + * `String`, `bool` and `null` as well as `Map` and `List` values.
|
| + */
|
| + core.Object v;
|
| +
|
| +
|
| + TableCell();
|
| +
|
| + TableCell.fromJson(core.Map _json) {
|
| + if (_json.containsKey("v")) {
|
| + v = _json["v"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (v != null) {
|
| + _json["v"] = v;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableDataInsertAllRequestRows {
|
| + /**
|
| + * [Optional] A unique ID for each row. BigQuery uses this property to detect
|
| + * duplicate insertion requests on a best-effort basis.
|
| + */
|
| + core.String insertId;
|
| +
|
| + /**
|
| + * [Required] A JSON object that contains a row of data. The object's
|
| + * properties and values must match the destination table's schema.
|
| + */
|
| + JsonObject json;
|
| +
|
| +
|
| + TableDataInsertAllRequestRows();
|
| +
|
| + TableDataInsertAllRequestRows.fromJson(core.Map _json) {
|
| + if (_json.containsKey("insertId")) {
|
| + insertId = _json["insertId"];
|
| + }
|
| + if (_json.containsKey("json")) {
|
| + json = new JsonObject.fromJson(_json["json"]);
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (insertId != null) {
|
| + _json["insertId"] = insertId;
|
| + }
|
| + if (json != null) {
|
| + _json["json"] = json;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableDataInsertAllRequest {
|
| + /** The resource type of the response. */
|
| + core.String kind;
|
| +
|
| + /** The rows to insert. */
|
| + core.List<TableDataInsertAllRequestRows> rows;
|
| +
|
| +
|
| + TableDataInsertAllRequest();
|
| +
|
| + TableDataInsertAllRequest.fromJson(core.Map _json) {
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("rows")) {
|
| + rows = _json["rows"].map((value) => new TableDataInsertAllRequestRows.fromJson(value)).toList();
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (rows != null) {
|
| + _json["rows"] = rows.map((value) => (value).toJson()).toList();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableDataInsertAllResponseInsertErrors {
|
| + /** Error information for the row indicated by the index property. */
|
| + core.List<ErrorProto> errors;
|
| +
|
| + /** The index of the row that error applies to. */
|
| + core.int index;
|
| +
|
| +
|
| + TableDataInsertAllResponseInsertErrors();
|
| +
|
| + TableDataInsertAllResponseInsertErrors.fromJson(core.Map _json) {
|
| + if (_json.containsKey("errors")) {
|
| + errors = _json["errors"].map((value) => new ErrorProto.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("index")) {
|
| + index = _json["index"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (errors != null) {
|
| + _json["errors"] = errors.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (index != null) {
|
| + _json["index"] = index;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableDataInsertAllResponse {
|
| + /** An array of errors for rows that were not inserted. */
|
| + core.List<TableDataInsertAllResponseInsertErrors> insertErrors;
|
| +
|
| + /** The resource type of the response. */
|
| + core.String kind;
|
| +
|
| +
|
| + TableDataInsertAllResponse();
|
| +
|
| + TableDataInsertAllResponse.fromJson(core.Map _json) {
|
| + if (_json.containsKey("insertErrors")) {
|
| + insertErrors = _json["insertErrors"].map((value) => new TableDataInsertAllResponseInsertErrors.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (insertErrors != null) {
|
| + _json["insertErrors"] = insertErrors.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableDataList {
|
| + /** A hash of this page of results. */
|
| + core.String etag;
|
| +
|
| + /** The resource type of the response. */
|
| + core.String kind;
|
| +
|
| + /**
|
| + * A token used for paging results. Providing this token instead of the
|
| + * startIndex parameter can help you retrieve stable results when an
|
| + * underlying table is changing.
|
| + */
|
| + core.String pageToken;
|
| +
|
| + /** Rows of results. */
|
| + core.List<TableRow> rows;
|
| +
|
| + /** The total number of rows in the complete table. */
|
| + core.String totalRows;
|
| +
|
| +
|
| + TableDataList();
|
| +
|
| + TableDataList.fromJson(core.Map _json) {
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("pageToken")) {
|
| + pageToken = _json["pageToken"];
|
| + }
|
| + if (_json.containsKey("rows")) {
|
| + rows = _json["rows"].map((value) => new TableRow.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("totalRows")) {
|
| + totalRows = _json["totalRows"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (pageToken != null) {
|
| + _json["pageToken"] = pageToken;
|
| + }
|
| + if (rows != null) {
|
| + _json["rows"] = rows.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (totalRows != null) {
|
| + _json["totalRows"] = totalRows;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableFieldSchema {
|
| + /** [Optional] The field description. */
|
| + core.String description;
|
| +
|
| + /**
|
| + * [Optional] Describes the nested schema fields if the type property is set
|
| + * to RECORD.
|
| + */
|
| + core.List<TableFieldSchema> fields;
|
| +
|
| + /**
|
| + * [Optional] The field mode. Possible values include NULLABLE, REQUIRED and
|
| + * REPEATED. The default value is NULLABLE.
|
| + */
|
| + core.String mode;
|
| +
|
| + /** [Required] The field name. */
|
| + core.String name;
|
| +
|
| + /**
|
| + * [Required] The field data type. Possible values include STRING, INTEGER,
|
| + * FLOAT, BOOLEAN, TIMESTAMP or RECORD (where RECORD indicates that the field
|
| + * contains a nested schema).
|
| + */
|
| + core.String type;
|
| +
|
| +
|
| + TableFieldSchema();
|
| +
|
| + TableFieldSchema.fromJson(core.Map _json) {
|
| + if (_json.containsKey("description")) {
|
| + description = _json["description"];
|
| + }
|
| + if (_json.containsKey("fields")) {
|
| + fields = _json["fields"].map((value) => new TableFieldSchema.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("mode")) {
|
| + mode = _json["mode"];
|
| + }
|
| + if (_json.containsKey("name")) {
|
| + name = _json["name"];
|
| + }
|
| + if (_json.containsKey("type")) {
|
| + type = _json["type"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (description != null) {
|
| + _json["description"] = description;
|
| + }
|
| + if (fields != null) {
|
| + _json["fields"] = fields.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (mode != null) {
|
| + _json["mode"] = mode;
|
| + }
|
| + if (name != null) {
|
| + _json["name"] = name;
|
| + }
|
| + if (type != null) {
|
| + _json["type"] = type;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableListTables {
|
| + /** The user-friendly name for this table. */
|
| + core.String friendlyName;
|
| +
|
| + /** An opaque ID of the table */
|
| + core.String id;
|
| +
|
| + /** The resource type. */
|
| + core.String kind;
|
| +
|
| + /** A reference uniquely identifying the table. */
|
| + TableReference tableReference;
|
| +
|
| + /** The type of table. Possible values are: TABLE, VIEW. */
|
| + core.String type;
|
| +
|
| +
|
| + TableListTables();
|
| +
|
| + TableListTables.fromJson(core.Map _json) {
|
| + if (_json.containsKey("friendlyName")) {
|
| + friendlyName = _json["friendlyName"];
|
| + }
|
| + if (_json.containsKey("id")) {
|
| + id = _json["id"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("tableReference")) {
|
| + tableReference = new TableReference.fromJson(_json["tableReference"]);
|
| + }
|
| + if (_json.containsKey("type")) {
|
| + type = _json["type"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (friendlyName != null) {
|
| + _json["friendlyName"] = friendlyName;
|
| + }
|
| + if (id != null) {
|
| + _json["id"] = id;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (tableReference != null) {
|
| + _json["tableReference"] = (tableReference).toJson();
|
| + }
|
| + if (type != null) {
|
| + _json["type"] = type;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableList {
|
| + /** A hash of this page of results. */
|
| + core.String etag;
|
| +
|
| + /** The type of list. */
|
| + core.String kind;
|
| +
|
| + /** A token to request the next page of results. */
|
| + core.String nextPageToken;
|
| +
|
| + /** Tables in the requested dataset. */
|
| + core.List<TableListTables> tables;
|
| +
|
| + /** The total number of tables in the dataset. */
|
| + core.int totalItems;
|
| +
|
| +
|
| + TableList();
|
| +
|
| + TableList.fromJson(core.Map _json) {
|
| + if (_json.containsKey("etag")) {
|
| + etag = _json["etag"];
|
| + }
|
| + if (_json.containsKey("kind")) {
|
| + kind = _json["kind"];
|
| + }
|
| + if (_json.containsKey("nextPageToken")) {
|
| + nextPageToken = _json["nextPageToken"];
|
| + }
|
| + if (_json.containsKey("tables")) {
|
| + tables = _json["tables"].map((value) => new TableListTables.fromJson(value)).toList();
|
| + }
|
| + if (_json.containsKey("totalItems")) {
|
| + totalItems = _json["totalItems"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (etag != null) {
|
| + _json["etag"] = etag;
|
| + }
|
| + if (kind != null) {
|
| + _json["kind"] = kind;
|
| + }
|
| + if (nextPageToken != null) {
|
| + _json["nextPageToken"] = nextPageToken;
|
| + }
|
| + if (tables != null) {
|
| + _json["tables"] = tables.map((value) => (value).toJson()).toList();
|
| + }
|
| + if (totalItems != null) {
|
| + _json["totalItems"] = totalItems;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableReference {
|
| + /** [Required] ID of the dataset containing the table. */
|
| + core.String datasetId;
|
| +
|
| + /** [Required] ID of the project billed for storage of the table. */
|
| + core.String projectId;
|
| +
|
| + /** [Required] ID of the table. */
|
| + core.String tableId;
|
| +
|
| +
|
| + TableReference();
|
| +
|
| + TableReference.fromJson(core.Map _json) {
|
| + if (_json.containsKey("datasetId")) {
|
| + datasetId = _json["datasetId"];
|
| + }
|
| + if (_json.containsKey("projectId")) {
|
| + projectId = _json["projectId"];
|
| + }
|
| + if (_json.containsKey("tableId")) {
|
| + tableId = _json["tableId"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (datasetId != null) {
|
| + _json["datasetId"] = datasetId;
|
| + }
|
| + if (projectId != null) {
|
| + _json["projectId"] = projectId;
|
| + }
|
| + if (tableId != null) {
|
| + _json["tableId"] = tableId;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/**
|
| + * Represents a single row in the result set, consisting of one or more fields.
|
| + */
|
| +class TableRow {
|
| + /** Not documented yet. */
|
| + core.List<TableCell> f;
|
| +
|
| +
|
| + TableRow();
|
| +
|
| + TableRow.fromJson(core.Map _json) {
|
| + if (_json.containsKey("f")) {
|
| + f = _json["f"].map((value) => new TableCell.fromJson(value)).toList();
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (f != null) {
|
| + _json["f"] = f.map((value) => (value).toJson()).toList();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class TableSchema {
|
| + /** Describes the fields in a table. */
|
| + core.List<TableFieldSchema> fields;
|
| +
|
| +
|
| + TableSchema();
|
| +
|
| + TableSchema.fromJson(core.Map _json) {
|
| + if (_json.containsKey("fields")) {
|
| + fields = _json["fields"].map((value) => new TableFieldSchema.fromJson(value)).toList();
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (fields != null) {
|
| + _json["fields"] = fields.map((value) => (value).toJson()).toList();
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
| +/** Not documented yet. */
|
| +class ViewDefinition {
|
| + /** [Required] A query that BigQuery executes when the view is referenced. */
|
| + core.String query;
|
| +
|
| +
|
| + ViewDefinition();
|
| +
|
| + ViewDefinition.fromJson(core.Map _json) {
|
| + if (_json.containsKey("query")) {
|
| + query = _json["query"];
|
| + }
|
| + }
|
| +
|
| + core.Map toJson() {
|
| + var _json = new core.Map();
|
| + if (query != null) {
|
| + _json["query"] = query;
|
| + }
|
| + return _json;
|
| + }
|
| +}
|
| +
|
| +
|
|
|
Chromium Code Reviews
Issue 559053002:
Generate 0.1.0 version of googleapis/googleapis_beta (Closed)
Base URL: git@github.com:dart-lang/googleapis.git@master