Contains the results of an Impala query execution. Parameters: Required: query (Query): The query object associated with this result. start_time (datetime): Timestamp at the start of execution. query_config (BeeswaxQueryExecConfig, HS2QueryExecConfig) client_name (int)
| 121 | |
| 122 | |
| 123 | class ImpalaQueryResult(HiveQueryResult): |
| 124 | """Contains the results of an Impala query execution. |
| 125 | |
| 126 | Parameters: |
| 127 | Required: |
| 128 | query (Query): The query object associated with this result. |
| 129 | start_time (datetime): Timestamp at the start of execution. |
| 130 | query_config (BeeswaxQueryExecConfig, HS2QueryExecConfig) |
| 131 | client_name (int): The thread id |
| 132 | |
| 133 | Optional: |
| 134 | time_taken (float): Time taken to execute the query. |
| 135 | summary (str): query exection summary (ex. returned 10 rows) |
| 136 | data (list of str): Query results returned by Impala. |
| 137 | runtime_profile (str): Saved runtime profile of the query's execution. |
| 138 | exec_summary (TExecSummary) |
| 139 | success (bool): True if the execution was successful. |
| 140 | |
| 141 | Attributes - these are modified by another class: |
| 142 | query_error (str): Empty string if the query succeeded. Error returned by the client |
| 143 | if it failed. |
| 144 | executor_name (str) |
| 145 | """ |
| 146 | |
| 147 | def __init__(self, query, **kwargs): |
| 148 | super(ImpalaQueryResult, self).__init__(query, **kwargs) |
| 149 | self.runtime_profile = kwargs.get('runtime_profile', str()) |
| 150 | self.exec_summary = kwargs.get('exec_summary', str()) |
no outgoing calls
no test coverage detected