Skip to content

Commit 9a16a8c

Browse files
committed
Merge branch 'bigquery-udf-resources'
2 parents 22d982a + dad9288 commit 9a16a8c

File tree

2 files changed

+17
-4
lines changed

2 files changed

+17
-4
lines changed

doc/source/whatsnew/v0.19.0.txt

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -379,6 +379,7 @@ Google BigQuery Enhancements
379379

380380
- The :func:`read_gbq` method has gained the ``dialect`` argument to allow users to specify whether to use BigQuery's legacy SQL or BigQuery's standard SQL. See the :ref:`docs <io.bigquery_reader>` for more details (:issue:`13615`).
381381
- The :func:`~DataFrame.to_gbq` method now allows the DataFrame column order to differ from the destination table schema (:issue:`11359`).
382+
- The :func:`read_gbq` method now allows passing user defined functions
382383

383384
.. _whatsnew_0190.errstate:
384385

pandas/io/gbq.py

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -375,7 +375,7 @@ def process_insert_errors(self, insert_errors):
375375

376376
raise StreamingInsertError
377377

378-
def run_query(self, query):
378+
def run_query(self, query, **kwargs):
379379
try:
380380
from googleapiclient.errors import HttpError
381381
except:
@@ -395,6 +395,10 @@ def run_query(self, query):
395395
}
396396
}
397397
}
398+
query_config = kwargs.get('query_config')
399+
if query_config is not None:
400+
job_data['configuration']['query'].update(query_config)
401+
398402

399403
self._start_timer()
400404
try:
@@ -621,8 +625,9 @@ def _parse_entry(field_value, field_type):
621625
return field_value
622626

623627

624-
def read_gbq(query, project_id=None, index_col=None, col_order=None,
625-
reauth=False, verbose=True, private_key=None, dialect='legacy'):
628+
def read_gbq(query, project_id=None, index_col=None, col_order=None,
629+
reauth=False, verbose=True, private_key=None, dialect='legacy',
630+
**kwargs):
626631
"""Load data from Google BigQuery.
627632
628633
THIS IS AN EXPERIMENTAL LIBRARY
@@ -682,6 +687,13 @@ def read_gbq(query, project_id=None, index_col=None, col_order=None,
682687
683688
.. versionadded:: 0.19.0
684689
690+
**kwargs: Arbitrary keyword arguments
691+
query_config (dict): query configuration parameters for job processing.
692+
For more information see `BigQuery SQL Reference
693+
<https://cloud.google.com/bigquery/docs/reference/rest/v2/jobs#configuration.query>`
694+
695+
.. versionadded:: 0.19.0
696+
685697
Returns
686698
-------
687699
df: DataFrame
@@ -698,7 +710,7 @@ def read_gbq(query, project_id=None, index_col=None, col_order=None,
698710
connector = GbqConnector(project_id, reauth=reauth, verbose=verbose,
699711
private_key=private_key,
700712
dialect=dialect)
701-
schema, pages = connector.run_query(query)
713+
schema, pages = connector.run_query(query, **kwargs)
702714
dataframe_list = []
703715
while len(pages) > 0:
704716
page = pages.pop()

0 commit comments

Comments
 (0)