-
Notifications
You must be signed in to change notification settings - Fork 1.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
bigquery: modify LoadJob #4103
bigquery: modify LoadJob #4103
Conversation
This PR handles loading from GCS. Loading from a local file will be done separately.
@@ -17,6 +17,7 @@ | |||
from __future__ import absolute_import | |||
|
|||
import collections | |||
import six |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
@@ -490,26 +491,37 @@ def list_jobs(self, max_results=None, page_token=None, all_users=None, | |||
max_results=max_results, | |||
extra_params=extra_params) | |||
|
|||
def load_table_from_storage(self, job_id, destination, *source_uris): | |||
def load_table_from_storage(self, destination, source_uris, |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
||
def __init__(self): | ||
self._properties = {} | ||
self._schema = () |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
config = copy.deepcopy(self._properties) | ||
if len(self.schema) > 0: | ||
config['schema'] = {'fields': _build_schema_resource(self.schema)} | ||
# TODO(jba): add a comment explaining why skipLeadingRows is a string. |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
@@ -490,26 +492,37 @@ def list_jobs(self, max_results=None, page_token=None, all_users=None, | |||
max_results=max_results, | |||
extra_params=extra_params) | |||
|
|||
def load_table_from_storage(self, job_id, destination, *source_uris): | |||
def load_table_from_storage(self, source_uris, destination, | |||
job_id=None, job_config=None): | |||
"""Construct a job for loading data into a table from CloudStorage. |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This PR handles loading from GCS. Loading from a local file will be done separately.
This PR handles loading from GCS. Loading from a local file will be done separately.
This PR handles loading from GCS. Loading from a local file will be done separately.