File tree
Expand file treeCollapse file tree3 files changed
+9
-9
lines changed third_party/bigframes_vendored/pandas/io
Expand file treeCollapse file tree3 files changed
+9
-9
lines changed Original file line number | Diff line number | Diff line change |
---|
@@ -290,16 +290,16 @@ def read_json(
|
290 | 290 |
|
291 | 291 |
|
292 | 292 | def read_gbq(
|
293 |
| -query: str, |
| 293 | +query_or_table: str, |
294 | 294 | *,
|
295 | 295 | index_col: Iterable[str] | str = (),
|
296 | 296 | col_order: Iterable[str] = (),
|
297 | 297 | max_results: Optional[int] = None,
|
298 | 298 | ) -> bigframes.dataframe.DataFrame:
|
299 |
| -_set_default_session_location_if_possible(query) |
| 299 | +_set_default_session_location_if_possible(query_or_table) |
300 | 300 | return global_session.with_default_session(
|
301 | 301 | bigframes.session.Session.read_gbq,
|
302 |
| -query, |
| 302 | +query_or_table, |
303 | 303 | index_col=index_col,
|
304 | 304 | col_order=col_order,
|
305 | 305 | max_results=max_results,
|
|
Original file line number | Diff line number | Diff line change |
---|
@@ -262,17 +262,17 @@ def close(self):
|
262 | 262 |
|
263 | 263 | def read_gbq(
|
264 | 264 | self,
|
265 |
| -query: str, |
| 265 | +query_or_table: str, |
266 | 266 | *,
|
267 | 267 | index_col: Iterable[str] | str = (),
|
268 | 268 | col_order: Iterable[str] = (),
|
269 | 269 | max_results: Optional[int] = None,
|
270 | 270 | # Add a verify index argument that fails if the index is not unique.
|
271 | 271 | ) -> dataframe.DataFrame:
|
272 | 272 | # TODO(b/281571214): Generate prompt to show the progress of read_gbq.
|
273 |
| -if _is_query(query): |
| 273 | +if _is_query(query_or_table): |
274 | 274 | return self._read_gbq_query(
|
275 |
| -query, |
| 275 | +query_or_table, |
276 | 276 | index_col=index_col,
|
277 | 277 | col_order=col_order,
|
278 | 278 | max_results=max_results,
|
@@ -283,7 +283,7 @@ def read_gbq(
|
283 | 283 | # deterministic query so we can avoid serializing if we have a
|
284 | 284 | # unique index.
|
285 | 285 | return self._read_gbq_table(
|
286 |
| -query, |
| 286 | +query_or_table, |
287 | 287 | index_col=index_col,
|
288 | 288 | col_order=col_order,
|
289 | 289 | max_results=max_results,
|
|
Original file line number | Diff line number | Diff line change |
---|
|
11 | 11 | class GBQIOMixin:
|
12 | 12 | def read_gbq(
|
13 | 13 | self,
|
14 |
| -query: str, |
| 14 | +query_or_table: str, |
15 | 15 | *,
|
16 | 16 | index_col: Iterable[str] | str = (),
|
17 | 17 | col_order: Iterable[str] = (),
|
@@ -69,7 +69,7 @@ def read_gbq(
|
69 | 69 | [5 rows x 3 columns]
|
70 | 70 |
|
71 | 71 | Args:
|
72 |
| -query (str): |
| 72 | +query_or_table (str): |
73 | 73 | A SQL string to be executed or a BigQuery table to be read. The
|
74 | 74 | table must be specified in the format of
|
75 | 75 | `project.dataset.tablename` or `dataset.tablename`.
|
|
You can’t perform that action at this time.
0 commit comments