| 1030 | } |
| 1031 | |
| 1032 | bool SQLClusterRouter::GetSQLPlan(const std::string& sql, |
| 1033 | ::hybridse::node::NodeManager* nm, |
| 1034 | ::hybridse::node::PlanNodeList* plan) { |
| 1035 | if (nm == NULL || plan == NULL) return false; |
| 1036 | ::hybridse::base::Status sql_status; |
| 1037 | PlanAPI::CreatePlanTreeFromScript(sql, *plan, nm, sql_status); |
| 1038 | if (0 != sql_status.code) { |
| 1039 | LOG(WARNING) << sql_status.msg; |
| 1040 | return false; |
| 1041 | } |
| 1042 | return true; |
| 1043 | } |
| 1044 | |
| 1045 | bool SQLClusterRouter::RefreshCatalog() { |
| 1046 | bool ok = cluster_sdk_->Refresh(); |
nothing calls this directly
no outgoing calls
no test coverage detected