File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change 23
23
import requests
24
24
25
25
from bigframes import clients
26
+ from bigframes .core import log_adapter
26
27
import bigframes .dataframe
27
28
import bigframes .exceptions as bfe
28
29
from bigframes .operations import base
33
34
FILE_EXT_REGEX = r"(\.[0-9a-zA-Z]+$)"
34
35
35
36
37
+ @log_adapter .class_logger
36
38
class BlobAccessor (base .SeriesMethods ):
37
39
def __init__ (self , * args , ** kwargs ):
38
40
if not bigframes .options .experiments .blob :
Original file line number Diff line number Diff line change @@ -1757,7 +1757,9 @@ def from_glob_path(
1757
1757
1758
1758
table = self ._create_object_table (path , connection )
1759
1759
1760
- s = self .read_gbq (table )["uri" ].str .to_blob (connection )
1760
+ s = self ._loader .read_gbq_table (table , api_name = "from_glob_path" )[
1761
+ "uri"
1762
+ ].str .to_blob (connection )
1761
1763
return s .rename (name ).to_frame ()
1762
1764
1763
1765
def _create_bq_connection (
@@ -1807,7 +1809,9 @@ def read_gbq_object_table(
1807
1809
table = self .bqclient .get_table (object_table )
1808
1810
connection = table ._properties ["externalDataConfiguration" ]["connectionId" ]
1809
1811
1810
- s = self .read_gbq (object_table )["uri" ].str .to_blob (connection )
1812
+ s = self ._loader .read_gbq_table (object_table , api_name = "read_gbq_object_table" )[
1813
+ "uri"
1814
+ ].str .to_blob (connection )
1811
1815
return s .rename (name ).to_frame ()
1812
1816
1813
1817
You can’t perform that action at this time.
0 commit comments