| 436 | } |
| 437 | |
| 438 | Status CatalogOpExecutor::GetPartitionStats( |
| 439 | const TGetPartitionStatsRequest& req, TGetPartitionStatsResponse* result) { |
| 440 | int attempt = 0; // Used for debug action only. |
| 441 | CatalogServiceConnection::RpcStatus rpc_status = |
| 442 | CatalogServiceConnection::DoRpcWithRetry(env_->catalogd_client_cache(), |
| 443 | *ExecEnv::GetInstance()->GetCatalogdAddress().get(), |
| 444 | &CatalogServiceClientWrapper::GetPartitionStats, req, |
| 445 | FLAGS_catalog_client_connection_num_retries, |
| 446 | FLAGS_catalog_client_rpc_retry_interval_ms, |
| 447 | [&attempt]() { return CatalogRpcDebugFn(&attempt); }, result); |
| 448 | RETURN_IF_ERROR(rpc_status.status); |
| 449 | return Status::OK(); |
| 450 | } |
| 451 | |
| 452 | Status CatalogOpExecutor::UpdateTableUsage(const TUpdateTableUsageRequest& req, |
| 453 | TUpdateTableUsageResponse* resp) { |
nothing calls this directly
no test coverage detected