| 468 | } |
| 469 | |
| 470 | Status CatalogOpExecutor::GetNullPartitionName( |
| 471 | const TGetNullPartitionNameRequest& req, TGetNullPartitionNameResponse* result) { |
| 472 | int attempt = 0; // Used for debug action only. |
| 473 | CatalogServiceConnection::RpcStatus rpc_status = |
| 474 | CatalogServiceConnection::DoRpcWithRetry( |
| 475 | env_->catalogd_lightweight_req_client_cache(), |
| 476 | *ExecEnv::GetInstance()->GetCatalogdAddress().get(), |
| 477 | &CatalogServiceClientWrapper::GetNullPartitionName, req, |
| 478 | FLAGS_catalog_client_connection_num_retries, |
| 479 | FLAGS_catalog_client_rpc_retry_interval_ms, |
| 480 | [&attempt]() { return CatalogRpcDebugFn(&attempt); }, result); |
| 481 | RETURN_IF_ERROR(rpc_status.status); |
| 482 | return Status::OK(); |
| 483 | } |
| 484 | |
| 485 | Status CatalogOpExecutor::GetLatestCompactions( |
| 486 | const TGetLatestCompactionsRequest& req, TGetLatestCompactionsResponse* result) { |
nothing calls this directly
no test coverage detected