2015-06-23 23:05:46 +00:00
|
|
|
# Copyright 2015 Google Inc.
|
|
|
|
#
|
|
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
# you may not use this file except in compliance with the License.
|
|
|
|
# You may obtain a copy of the License at
|
|
|
|
#
|
|
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
#
|
|
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
|
# See the License for the specific language governing permissions and
|
|
|
|
# limitations under the License.
|
|
|
|
|
|
|
|
require 'google/apis/core/base_service'
|
|
|
|
require 'google/apis/core/json_representation'
|
|
|
|
require 'google/apis/core/hashable'
|
|
|
|
require 'google/apis/errors'
|
|
|
|
|
|
|
|
module Google
|
|
|
|
module Apis
|
|
|
|
module BigqueryV2
|
|
|
|
# BigQuery API
|
|
|
|
#
|
|
|
|
# A data platform for customers to create, manage, share and query data.
|
|
|
|
#
|
|
|
|
# @example
|
|
|
|
# require 'google/apis/bigquery_v2'
|
|
|
|
#
|
|
|
|
# Bigquery = Google::Apis::BigqueryV2 # Alias the module
|
|
|
|
# service = Bigquery::BigqueryService.new
|
|
|
|
#
|
|
|
|
# @see https://cloud.google.com/bigquery/
|
|
|
|
class BigqueryService < Google::Apis::Core::BaseService
|
|
|
|
# @return [String]
|
|
|
|
# API key. Your API key identifies your project and provides you with API access,
|
|
|
|
# quota, and reports. Required unless you provide an OAuth 2.0 token.
|
|
|
|
attr_accessor :key
|
|
|
|
|
|
|
|
# @return [String]
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
attr_accessor :quota_user
|
|
|
|
|
|
|
|
# @return [String]
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
attr_accessor :user_ip
|
|
|
|
|
|
|
|
def initialize
|
feat: Automated regeneration of bigquery v2 client (#1329)
This PR was generated using Autosynth. :rainbow:
<details><summary>Log from Synthtool</summary>
```
2020-10-30 01:40:00,027 synthtool [DEBUG] > Executing /home/kbuilder/.cache/synthtool/google-api-ruby-client/synth.py.
On branch autosynth-bigquery-v2
nothing to commit, working tree clean
2020-10-30 01:40:00,057 synthtool [DEBUG] > Running: docker run --rm -v/home/kbuilder/.cache/synthtool/google-api-ruby-client:/workspace -v/var/run/docker.sock:/var/run/docker.sock -w /workspace --entrypoint script/synth.rb gcr.io/cloud-devrel-kokoro-resources/yoshi-ruby/autosynth bigquery v2
DEBUG:synthtool:Running: docker run --rm -v/home/kbuilder/.cache/synthtool/google-api-ruby-client:/workspace -v/var/run/docker.sock:/var/run/docker.sock -w /workspace --entrypoint script/synth.rb gcr.io/cloud-devrel-kokoro-resources/yoshi-ruby/autosynth bigquery v2
bundle install
Don't run Bundler as root. Bundler can ask for sudo if it is needed, and
installing your bundle as root will break this application for all non-root
users on this machine.
The dependency jruby-openssl (>= 0) will be unused by any of the platforms Bundler is installing for. Bundler is installing for ruby but the dependency is only for java. To add those platforms to the bundle, run `bundle lock --add-platform java`.
Fetching gem metadata from https://rubygems.org/.........
Fetching gem metadata from https://rubygems.org/.
Resolving dependencies...
Fetching rake 11.3.0
Installing rake 11.3.0
Fetching concurrent-ruby 1.1.7
Installing concurrent-ruby 1.1.7
Fetching i18n 1.8.5
Installing i18n 1.8.5
Fetching minitest 5.14.2
Installing minitest 5.14.2
Fetching thread_safe 0.3.6
Installing thread_safe 0.3.6
Fetching tzinfo 1.2.7
Installing tzinfo 1.2.7
Fetching activesupport 5.0.7.2
Installing activesupport 5.0.7.2
Fetching public_suffix 4.0.6
Installing public_suffix 4.0.6
Fetching addressable 2.7.0
Installing addressable 2.7.0
Fetching ast 2.4.1
Installing ast 2.4.1
Using bundler 2.1.4
Fetching byebug 11.1.3
Installing byebug 11.1.3 with native extensions
Fetching coderay 1.1.3
Installing coderay 1.1.3
Fetching json 2.3.1
Installing json 2.3.1 with native extensions
Fetching docile 1.3.2
Installing docile 1.3.2
Fetching simplecov-html 0.10.2
Installing simplecov-html 0.10.2
Fetching simplecov 0.16.1
Installing simplecov 0.16.1
Using sync 0.5.0
Fetching tins 1.26.0
Installing tins 1.26.0
Fetching term-ansicolor 1.7.1
Installing term-ansicolor 1.7.1
Fetching thor 0.20.3
Installing thor 0.20.3
Fetching coveralls 0.8.23
Installing coveralls 0.8.23
Fetching crack 0.4.4
Installing crack 0.4.4
Fetching declarative 0.0.20
Installing declarative 0.0.20
Fetching declarative-option 0.1.0
Installing declarative-option 0.1.0
Fetching diff-lcs 1.4.4
Installing diff-lcs 1.4.4
Fetching dotenv 2.7.6
Installing dotenv 2.7.6
Fetching fakefs 0.20.1
Installing fakefs 0.20.1
Fetching multipart-post 2.1.1
Installing multipart-post 2.1.1
Fetching ruby2_keywords 0.0.2
Installing ruby2_keywords 0.0.2
Fetching faraday 1.1.0
Installing faraday 1.1.0
Fetching gems 1.2.0
Installing gems 1.2.0
Fetching github-markup 1.7.0
Installing github-markup 1.7.0
Fetching jwt 2.2.2
Installing jwt 2.2.2
Fetching memoist 0.16.2
Installing memoist 0.16.2
Fetching multi_json 1.15.0
Installing multi_json 1.15.0
Fetching os 0.9.6
Installing os 0.9.6
Fetching signet 0.14.0
Installing signet 0.14.0
Fetching googleauth 0.14.0
Installing googleauth 0.14.0
Fetching httpclient 2.8.3
Installing httpclient 2.8.3
Fetching mini_mime 1.0.2
Installing mini_mime 1.0.2
Fetching uber 0.1.0
Installing uber 0.1.0
Fetching representable 3.0.4
Installing representable 3.0.4
Fetching retriable 3.1.2
Installing retriable 3.1.2
Fetching rexml 3.2.4
Installing rexml 3.2.4
Using google-api-client 0.47.0 from source at `.`
Fetching google-id-token 1.4.2
Installing google-id-token 1.4.2
Fetching hashdiff 1.0.1
Installing hashdiff 1.0.1
Fetching mime-types-data 3.2020.0512
Installing mime-types-data 3.2020.0512
Fetching mime-types 3.3.1
Installing mime-types 3.3.1
Fetching multi_xml 0.6.0
Installing multi_xml 0.6.0
Fetching httparty 0.18.1
Installing httparty 0.18.1
Fetching rspec-support 3.9.4
Installing rspec-support 3.9.4
Fetching rspec-core 3.9.3
Installing rspec-core 3.9.3
Fetching rspec-expectations 3.9.4
Installing rspec-expectations 3.9.4
Fetching rspec-mocks 3.9.1
Installing rspec-mocks 3.9.1
Fetching rspec 3.9.0
Installing rspec 3.9.0
Fetching json_spec 1.1.5
Installing json_spec 1.1.5
Fetching launchy 2.5.0
Installing launchy 2.5.0
Fetching little-plugger 1.1.4
Installing little-plugger 1.1.4
Fetching logging 2.3.0
Installing logging 2.3.0
Fetching method_source 1.0.0
Installing method_source 1.0.0
Fetching opencensus 0.5.0
Installing opencensus 0.5.0
Fetching parallel 1.19.2
Installing parallel 1.19.2
Fetching parser 2.7.2.0
Installing parser 2.7.2.0
Fetching powerpack 0.1.2
Installing powerpack 0.1.2
Fetching pry 0.13.1
Installing pry 0.13.1
Fetching pry-byebug 3.9.0
Installing pry-byebug 3.9.0
Fetching yard 0.9.25
Installing yard 0.9.25
Fetching pry-doc 0.13.5
Installing pry-doc 0.13.5
Fetching rainbow 2.2.2
Installing rainbow 2.2.2 with native extensions
Fetching redcarpet 3.5.0
Installing redcarpet 3.5.0 with native extensions
Fetching redis 3.3.5
Installing redis 3.3.5
Fetching rmail 1.1.4
Installing rmail 1.1.4
Fetching ruby-progressbar 1.10.1
Installing ruby-progressbar 1.10.1
Fetching unicode-display_width 1.7.0
Installing unicode-display_width 1.7.0
Fetching rubocop 0.49.1
Installing rubocop 0.49.1
Fetching webmock 2.3.2
Installing webmock 2.3.2
Bundle complete! 31 Gemfile dependencies, 78 gems now installed.
Use `bundle info [gemname]` to see where a bundled gem is installed.
Post-install message from i18n:
HEADS UP! i18n 1.1 changed fallbacks to exclude default locale.
But that may break your application.
If you are upgrading your Rails application from an older version of Rails:
Please check your Rails app for 'config.i18n.fallbacks = true'.
If you're using I18n (>= 1.1.0) and Rails (< 5.2.2), this should be
'config.i18n.fallbacks = [I18n.default_locale]'.
If not, fallbacks will be broken in your app by I18n 1.1.x.
If you are starting a NEW Rails application, you can ignore this notice.
For more info see:
https://github.com/svenfuchs/i18n/releases/tag/v1.1.0
Post-install message from httparty:
When you HTTParty, you must party hard!
echo a | bundle exec bin/generate-api gen generated --api=bigquery.v2 --names-out=/workspace/api_names_out.yaml
Loading bigquery, version v2 from https://raw.githubusercontent.com/googleapis/discovery-artifact-manager/master/discoveries/bigquery.v2.json
conflict google/apis/bigquery_v2.rb
<pis/bigquery_v2.rb? (enter "h" for help) [Ynaqdhm] a
force google/apis/bigquery_v2.rb
conflict google/apis/bigquery_v2/service.rb
force google/apis/bigquery_v2/service.rb
conflict google/apis/bigquery_v2/classes.rb
force google/apis/bigquery_v2/classes.rb
identical google/apis/bigquery_v2/representations.rb
identical /workspace/api_names_out.yaml
2020-10-30 01:40:27,956 synthtool [DEBUG] > Wrote metadata to generated/google/apis/bigquery_v2/synth.metadata.
DEBUG:synthtool:Wrote metadata to generated/google/apis/bigquery_v2/synth.metadata.
```
</details>
Full log will be available here:
https://source.cloud.google.com/results/invocations/7d362833-5328-4c81-a247-3f5caf27d99a/targets
- [ ] To automatically regenerate this PR, check this box.
2020-10-30 08:52:02 +00:00
|
|
|
super('https://www.googleapis.com/', 'bigquery/v2/')
|
2017-09-09 00:35:50 +00:00
|
|
|
@batch_path = 'batch/bigquery/v2'
|
2015-06-23 23:05:46 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
# 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.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the dataset being deleted
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of dataset being deleted
|
|
|
|
# @param [Boolean] delete_contents
|
|
|
|
# If True, delete all the tables in the dataset. If False and the dataset
|
|
|
|
# contains tables, the request will fail. Default is False
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [NilClass] No result returned for this method
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [void]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def delete_dataset(project_id, dataset_id, delete_contents: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:delete, 'projects/{projectId}/datasets/{datasetId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['deleteContents'] = delete_contents unless delete_contents.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Returns the dataset specified by datasetID.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the requested dataset
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the requested dataset
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Dataset] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Dataset]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def get_dataset(project_id, dataset_id, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/datasets/{datasetId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Dataset::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Dataset
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Creates a new empty dataset.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the new dataset
|
|
|
|
# @param [Google::Apis::BigqueryV2::Dataset] dataset_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Dataset] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Dataset]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def insert_dataset(project_id, dataset_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:post, 'projects/{projectId}/datasets', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Dataset::Representation
|
|
|
|
command.request_object = dataset_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Dataset::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Dataset
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Lists all datasets in the specified project to which you have been granted the
|
|
|
|
# READER dataset role.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the datasets to be listed
|
|
|
|
# @param [Boolean] all
|
|
|
|
# Whether to list all datasets, including hidden ones
|
2016-08-08 20:25:38 +00:00
|
|
|
# @param [String] filter
|
|
|
|
# An expression for filtering the results of the request by label. The syntax is
|
2016-09-19 21:24:23 +00:00
|
|
|
# "labels.<name>[:<value>]". Multiple filters can be ANDed together by
|
|
|
|
# connecting with a space. Example: "labels.department:receiving labels.active".
|
|
|
|
# See Filtering datasets using labels for details.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Fixnum] max_results
|
|
|
|
# The maximum number of results to return
|
|
|
|
# @param [String] page_token
|
|
|
|
# Page token, returned by a previous call, to request the next page of results
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::DatasetList] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::DatasetList]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2016-08-08 20:25:38 +00:00
|
|
|
def list_datasets(project_id, all: nil, filter: nil, max_results: nil, page_token: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/datasets', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::DatasetList::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::DatasetList
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.query['all'] = all unless all.nil?
|
2016-08-08 20:25:38 +00:00
|
|
|
command.query['filter'] = filter unless filter.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# 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.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the dataset being updated
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the dataset being updated
|
|
|
|
# @param [Google::Apis::BigqueryV2::Dataset] dataset_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Dataset] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Dataset]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def patch_dataset(project_id, dataset_id, dataset_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:patch, 'projects/{projectId}/datasets/{datasetId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Dataset::Representation
|
|
|
|
command.request_object = dataset_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Dataset::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Dataset
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# 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.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the dataset being updated
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the dataset being updated
|
|
|
|
# @param [Google::Apis::BigqueryV2::Dataset] dataset_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Dataset] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Dataset]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def update_dataset(project_id, dataset_id, dataset_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:put, 'projects/{projectId}/datasets/{datasetId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Dataset::Representation
|
|
|
|
command.request_object = dataset_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Dataset::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Dataset
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Requests that a job be cancelled. This call will return immediately, and the
|
|
|
|
# client will need to poll for the job status to see if the cancel completed
|
2015-12-03 01:10:07 +00:00
|
|
|
# successfully. Cancelled jobs may still incur costs.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] project_id
|
2016-01-08 00:23:51 +00:00
|
|
|
# [Required] Project ID of the job to cancel
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] job_id
|
2016-01-08 00:23:51 +00:00
|
|
|
# [Required] Job ID of the job to cancel
|
2018-02-03 00:35:36 +00:00
|
|
|
# @param [String] location
|
2018-12-08 00:36:43 +00:00
|
|
|
# The geographic location of the job. Required except for US and EU. See details
|
|
|
|
# at https://cloud.google.com/bigquery/docs/locations#specifying_your_location.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::CancelJobResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::CancelJobResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2018-02-03 00:35:36 +00:00
|
|
|
def cancel_job(project_id, job_id, location: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:post, 'projects/{projectId}/jobs/{jobId}/cancel', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::CancelJobResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::CancelJobResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['jobId'] = job_id unless job_id.nil?
|
2018-02-03 00:35:36 +00:00
|
|
|
command.query['location'] = location unless location.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Returns information about a specific job. Job information is available for a
|
|
|
|
# six month period after creation. Requires that you're the person who ran the
|
|
|
|
# job, or have the Is Owner project role.
|
|
|
|
# @param [String] project_id
|
2016-01-08 00:23:51 +00:00
|
|
|
# [Required] Project ID of the requested job
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] job_id
|
2016-01-08 00:23:51 +00:00
|
|
|
# [Required] Job ID of the requested job
|
2018-02-03 00:35:36 +00:00
|
|
|
# @param [String] location
|
2018-12-08 00:36:43 +00:00
|
|
|
# The geographic location of the job. Required except for US and EU. See details
|
|
|
|
# at https://cloud.google.com/bigquery/docs/locations#specifying_your_location.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Job] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Job]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2018-02-03 00:35:36 +00:00
|
|
|
def get_job(project_id, job_id, location: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/jobs/{jobId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Job::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Job
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['jobId'] = job_id unless job_id.nil?
|
2018-02-03 00:35:36 +00:00
|
|
|
command.query['location'] = location unless location.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Retrieves the results of a query job.
|
|
|
|
# @param [String] project_id
|
2016-01-08 00:23:51 +00:00
|
|
|
# [Required] Project ID of the query job
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] job_id
|
2016-01-08 00:23:51 +00:00
|
|
|
# [Required] Job ID of the query job
|
2018-02-03 00:35:36 +00:00
|
|
|
# @param [String] location
|
2018-12-08 00:36:43 +00:00
|
|
|
# The geographic location where the job should run. Required except for US and
|
|
|
|
# EU. See details at https://cloud.google.com/bigquery/docs/locations#
|
|
|
|
# specifying_your_location.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Fixnum] max_results
|
|
|
|
# Maximum number of results to read
|
|
|
|
# @param [String] page_token
|
|
|
|
# Page token, returned by a previous call, to request the next page of results
|
2017-04-03 20:18:48 +00:00
|
|
|
# @param [Fixnum] start_index
|
2015-06-23 23:05:46 +00:00
|
|
|
# Zero-based index of the starting row
|
|
|
|
# @param [Fixnum] timeout_ms
|
|
|
|
# How long to wait for the query to complete, in milliseconds, before returning.
|
2015-07-20 21:49:34 +00:00
|
|
|
# Default is 10 seconds. If the timeout passes before the job completes, the '
|
|
|
|
# jobComplete' field in the response will be false
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::GetQueryResultsResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::GetQueryResultsResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2018-02-03 00:35:36 +00:00
|
|
|
def get_job_query_results(project_id, job_id, location: nil, max_results: nil, page_token: nil, start_index: nil, timeout_ms: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/queries/{jobId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::GetQueryResultsResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::GetQueryResultsResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['jobId'] = job_id unless job_id.nil?
|
2018-02-03 00:35:36 +00:00
|
|
|
command.query['location'] = location unless location.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
|
|
|
command.query['startIndex'] = start_index unless start_index.nil?
|
|
|
|
command.query['timeoutMs'] = timeout_ms unless timeout_ms.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Starts a new asynchronous job. Requires the Can View project role.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the project that will be billed for the job
|
|
|
|
# @param [Google::Apis::BigqueryV2::Job] job_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [IO, String] upload_source
|
|
|
|
# IO stream or filename containing content to upload
|
|
|
|
# @param [String] content_type
|
|
|
|
# Content type of the uploaded content.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Job] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Job]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def insert_job(project_id, job_object = nil, fields: nil, quota_user: nil, user_ip: nil, upload_source: nil, content_type: nil, options: nil, &block)
|
|
|
|
if upload_source.nil?
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:post, 'projects/{projectId}/jobs', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
else
|
2015-12-03 01:10:07 +00:00
|
|
|
command = make_upload_command(:post, 'projects/{projectId}/jobs', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.upload_source = upload_source
|
|
|
|
command.upload_content_type = content_type
|
|
|
|
end
|
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Job::Representation
|
|
|
|
command.request_object = job_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Job::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Job
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2015-07-31 00:05:47 +00:00
|
|
|
# Lists all jobs that you started in the specified project. Job information is
|
|
|
|
# available for a six month period after creation. The job list is sorted in
|
|
|
|
# reverse chronological order, by job creation time. Requires the Can View
|
|
|
|
# project role, or the Is Owner project role if you set the allUsers property.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the jobs to list
|
|
|
|
# @param [Boolean] all_users
|
|
|
|
# Whether to display jobs owned by all users in the project. Default false
|
2018-03-03 00:36:18 +00:00
|
|
|
# @param [Fixnum] max_creation_time
|
|
|
|
# Max value for job creation time, in milliseconds since the POSIX epoch. If set,
|
|
|
|
# only jobs created before or at this timestamp are returned
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Fixnum] max_results
|
|
|
|
# Maximum number of results to return
|
2018-03-03 00:36:18 +00:00
|
|
|
# @param [Fixnum] min_creation_time
|
|
|
|
# Min value for job creation time, in milliseconds since the POSIX epoch. If set,
|
|
|
|
# only jobs created after or at this timestamp are returned
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] page_token
|
|
|
|
# Page token, returned by a previous call, to request the next page of results
|
2019-08-13 00:37:50 +00:00
|
|
|
# @param [String] parent_job_id
|
|
|
|
# If set, retrieves only jobs whose parent is this job. Otherwise, retrieves
|
|
|
|
# only jobs which have no parent
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] projection
|
|
|
|
# Restrict information returned to a set of selected fields
|
|
|
|
# @param [Array<String>, String] state_filter
|
|
|
|
# Filter for job state
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::JobList] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::JobList]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2019-08-13 00:37:50 +00:00
|
|
|
def list_jobs(project_id, all_users: nil, max_creation_time: nil, max_results: nil, min_creation_time: nil, page_token: nil, parent_job_id: nil, projection: nil, state_filter: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/jobs', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::JobList::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::JobList
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.query['allUsers'] = all_users unless all_users.nil?
|
2018-03-03 00:36:18 +00:00
|
|
|
command.query['maxCreationTime'] = max_creation_time unless max_creation_time.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
2018-03-03 00:36:18 +00:00
|
|
|
command.query['minCreationTime'] = min_creation_time unless min_creation_time.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
2019-08-13 00:37:50 +00:00
|
|
|
command.query['parentJobId'] = parent_job_id unless parent_job_id.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['projection'] = projection unless projection.nil?
|
|
|
|
command.query['stateFilter'] = state_filter unless state_filter.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Runs a BigQuery SQL query synchronously and returns query results if the query
|
|
|
|
# completes within a specified timeout.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the project billed for the query
|
|
|
|
# @param [Google::Apis::BigqueryV2::QueryRequest] query_request_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::QueryResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::QueryResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2015-12-03 01:10:07 +00:00
|
|
|
def query_job(project_id, query_request_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:post, 'projects/{projectId}/queries', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::QueryRequest::Representation
|
|
|
|
command.request_object = query_request_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::QueryResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::QueryResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2019-05-17 00:37:21 +00:00
|
|
|
# Deletes the model specified by modelId from the dataset.
|
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the model to delete.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the model to delete.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] model_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Model ID of the model to delete.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [NilClass] No result returned for this method
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [void]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def delete_model(project_id, dataset_id, model_id, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:delete, 'projects/{+projectId}/datasets/{+datasetId}/models/{+modelId}', options)
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['modelId'] = model_id unless model_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Gets the specified model resource by model ID.
|
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the requested model.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the requested model.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] model_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Model ID of the requested model.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Model] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Model]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def get_model(project_id, dataset_id, model_id, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:get, 'projects/{+projectId}/datasets/{+datasetId}/models/{+modelId}', options)
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Model::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Model
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['modelId'] = model_id unless model_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2020-08-13 00:39:19 +00:00
|
|
|
# Lists all models in the specified dataset. Requires the READER dataset role.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the models to list.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the models to list.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [Fixnum] max_results
|
2020-08-13 00:39:19 +00:00
|
|
|
# The maximum number of results to return in a single response page. Leverage
|
|
|
|
# the page tokens to iterate through the entire collection.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] page_token
|
2020-08-13 00:39:19 +00:00
|
|
|
# Page token, returned by a previous call to request the next page of results
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::ListModelsResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::ListModelsResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def list_models(project_id, dataset_id, max_results: nil, page_token: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:get, 'projects/{+projectId}/datasets/{+datasetId}/models', options)
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::ListModelsResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::ListModelsResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Patch specific fields in the specified model.
|
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the model to patch.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the model to patch.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [String] model_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Model ID of the model to patch.
|
2019-05-17 00:37:21 +00:00
|
|
|
# @param [Google::Apis::BigqueryV2::Model] model_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Model] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Model]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def patch_model(project_id, dataset_id, model_id, model_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:patch, 'projects/{+projectId}/datasets/{+datasetId}/models/{+modelId}', options)
|
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Model::Representation
|
|
|
|
command.request_object = model_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Model::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Model
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['modelId'] = model_id unless model_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2017-09-09 00:35:50 +00:00
|
|
|
# Returns the email address of the service account for your project used for
|
|
|
|
# interactions with Google Cloud KMS.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID for which the service account is requested.
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2017-09-09 00:35:50 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2017-09-09 00:35:50 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::GetServiceAccountResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::GetServiceAccountResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def get_project_service_account(project_id, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/serviceAccount', options)
|
2017-09-09 00:35:50 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::GetServiceAccountResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::GetServiceAccountResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2015-06-23 23:05:46 +00:00
|
|
|
# Lists all projects to which you have been granted any project role.
|
|
|
|
# @param [Fixnum] max_results
|
|
|
|
# Maximum number of results to return
|
|
|
|
# @param [String] page_token
|
|
|
|
# Page token, returned by a previous call, to request the next page of results
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::ProjectList] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::ProjectList]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def list_projects(max_results: nil, page_token: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::ProjectList::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::ProjectList
|
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2019-06-14 00:37:43 +00:00
|
|
|
# Deletes the routine specified by routineId from the dataset.
|
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the routine to delete
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the routine to delete
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] routine_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Routine ID of the routine to delete
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [NilClass] No result returned for this method
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [void]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def delete_routine(project_id, dataset_id, routine_id, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:delete, 'projects/{+projectId}/datasets/{+datasetId}/routines/{+routineId}', options)
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['routineId'] = routine_id unless routine_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Gets the specified routine resource by routine ID.
|
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the requested routine
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the requested routine
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] routine_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Routine ID of the requested routine
|
2019-12-20 00:38:31 +00:00
|
|
|
# @param [String] read_mask
|
2020-08-13 00:39:19 +00:00
|
|
|
# If set, only the Routine fields in the field mask are returned in the response.
|
|
|
|
# If unset, all Routine fields are returned.
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Routine] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Routine]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2019-12-20 00:38:31 +00:00
|
|
|
def get_routine(project_id, dataset_id, routine_id, read_mask: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-06-14 00:37:43 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{+projectId}/datasets/{+datasetId}/routines/{+routineId}', options)
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Routine::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Routine
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['routineId'] = routine_id unless routine_id.nil?
|
2019-12-20 00:38:31 +00:00
|
|
|
command.query['readMask'] = read_mask unless read_mask.nil?
|
2019-06-14 00:37:43 +00:00
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Creates a new routine in the dataset.
|
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the new routine
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the new routine
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [Google::Apis::BigqueryV2::Routine] routine_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Routine] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Routine]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def insert_routine(project_id, dataset_id, routine_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:post, 'projects/{+projectId}/datasets/{+datasetId}/routines', options)
|
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Routine::Representation
|
|
|
|
command.request_object = routine_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Routine::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Routine
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2020-08-13 00:39:19 +00:00
|
|
|
# Lists all routines in the specified dataset. Requires the READER dataset role.
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the routines to list
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the routines to list
|
2019-12-20 00:38:31 +00:00
|
|
|
# @param [String] filter
|
2020-08-13 00:39:19 +00:00
|
|
|
# If set, then only the Routines matching this filter are returned. The current
|
|
|
|
# supported form is either "routine_type:" or "routineType:", where is a
|
|
|
|
# RoutineType enum. Example: "routineType:SCALAR_FUNCTION".
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [Fixnum] max_results
|
2020-08-13 00:39:19 +00:00
|
|
|
# The maximum number of results to return in a single response page. Leverage
|
|
|
|
# the page tokens to iterate through the entire collection.
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] page_token
|
2020-08-13 00:39:19 +00:00
|
|
|
# Page token, returned by a previous call, to request the next page of results
|
2019-12-20 00:38:31 +00:00
|
|
|
# @param [String] read_mask
|
2020-08-13 00:39:19 +00:00
|
|
|
# If set, then only the Routine fields in the field mask, as well as project_id,
|
|
|
|
# dataset_id and routine_id, are returned in the response. If unset, then the
|
|
|
|
# following Routine fields are returned: etag, project_id, dataset_id,
|
|
|
|
# routine_id, routine_type, creation_time, last_modified_time, and language.
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::ListRoutinesResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::ListRoutinesResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2019-12-20 00:38:31 +00:00
|
|
|
def list_routines(project_id, dataset_id, filter: nil, max_results: nil, page_token: nil, read_mask: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-06-14 00:37:43 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{+projectId}/datasets/{+datasetId}/routines', options)
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::ListRoutinesResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::ListRoutinesResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
2019-12-20 00:38:31 +00:00
|
|
|
command.query['filter'] = filter unless filter.nil?
|
2019-06-14 00:37:43 +00:00
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
2019-12-20 00:38:31 +00:00
|
|
|
command.query['readMask'] = read_mask unless read_mask.nil?
|
2019-06-14 00:37:43 +00:00
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Updates information in an existing routine. The update method replaces the
|
|
|
|
# entire Routine resource.
|
|
|
|
# @param [String] project_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Project ID of the routine to update
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] dataset_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Dataset ID of the routine to update
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [String] routine_id
|
2019-09-13 00:38:03 +00:00
|
|
|
# Required. Routine ID of the routine to update
|
2019-06-14 00:37:43 +00:00
|
|
|
# @param [Google::Apis::BigqueryV2::Routine] routine_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Routine] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Routine]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def update_routine(project_id, dataset_id, routine_id, routine_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:put, 'projects/{+projectId}/datasets/{+datasetId}/routines/{+routineId}', options)
|
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Routine::Representation
|
|
|
|
command.request_object = routine_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Routine::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Routine
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['routineId'] = routine_id unless routine_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2020-10-16 00:39:01 +00:00
|
|
|
# Lists all row access policies on the specified table.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Required. Project ID of the row access policies to list.
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Required. Dataset ID of row access policies to list.
|
|
|
|
# @param [String] table_id
|
|
|
|
# Required. Table ID of the table to list row access policies.
|
|
|
|
# @param [Fixnum] page_size
|
|
|
|
# The maximum number of results to return in a single response page. Leverage
|
|
|
|
# the page tokens to iterate through the entire collection.
|
|
|
|
# @param [String] page_token
|
|
|
|
# Page token, returned by a previous call, to request the next page of results.
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::ListRowAccessPoliciesResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::ListRowAccessPoliciesResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def list_row_access_policies(project_id, dataset_id, table_id, page_size: nil, page_token: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:get, 'projects/{+projectId}/datasets/{+datasetId}/tables/{+tableId}/rowAccessPolicies', options)
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::ListRowAccessPoliciesResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::ListRowAccessPoliciesResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['tableId'] = table_id unless table_id.nil?
|
|
|
|
command.query['pageSize'] = page_size unless page_size.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2015-06-23 23:05:46 +00:00
|
|
|
# Streams data into BigQuery one record at a time without needing to run a load
|
|
|
|
# job. Requires the WRITER dataset role.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the destination table.
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the destination table.
|
|
|
|
# @param [String] table_id
|
|
|
|
# Table ID of the destination table.
|
|
|
|
# @param [Google::Apis::BigqueryV2::InsertAllTableDataRequest] insert_all_table_data_request_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::InsertAllTableDataResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::InsertAllTableDataResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def insert_all_table_data(project_id, dataset_id, table_id, insert_all_table_data_request_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:post, 'projects/{projectId}/datasets/{datasetId}/tables/{tableId}/insertAll', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::InsertAllTableDataRequest::Representation
|
|
|
|
command.request_object = insert_all_table_data_request_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::InsertAllTableDataResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::InsertAllTableDataResponse
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['tableId'] = table_id unless table_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Retrieves table data from a specified set of rows. Requires the READER dataset
|
|
|
|
# role.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the table to read
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the table to read
|
|
|
|
# @param [String] table_id
|
|
|
|
# Table ID of the table to read
|
|
|
|
# @param [Fixnum] max_results
|
|
|
|
# Maximum number of results to return
|
|
|
|
# @param [String] page_token
|
|
|
|
# Page token, returned by a previous call, identifying the result set
|
2017-03-27 22:14:47 +00:00
|
|
|
# @param [String] selected_fields
|
|
|
|
# List of fields to return (comma-separated). If unspecified, all fields are
|
|
|
|
# returned
|
2017-04-03 20:18:48 +00:00
|
|
|
# @param [Fixnum] start_index
|
2015-06-23 23:05:46 +00:00
|
|
|
# Zero-based index of the starting row to read
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::TableDataList] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::TableDataList]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2017-03-27 22:14:47 +00:00
|
|
|
def list_table_data(project_id, dataset_id, table_id, max_results: nil, page_token: nil, selected_fields: nil, start_index: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/datasets/{datasetId}/tables/{tableId}/data', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::TableDataList::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::TableDataList
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['tableId'] = table_id unless table_id.nil?
|
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
2017-03-27 22:14:47 +00:00
|
|
|
command.query['selectedFields'] = selected_fields unless selected_fields.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['startIndex'] = start_index unless start_index.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Deletes the table specified by tableId from the dataset. If the table contains
|
|
|
|
# data, all the data will be deleted.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the table to delete
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the table to delete
|
|
|
|
# @param [String] table_id
|
|
|
|
# Table ID of the table to delete
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [NilClass] No result returned for this method
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [void]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def delete_table(project_id, dataset_id, table_id, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:delete, 'projects/{projectId}/datasets/{datasetId}/tables/{tableId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['tableId'] = table_id unless table_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# 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.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the requested table
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the requested table
|
|
|
|
# @param [String] table_id
|
|
|
|
# Table ID of the requested table
|
2017-03-27 22:14:47 +00:00
|
|
|
# @param [String] selected_fields
|
|
|
|
# List of fields to return (comma-separated). If unspecified, all fields are
|
|
|
|
# returned
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Table] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Table]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
2017-03-27 22:14:47 +00:00
|
|
|
def get_table(project_id, dataset_id, table_id, selected_fields: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/datasets/{datasetId}/tables/{tableId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Table::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Table
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['tableId'] = table_id unless table_id.nil?
|
2017-03-27 22:14:47 +00:00
|
|
|
command.query['selectedFields'] = selected_fields unless selected_fields.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2020-08-13 00:39:19 +00:00
|
|
|
# Gets the access control policy for a resource. Returns an empty policy if the
|
|
|
|
# resource exists and does not have a policy set.
|
2020-05-09 00:38:07 +00:00
|
|
|
# @param [String] resource
|
2020-08-13 00:39:19 +00:00
|
|
|
# REQUIRED: The resource for which the policy is being requested. See the
|
|
|
|
# operation documentation for the appropriate value for this field.
|
2020-05-09 00:38:07 +00:00
|
|
|
# @param [Google::Apis::BigqueryV2::GetIamPolicyRequest] get_iam_policy_request_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Policy] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Policy]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def get_table_iam_policy(resource, get_iam_policy_request_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:post, '{+resource}:getIamPolicy', options)
|
|
|
|
command.request_representation = Google::Apis::BigqueryV2::GetIamPolicyRequest::Representation
|
|
|
|
command.request_object = get_iam_policy_request_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Policy::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Policy
|
|
|
|
command.params['resource'] = resource unless resource.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2015-06-23 23:05:46 +00:00
|
|
|
# Creates a new, empty table in the dataset.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the new table
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the new table
|
|
|
|
# @param [Google::Apis::BigqueryV2::Table] table_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Table] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Table]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def insert_table(project_id, dataset_id, table_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:post, 'projects/{projectId}/datasets/{datasetId}/tables', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Table::Representation
|
|
|
|
command.request_object = table_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Table::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Table
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Lists all tables in the specified dataset. Requires the READER dataset role.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the tables to list
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the tables to list
|
|
|
|
# @param [Fixnum] max_results
|
|
|
|
# Maximum number of results to return
|
|
|
|
# @param [String] page_token
|
|
|
|
# Page token, returned by a previous call, to request the next page of results
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::TableList] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::TableList]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def list_tables(project_id, dataset_id, max_results: nil, page_token: nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:get, 'projects/{projectId}/datasets/{datasetId}/tables', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.response_representation = Google::Apis::BigqueryV2::TableList::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::TableList
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.query['maxResults'] = max_results unless max_results.nil?
|
|
|
|
command.query['pageToken'] = page_token unless page_token.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# 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.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the table to update
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the table to update
|
|
|
|
# @param [String] table_id
|
|
|
|
# Table ID of the table to update
|
|
|
|
# @param [Google::Apis::BigqueryV2::Table] table_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Table] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Table]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def patch_table(project_id, dataset_id, table_id, table_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:patch, 'projects/{projectId}/datasets/{datasetId}/tables/{tableId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Table::Representation
|
|
|
|
command.request_object = table_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Table::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Table
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['tableId'] = table_id unless table_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
2020-05-09 00:38:07 +00:00
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# Sets the access control policy on the specified resource. Replaces any
|
2020-08-13 00:39:19 +00:00
|
|
|
# existing policy. Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `
|
|
|
|
# PERMISSION_DENIED` errors.
|
2020-05-09 00:38:07 +00:00
|
|
|
# @param [String] resource
|
2020-08-13 00:39:19 +00:00
|
|
|
# REQUIRED: The resource for which the policy is being specified. See the
|
|
|
|
# operation documentation for the appropriate value for this field.
|
2020-05-09 00:38:07 +00:00
|
|
|
# @param [Google::Apis::BigqueryV2::SetIamPolicyRequest] set_iam_policy_request_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Policy] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Policy]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def set_table_iam_policy(resource, set_iam_policy_request_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:post, '{+resource}:setIamPolicy', options)
|
|
|
|
command.request_representation = Google::Apis::BigqueryV2::SetIamPolicyRequest::Representation
|
|
|
|
command.request_object = set_iam_policy_request_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Policy::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Policy
|
|
|
|
command.params['resource'] = resource unless resource.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
2020-08-13 00:39:19 +00:00
|
|
|
# Returns permissions that a caller has on the specified resource. If the
|
|
|
|
# resource does not exist, this will return an empty set of permissions, not a `
|
|
|
|
# NOT_FOUND` error. Note: This operation is designed to be used for building
|
|
|
|
# permission-aware UIs and command-line tools, not for authorization checking.
|
|
|
|
# This operation may "fail open" without warning.
|
2020-05-09 00:38:07 +00:00
|
|
|
# @param [String] resource
|
2020-08-13 00:39:19 +00:00
|
|
|
# REQUIRED: The resource for which the policy detail is being requested. See the
|
|
|
|
# operation documentation for the appropriate value for this field.
|
2020-05-09 00:38:07 +00:00
|
|
|
# @param [Google::Apis::BigqueryV2::TestIamPermissionsRequest] test_iam_permissions_request_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
|
|
|
# @param [String] user_ip
|
|
|
|
# Deprecated. Please use quotaUser instead.
|
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::TestIamPermissionsResponse] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::TestIamPermissionsResponse]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def test_table_iam_permissions(resource, test_iam_permissions_request_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
|
|
|
command = make_simple_command(:post, '{+resource}:testIamPermissions', options)
|
|
|
|
command.request_representation = Google::Apis::BigqueryV2::TestIamPermissionsRequest::Representation
|
|
|
|
command.request_object = test_iam_permissions_request_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::TestIamPermissionsResponse::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::TestIamPermissionsResponse
|
|
|
|
command.params['resource'] = resource unless resource.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
2015-06-23 23:05:46 +00:00
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
# 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.
|
|
|
|
# @param [String] project_id
|
|
|
|
# Project ID of the table to update
|
|
|
|
# @param [String] dataset_id
|
|
|
|
# Dataset ID of the table to update
|
|
|
|
# @param [String] table_id
|
|
|
|
# Table ID of the table to update
|
|
|
|
# @param [Google::Apis::BigqueryV2::Table] table_object
|
|
|
|
# @param [String] fields
|
|
|
|
# Selector specifying which fields to include in a partial response.
|
|
|
|
# @param [String] quota_user
|
2018-05-02 00:35:55 +00:00
|
|
|
# An opaque string that represents a user for quota purposes. Must not exceed 40
|
|
|
|
# characters.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [String] user_ip
|
2018-05-02 00:35:55 +00:00
|
|
|
# Deprecated. Please use quotaUser instead.
|
2015-06-23 23:05:46 +00:00
|
|
|
# @param [Google::Apis::RequestOptions] options
|
|
|
|
# Request-specific options
|
|
|
|
#
|
|
|
|
# @yield [result, err] Result & error if block supplied
|
|
|
|
# @yieldparam result [Google::Apis::BigqueryV2::Table] parsed result object
|
|
|
|
# @yieldparam err [StandardError] error object if request failed
|
|
|
|
#
|
|
|
|
# @return [Google::Apis::BigqueryV2::Table]
|
|
|
|
#
|
|
|
|
# @raise [Google::Apis::ServerError] An error occurred on the server and the request can be retried
|
|
|
|
# @raise [Google::Apis::ClientError] The request is invalid and should not be retried without modification
|
|
|
|
# @raise [Google::Apis::AuthorizationError] Authorization is required
|
|
|
|
def update_table(project_id, dataset_id, table_id, table_object = nil, fields: nil, quota_user: nil, user_ip: nil, options: nil, &block)
|
2019-05-10 00:37:26 +00:00
|
|
|
command = make_simple_command(:put, 'projects/{projectId}/datasets/{datasetId}/tables/{tableId}', options)
|
2015-06-23 23:05:46 +00:00
|
|
|
command.request_representation = Google::Apis::BigqueryV2::Table::Representation
|
|
|
|
command.request_object = table_object
|
|
|
|
command.response_representation = Google::Apis::BigqueryV2::Table::Representation
|
|
|
|
command.response_class = Google::Apis::BigqueryV2::Table
|
|
|
|
command.params['projectId'] = project_id unless project_id.nil?
|
|
|
|
command.params['datasetId'] = dataset_id unless dataset_id.nil?
|
|
|
|
command.params['tableId'] = table_id unless table_id.nil?
|
|
|
|
command.query['fields'] = fields unless fields.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
execute_or_queue_command(command, &block)
|
|
|
|
end
|
|
|
|
|
|
|
|
protected
|
|
|
|
|
|
|
|
def apply_command_defaults(command)
|
|
|
|
command.query['key'] = key unless key.nil?
|
|
|
|
command.query['quotaUser'] = quota_user unless quota_user.nil?
|
|
|
|
command.query['userIp'] = user_ip unless user_ip.nil?
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|