Create workload threads. Each workload thread is analogus to a client name, and is identified by a unique ID, the workload that's being run and the table formats it's being run on.
(self)
| 73 | return self._results |
| 74 | |
| 75 | def _create_workload_threads(self): |
| 76 | """Create workload threads. |
| 77 | |
| 78 | Each workload thread is analogus to a client name, and is identified by a unique ID, |
| 79 | the workload that's being run and the table formats it's being run on.""" |
| 80 | for thread_num in range(self.num_clients): |
| 81 | thread = Thread(target=self._run_queries, args=[thread_num], |
| 82 | name=self._thread_name % thread_num) |
| 83 | thread.daemon = True |
| 84 | self._threads.append(thread) |
| 85 | |
| 86 | def _get_next_impalad(self): |
| 87 | """Maintains a rotating list of impalads""" |