本文整理了Java中com.liveramp.hank.coordinator.zk.ZkDomain类的一些代码示例，展示了ZkDomain类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkDomain类的具体详情如下：
包路径：com.liveramp.hank.coordinator.zk.ZkDomain
类名称：ZkDomain

ZkDomain介绍

暂无

代码示例

代码示例来源：origin: LiveRamp/hank

@Override
 public String toString() {
  return "ZkDomain [domainPath=" + path + ", id=" + getId() + ", name=" + name + ", numParts=" + getNumParts()
    + ", partitioner=" + getPartitionerClassName() + ", storageEngine=" + getStorageEngine()
    + ", storageEngineFactoryClassName=" + getStorageEngineFactoryClassName() + ", storageEngineOptions="
    + getStorageEngineOptions() + "]";
 }
}

代码示例来源：origin: LiveRamp/hank

@Override
public DomainVersion getVersionShallow(int versionNumber) throws IOException {
 if (versions.isLoaded()) {
  return findVersion(getVersions(), versionNumber);
 } else {
  try {
   return new ZkDomainVersion(zk,
     ZkPath.append(path, VERSIONS_PATH, ZkDomainVersion.getPathName(versionNumber)),
     getDomainVersionPropertiesSerialization());
  } catch (InterruptedException e) {
   return null;
  } catch (KeeperException e) {
   return null;
  }
 }
}

代码示例来源：origin: LiveRamp/hank

@Override
public DomainVersion getVersion(int versionNumber) throws IOException {
 return findVersion(getVersions(), versionNumber);
}

代码示例来源：origin: LiveRamp/hank

@Override
public StorageEngine getStorageEngine() {
 String storageEngineFactoryClassName = getStorageEngineFactoryClassName();
 try {
  StorageEngineFactory factory = (StorageEngineFactory)Class.forName(storageEngineFactoryClassName).newInstance();
  return factory.getStorageEngine(getStorageEngineOptions(), this);
 } catch (Exception e) {
  LOG.error("Could not instantiate storage engine from factory " + storageEngineFactoryClassName
    + " with options " + getStorageEngineOptions(), e);
  return null;
 }
}

代码示例来源：origin: LiveRamp/hank

@Test
public void testCreate() throws Exception {
 ZkDomain dc = ZkDomain.create(getZk(), getRoot(), "domain0", 1024, ConstantStorageEngine.Factory.class.getName(), "---", Murmur64Partitioner.class.getName(), 0, Collections.<String>emptyList());
 assertEquals(0, dc.getId());
 assertEquals("domain0", dc.getName());
 assertEquals(1024, dc.getNumParts());
 assertEquals(ConstantStorageEngine.Factory.class.getName(), dc.getStorageEngineFactoryClassName());
 assertEquals(ConstantStorageEngine.Factory.class, dc.getStorageEngineFactoryClass());
 assertTrue(dc.getStorageEngine() instanceof ConstantStorageEngine);
 assertTrue(dc.getVersions().isEmpty());
 assertTrue(dc.getPartitioner() instanceof Murmur64Partitioner);
}

代码示例来源：origin: LiveRamp/hank

@Test
public void testVersioning() throws Exception {
 final ZkDomain dc = ZkDomain.create(getZk(), getRoot(), "domain0", 1, STORAGE_ENGINE_FACTORY, STORAGE_ENGINE_OPTS, CONST_PARTITIONER, 0, Collections.<String>emptyList());
 assertTrue(dc.getVersions().isEmpty());
 DomainVersion version = dc.openNewVersion(null);
 assertEquals(0, version.getVersionNumber());
 assertEquals(1, dc.getVersions().size());
 version.close();
 Thread.sleep(1000);
 version = dc.openNewVersion(null);
 assertNotNull(version);
 assertEquals(1, version.getVersionNumber());
 assertEquals(2, dc.getVersions().size());
 // Test getVersionShallow
 assertTrue(dc.getVersionShallow(0) != null);
 assertEquals(dc.getVersion(0), dc.getVersionShallow(0));
}

