(self, **kwargs)
| 53 | plan_first (boolean): EXPLAIN queries before executing them |
| 54 | """ |
| 55 | def __init__(self, **kwargs): |
| 56 | self.query_executors = kwargs.get('query_executors') |
| 57 | self.shuffle = kwargs.get('shuffle', False) |
| 58 | self.iterations = kwargs.get('iterations', 1) |
| 59 | self.query_iterations = kwargs.get('query_iterations', 1) |
| 60 | self.impalads = kwargs.get('impalads') |
| 61 | self.num_clients = kwargs.get('num_clients', 1) |
| 62 | self.plan_first = kwargs.get('plan_first', False) |
| 63 | self._exit = Event() |
| 64 | self._results = list() |
| 65 | self._result_dict_lock = Lock() |
| 66 | self._thread_name = "[%s " % self.query_executors[0].query.db + "Thread %d]" |
| 67 | self._threads = [] |
| 68 | self._create_workload_threads() |
| 69 | |
| 70 | @property |
| 71 | def results(self): |
nothing calls this directly
no test coverage detected