Connect to the server and start the query runner thread.
(self)
| 96 | NUM_OTHER_ERRORS: Value("i", 0)} |
| 97 | |
| 98 | def connect(self): |
| 99 | """Connect to the server and start the query runner thread.""" |
| 100 | self.impalad_conn = self.impalad.impala.connect(impalad=self.impalad) |
| 101 | |
| 102 | def run_query(self, query, mem_limit_mb, run_set_up=False, |
| 103 | timeout_secs=maxsize, cancel_mech=None, retain_profile=False): |
no outgoing calls