代码示例来源：origin: LiveRamp/hank

@Test
 public void testDelete() throws Exception {
  ZkDomain dc = ZkDomain.create(getZk(), getRoot(), "domain0", 1, ConstantStorageEngine.Factory.class.getName(), "---", Murmur64Partitioner.class.getName(), 0, Collections.<String>emptyList());
  assertNotNull(getZk().exists(ZkPath.append(getRoot(), "domain0"), false));
  assertTrue(dc.delete());
  WaitUntil.orDie(() -> {
   try {
    return getZk().exists(ZkPath.append(getRoot(), "domain0"), false) == null;
   } catch (KeeperException e) {
    throw new RuntimeException(e);
   } catch (InterruptedException e) {
    throw new RuntimeException(e);
   }
  });
  assertNull(getZk().exists(ZkPath.append(getRoot(), "domain0"), false));
 }
}

代码示例来源：origin: LiveRamp/hank

@Override
public Domain updateDomain(String domainName,
              int numParts,
              String storageEngineFactoryClassName,
              String storageEngineOptions,
              String partitionerClassName,
              List<String> requiredHostFlags) throws IOException {
 ZkDomain domain = (ZkDomain)getDomain(domainName);
 if (domain == null) {
  throw new IOException("Could not get Domain '" + domainName + "' from Coordinator.");
 } else {
  try {
   domain.update(domain.getId(), numParts, storageEngineFactoryClassName, storageEngineOptions,
     partitionerClassName, requiredHostFlags);
   return domain;
  } catch (Exception e) {
   throw new IOException(e);
  }
 }
}

代码示例来源：origin: LiveRamp/hank

@Override
public Domain addDomain(String domainName,
            int numParts,
            String storageEngineFactoryName,
            String storageEngineOptions,
            String partitionerName,
            List<String> requiredHostFlags) throws IOException {
 try {
  ZkDomain domain = ZkDomain.create(zk, domainsRoot, domainName, numParts, storageEngineFactoryName,
    storageEngineOptions, partitionerName, getNextDomainId(), requiredHostFlags);
  domains.put(domainName, domain);
  return domain;
 } catch (Exception e) {
  throw new IOException(e);
 }
}

代码示例来源：origin: LiveRamp/hank

@Override
public Domain getDomainShallow(String domainName) {
 if (domains.isLoaded()) {
  return getDomain(domainName);
 } else {
  try {
   return new ZkDomain(zk, ZkPath.append(domainsRoot, domainName));
  } catch (InterruptedException e) {
   return null;
  } catch (KeeperException e) {
   return null;
  }
 }
}

代码示例来源：origin: LiveRamp/hank

