@@ -77,6 +77,7 @@ def read_parquet(
7777 columns : Optional [List [str ]] = ...,
7878 validate_schema : bool = ...,
7979 coerce_int96_timestamp_unit : Optional [str ] = ...,
80+ schema : Optional [pa .Schema ] = ...,
8081 last_modified_begin : Optional [datetime .datetime ] = ...,
8182 last_modified_end : Optional [datetime .datetime ] = ...,
8283 version_id : Optional [Union [str , Dict [str , str ]]] = ...,
@@ -101,6 +102,7 @@ def read_parquet(
101102 columns : Optional [List [str ]] = ...,
102103 validate_schema : bool = ...,
103104 coerce_int96_timestamp_unit : Optional [str ] = ...,
105+ schema : Optional [pa .Schema ] = ...,
104106 last_modified_begin : Optional [datetime .datetime ] = ...,
105107 last_modified_end : Optional [datetime .datetime ] = ...,
106108 version_id : Optional [Union [str , Dict [str , str ]]] = ...,
@@ -125,6 +127,7 @@ def read_parquet(
125127 columns : Optional [List [str ]] = ...,
126128 validate_schema : bool = ...,
127129 coerce_int96_timestamp_unit : Optional [str ] = ...,
130+ schema : Optional [pa .Schema ] = ...,
128131 last_modified_begin : Optional [datetime .datetime ] = ...,
129132 last_modified_end : Optional [datetime .datetime ] = ...,
130133 version_id : Optional [Union [str , Dict [str , str ]]] = ...,
@@ -149,6 +152,7 @@ def read_parquet(
149152 columns : Optional [List [str ]] = ...,
150153 validate_schema : bool = ...,
151154 coerce_int96_timestamp_unit : Optional [str ] = ...,
155+ schema : Optional [pa .Schema ] = ...,
152156 last_modified_begin : Optional [datetime .datetime ] = ...,
153157 last_modified_end : Optional [datetime .datetime ] = ...,
154158 version_id : Optional [Union [str , Dict [str , str ]]] = ...,
0 commit comments