| 421 | |
| 422 | |
| 423 | Status CatalogOpExecutor::PrioritizeLoad(const TPrioritizeLoadRequest& req, |
| 424 | TPrioritizeLoadResponse* result) { |
| 425 | int attempt = 0; // Used for debug action only. |
| 426 | CatalogServiceConnection::RpcStatus rpc_status = |
| 427 | CatalogServiceConnection::DoRpcWithRetry( |
| 428 | env_->catalogd_lightweight_req_client_cache(), |
| 429 | *ExecEnv::GetInstance()->GetCatalogdAddress().get(), |
| 430 | &CatalogServiceClientWrapper::PrioritizeLoad, req, |
| 431 | FLAGS_catalog_client_connection_num_retries, |
| 432 | FLAGS_catalog_client_rpc_retry_interval_ms, |
| 433 | [&attempt]() { return CatalogRpcDebugFn(&attempt); }, result); |
| 434 | RETURN_IF_ERROR(rpc_status.status); |
| 435 | return Status::OK(); |
| 436 | } |
| 437 | |
| 438 | Status CatalogOpExecutor::GetPartitionStats( |
| 439 | const TGetPartitionStatsRequest& req, TGetPartitionStatsResponse* result) { |
nothing calls this directly
no test coverage detected