@Override public IsCatalogJanitorEnabledResponse isCatalogJanitorEnabled(RpcController c, IsCatalogJanitorEnabledRequest req) throws ServiceException { return IsCatalogJanitorEnabledResponse.newBuilder().setValue( master.isCatalogJanitorEnabled()).build(); }
@Override public IsCatalogJanitorEnabledResponse isCatalogJanitorEnabled(RpcController c, IsCatalogJanitorEnabledRequest req) throws ServiceException { boolean isEnabled = catalogJanitorChore != null ? catalogJanitorChore.getEnabled() : false; return IsCatalogJanitorEnabledResponse.newBuilder().setValue(isEnabled).build(); }
/** * Creates a request for querying the master whether the catalog janitor is enabled * @return A {@link IsCatalogJanitorEnabledRequest} */ public static IsCatalogJanitorEnabledRequest buildIsCatalogJanitorEnabledRequest() { return IS_CATALOG_JANITOR_ENABLED_REQUEST; }