(self)
| 882 | return cursor |
| 883 | |
| 884 | def _connect(self): |
| 885 | self._conn = impala.dbapi.connect( |
| 886 | host=self._host_name, |
| 887 | port=self._port, |
| 888 | user=self._user_name, |
| 889 | password=self._password, |
| 890 | database=self.db_name, |
| 891 | timeout=(60 * 60), |
| 892 | auth_mechanism=('GSSAPI' if self._use_kerberos else self._NON_KERBEROS_AUTH_MECH), |
| 893 | kerberos_service_name=self._KERBEROS_SERVICE_NAME, |
| 894 | use_ssl=self._use_ssl, |
| 895 | ca_cert=self._ca_cert) |
| 896 | |
| 897 | |
| 898 | class HiveCursor(ImpalaCursor): |