import org.gbif.api.service.registry.NetworkService; //导入依赖的package包/类
public NubChangedService(NubChangedConfiguration configuration) {
  this.cfg = configuration;
  Injector regInj = cfg.registry.createRegistryInjector(new MetricModule(cfg.ganglia));
  datasetService = regInj.getInstance(DatasetService.class);
  nubUpdService = new BackboneDatasetUpdater(datasetService, regInj.getInstance(OrganizationService.class), regInj.getInstance(NetworkService.class));
  registry = regInj.getInstance(MetricRegistry.class);
  registry.meter(MATCH_METER);
}
 

import org.gbif.api.service.registry.NetworkService; //导入依赖的package包/类
@Override
protected void configure() {
  bind(DatasetService.class).toInstance(new DatasetServiceFileImpl(datasetFile));
  bind(OrganizationService.class).toInstance(new OrganizationServiceEmptyImpl());
  bind(InstallationService.class).toInstance(new InstallationServiceEmptyImpl());
  bind(NetworkService.class).toInstance(new NetworkServiceEmptyImpl());
  bind(NodeService.class).toInstance(new NodeServiceEmptyImpl());
}
 

import org.gbif.api.service.registry.NetworkService; //导入依赖的package包/类
/**
 * Returns a dataset iterable by testing the given registry key first to see whether it is a dataset, organization or installation.
 * In case of an organization key the published datasets will be returned.
 *
 * @param key a valid dataset, organization or installation key. If null all datasets will be iterated over
 * @param pageSize to use when talking to the registry
 * @throws IllegalArgumentException if given key is not existing
 */
public static Iterable<Dataset> datasets(@Nullable UUID key, @Nullable DatasetType type,
                                         DatasetService ds, OrganizationService os, InstallationService is,
                                         NetworkService ns, NodeService nos, int pageSize) {
    if (key == null) {
        LOG.info("Iterate over all {} datasets", type == null ? "" : type);
        return new DatasetPager(ds, type, pageSize);

    } else if (isDataset(key, ds)) {
        LOG.info("Iterate over dataset {}", key);
        return ImmutableList.of(ds.get(key));

    } else if (isOrganization(key, os)) {
        LOG.info("Iterate over all {} datasets published by {}", type == null ? "" : type, key);
        return new OrgPublishingPager(os, key, type, pageSize);

    } else if (isInstallation(key, is)) {
        LOG.info("Iterate over all {} datasets hosted by installation {}", type == null ? "" : type, key);
        return new InstallationPager(is, key, type, pageSize);

    } else if (isNode(key, nos)) {
        LOG.info("Iterate over all {} datasets endorsed by node {}", type == null ? "" : type, key);
        return new NetworkPager(ns, key, type, pageSize);

    } else if (isNetwork(key, ns)) {
        LOG.info("Iterate over all {} datasets belonging to network {}", type == null ? "" : type, key);
        return new NodeDatasetPager(nos, key, type, pageSize);
    }
    throw new IllegalArgumentException("Given key is no valid GBIF registry key: " + key);
}
 

import org.gbif.api.service.registry.NetworkService; //导入依赖的package包/类
public BackboneDatasetUpdater(DatasetService datasetService, OrganizationService organizationService, NetworkService networkService) {
  this.datasetService = datasetService;
  this.organizationService = organizationService;
  this.networkService = networkService;
}
 

import org.gbif.api.service.registry.NetworkService; //导入依赖的package包/类
private static boolean isNetwork(UUID key, NetworkService ns) {
    return ns.get(key) != null;
}
 

import org.gbif.api.service.registry.NetworkService; //导入依赖的package包/类
public NetworkPager(NetworkService service, UUID key, @Nullable DatasetType type, int pageSize) {
    super(type, pageSize);
    this.service = service;
    this.key = key;
}
 

import org.gbif.api.service.registry.NetworkService; //导入依赖的package包/类
/**
 * Iterates over all constituents of a given network.
 * @param key a valid network key
 * @param type an optional filter to just include the given dataset type
 */
public static Iterable<Dataset> networkDatasets(UUID key, @Nullable DatasetType type, NetworkService service) {
    LOG.info("Iterate over all {} datasets belonging to network {}", type == null ? "" : type, key);
    return new NetworkPager(service, key, type, PagingConstants.DEFAULT_PARAM_LIMIT);
}