@Override
public Class<? extends StorageEngineFactory> getStorageEngineFactoryClass() {
 try {
  return (Class<? extends StorageEngineFactory>)Class.forName(getStorageEngineFactoryClassName());
 } catch (ClassNotFoundException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: LiveRamp/hank

@Override
public boolean deleteDomain(String domainName) throws IOException {
 ZkDomain domain = domains.remove(domainName);
 if (domain == null) {
  return false;
 }
 // remove domain from all domain groups
 for (DomainGroup domainGroup : getDomainGroups()) {
  domainGroup.removeDomain(domain);
 }
 return domain.delete();
}

代码示例来源：origin: LiveRamp/hank

@Override
public DomainVersion openNewVersion(DomainVersionProperties domainVersionProperties) throws IOException {
 // First, copy next version number
 int versionNumber = metadata.get().get_next_version_number();
 // Then, increment next version counter
 try {
  metadata.update(metadata.new Updater() {
   @Override
   public void updateCopy(DomainMetadata currentCopy) {
    currentCopy.set_next_version_number(currentCopy.get_next_version_number() + 1);
   }
  });
 } catch (InterruptedException e) {
  throw new RuntimeException(e);
 } catch (KeeperException e) {
  throw new RuntimeException(e);
 }
 try {
  ZkDomainVersion newVersion = ZkDomainVersion.create(zk, path, versionNumber, domainVersionProperties, getDomainVersionPropertiesSerialization());
  versions.put(ZkDomainVersion.getPathName(newVersion.getVersionNumber()), newVersion);
  return newVersion;
 } catch (Exception e) {
  // pretty good chance that someone beat us to the punch.
  LOG.warn("Got an exception when trying to open a version for domain " + path, e);
  throw new IOException(e);
 }
}

代码示例来源：origin: LiveRamp/hank

@Test
public void testLoad() throws Exception {
 ZkDomain.create(getZk(), getRoot(), "domain0", 1024, ConstantStorageEngine.Factory.class.getName(), "---", Murmur64Partitioner.class.getName(), 0, Collections.<String>emptyList());
 ZkDomain dc = new ZkDomain(getZk(), ZkPath.append(getRoot(), "domain0"));
 assertEquals(0, dc.getId());
 assertEquals("domain0", dc.getName());
 assertEquals(1024, dc.getNumParts());
 assertEquals(ConstantStorageEngine.Factory.class.getName(), dc.getStorageEngineFactoryClassName());
 assertEquals(ConstantStorageEngine.Factory.class, dc.getStorageEngineFactoryClass());
 assertTrue(dc.getStorageEngine() instanceof ConstantStorageEngine);
 assertTrue(dc.getVersions().isEmpty());
 assertTrue(dc.getPartitioner() instanceof Murmur64Partitioner);
}

代码示例来源：origin: LiveRamp/hank

@Before
public void setUp() throws Exception {
 create(domains_root);
 create(domain_groups_root);
 create(ring_groups_root);
 ZkDomain.create(getZk(), domains_root, "domain0", 1, ConstantStorageEngine.Factory.class.getName(), "---", ConstantPartitioner.class.getName(), 0, Collections.emptyList());
 ZkDomainGroup domainGroup = ZkDomainGroup.create(getZk(), null, domain_groups_root, "myDomainGroup");
 Map<Domain, Integer> domainIdToVersion = new HashMap<>();
 domainGroup.setDomainVersions(domainIdToVersion);
 ZkRingGroup rg = ZkRingGroup.create(getZk(), ring_groups_root + "/myRingGroup", domainGroup, new MockCoordinator());
 Ring rc = rg.addRing(1);
 rc.addHost(new PartitionServerAddress("localhost", 1), Collections.emptyList());
 coord = getCoord();
}

代码示例来源：origin: LiveRamp/hank

public static ZkDomain create(ZooKeeperPlus zk,
               String domainsRoot,
               String domainName,
               int numParts,
               String storageEngineFactoryClassName,
               String storageEngineOptions,
               String partitionerClassName,
               int id,
               List<String> requiredHostFlags) throws KeeperException, InterruptedException, IOException {
 String path = ZkPath.append(domainsRoot, domainName);
 DomainMetadata initialValue = new DomainMetadata(id, numParts, storageEngineFactoryClassName,
   storageEngineOptions, partitionerClassName, Hosts.joinHostFlags(requiredHostFlags), 0);
 return new ZkDomain(zk, path, true, initialValue);
}

代码示例来源：origin: LiveRamp/hank

@Test
public void testLoad() throws Exception {
 final Domain d0 = ZkDomain.create(getZk(), domainsRoot, "domain0", 1024, Echo.Factory.class.getName(), "---",
   Murmur64Partitioner.class.getName(), 0, Collections.emptyList());
 final Domain d1 = ZkDomain.create(getZk(), domainsRoot, "domain1", 1024, Echo.Factory.class.getName(), "---",
   Murmur64Partitioner.class.getName(), 1, Collections.emptyList());

代码示例来源：origin: LiveRamp/hank

return null;
} else {
 return new ZkDomain(zk, ZkPath.append(basePath, relPath));