| 1963 | } |
| 1964 | |
| 1965 | void ClientRequestState::SetCreateTableAsSelectResultSet() { |
| 1966 | DCHECK(ddl_type() == TDdlType::CREATE_TABLE_AS_SELECT); |
| 1967 | int64_t total_num_rows_inserted = 0; |
| 1968 | // There will only be rows inserted in the case a new table was created as part of this |
| 1969 | // operation. |
| 1970 | if (catalog_op_executor_->ddl_exec_response()->new_table_created) { |
| 1971 | DCHECK(GetCoordinator()); |
| 1972 | total_num_rows_inserted = GetCoordinator()->dml_exec_state()->GetNumModifiedRows(); |
| 1973 | } |
| 1974 | const string& summary_msg = Substitute("Inserted $0 row(s)", total_num_rows_inserted); |
| 1975 | VLOG_QUERY << summary_msg; |
| 1976 | vector<string> results(1, summary_msg); |
| 1977 | SetResultSet(results); |
| 1978 | } |
| 1979 | |
| 1980 | void ClientRequestState::MarkInactive() { |
| 1981 | client_wait_sw_.Start(); |
nothing calls this directly
no test coverage detected