(self, db_name=None)
| 384 | return self._warehouse_dir |
| 385 | |
| 386 | def connect(self, db_name=None): |
| 387 | conn = HiveConnection( |
| 388 | host_name=self.hs2_host_name, |
| 389 | port=self.hs2_port, |
| 390 | user_name=self.cluster.hadoop_user_name, |
| 391 | db_name=db_name, |
| 392 | use_kerberos=self.cluster.use_kerberos, |
| 393 | use_ssl=self.cluster.use_ssl, |
| 394 | ca_cert=self.cluster.ca_cert, |
| 395 | ) |
| 396 | conn.cluster = self.cluster |
| 397 | return conn |
| 398 | |
| 399 | @contextmanager |
| 400 | def cursor(self, db_name=None): |