File tree Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Original file line number Diff line number Diff line change @@ -188,9 +188,10 @@ def _init_thrift_transport(self) -> TTransport:
188
188
189
189
def _client (self ) -> Client :
190
190
protocol = TBinaryProtocol .TBinaryProtocol (self ._transport )
191
- client : Client = self .hms_v4 .Client (protocol )
192
- if self ._hive_version and self ._hive_version < 4 :
191
+ if self ._hive_version < 4 :
193
192
client : Client = self .hms_v3 .Client (protocol )
193
+ else :
194
+ client : Client = self .hms_v4 .Client (protocol )
194
195
if self ._ugi :
195
196
client .set_ugi (* self ._ugi )
196
197
return client
@@ -348,12 +349,6 @@ def _create_hive_client(properties: Dict[str, str]) -> _HiveClient:
348
349
else :
349
350
raise ValueError (f"Unable to connect to hive using uri: { properties [URI ]} " )
350
351
351
- def _update_imported_metastore_modules (self , properties ) -> None :
352
- breakpoint ()
353
- v3 = importlib .import_module ('hive_metastore.v3.ThriftHiveMetastore' )
354
- Client = v3 .Client
355
- self ._client = self ._create_hive_client (properties )
356
-
357
352
def _convert_hive_into_iceberg (self , table : HiveTable ) -> Table :
358
353
properties : Dict [str , str ] = table .parameters
359
354
if TABLE_TYPE not in properties :
You can’t perform that action at this time.
0 commit comments