(self, sql_stmt, user=None, fetch_profile_after_close=False,
fetch_exec_summary=False, profile_format=TRuntimeProfileFormat.STRING)
| 450 | self.__beeswax_client.close_dml(operation_handle.get_handle()) |
| 451 | |
| 452 | def execute(self, sql_stmt, user=None, fetch_profile_after_close=False, |
| 453 | fetch_exec_summary=False, profile_format=TRuntimeProfileFormat.STRING): |
| 454 | assert profile_format == TRuntimeProfileFormat.STRING, ( |
| 455 | "Beeswax client only supports getting runtime profile in STRING format.") |
| 456 | self.log_client(u"executing against {0}\n{1}".format( |
| 457 | self.__host_port, format_sql_for_logging(sql_stmt))) |
| 458 | return self.__beeswax_client.execute(sql_stmt, user=user, |
| 459 | fetch_profile_after_close=fetch_profile_after_close, |
| 460 | fetch_exec_summary=fetch_exec_summary) |
| 461 | |
| 462 | def execute_async(self, sql_stmt, user=None): |
| 463 | self.log_client(u"executing async {0}\n{1}".format( |
nothing calls this directly
no test coverage detected