| 450 | } |
| 451 | |
| 452 | Status CatalogOpExecutor::UpdateTableUsage(const TUpdateTableUsageRequest& req, |
| 453 | TUpdateTableUsageResponse* resp) { |
| 454 | int attempt = 0; // Used for debug action only. |
| 455 | CatalogServiceConnection::RpcStatus rpc_status = |
| 456 | CatalogServiceConnection::DoRpcWithRetry( |
| 457 | // The operation doesn't require table lock in catalogd. It doesn't require |
| 458 | // the table being loaded neither. So we can use clients for lightweight |
| 459 | // requests. |
| 460 | env_->catalogd_lightweight_req_client_cache(), |
| 461 | *ExecEnv::GetInstance()->GetCatalogdAddress().get(), |
| 462 | &CatalogServiceClientWrapper::UpdateTableUsage, req, |
| 463 | FLAGS_catalog_client_connection_num_retries, |
| 464 | FLAGS_catalog_client_rpc_retry_interval_ms, |
| 465 | [&attempt]() { return CatalogRpcDebugFn(&attempt); }, resp); |
| 466 | RETURN_IF_ERROR(rpc_status.status); |
| 467 | return Status::OK(); |
| 468 | } |
| 469 | |
| 470 | Status CatalogOpExecutor::GetNullPartitionName( |
| 471 | const TGetNullPartitionNameRequest& req, TGetNullPartitionNameResponse* result) { |
nothing calls this directly
no test coverage detected