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

ZkHost.getAddress介绍

暂无

代码示例

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

@Override
public int hashCode() {
 final int prime = 31;
 int result = 1;
 result = prime * result + ((getAddress() == null) ? 0 : getAddress().hashCode());
 result = prime * result + ((path == null) ? 0 : path.hashCode());
 return result;
}

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

@Override
 public boolean equals(Object obj) {
  if (this == obj) {
   return true;
  }
  if (obj == null) {
   return false;
  }
  if (getClass() != obj.getClass()) {
   return false;
  }
  ZkHost other = (ZkHost) obj;
  if (getAddress() == null) {
   if (other.getAddress() != null) {
    return false;
   }
  } else if (!getAddress().equals(other.getAddress())) {
   return false;
  }
  if (path == null) {
   if (other.path != null) {
    return false;
   }
  } else if (!path.equals(other.path)) {
   return false;
  }
  return true;
 }
}

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

@Override
public Host getHostByAddress(PartitionServerAddress address) {
 for (ZkHost host : hosts.values()) {
  if (host.getAddress().equals(address)) {
   return host;
  }
 }
 return null;
}

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

@Override
public boolean removeHost(PartitionServerAddress address) throws IOException {
 for (Map.Entry<String, ZkHost> entry : hosts.entrySet()) {
  if (entry.getValue().getAddress().equals(address)) {
   ZkHost host = hosts.remove(entry.getKey());
   host.delete();
   fireDataLocationChangeListener();
   return true;
  }
 }
 return false;
}

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

@Test
public void testCreateAndLoad() throws Exception {
 final ZkHost host = ZkHost.create(getZk(), coordinator, getRoot(), ADDRESS, null, Collections.emptyList());
 assertEquals(ADDRESS, host.getAddress());
 assertEquals(0, host.getCommandQueue().size());
 assertNull(host.getCurrentCommand());
 assertEquals(HostState.OFFLINE, host.getState());
 assertFalse(Hosts.isOnline(host));
 host.setEphemeralStatistic("a", "A");
 host.setEphemeralStatistic("b", "B");
 WaitUntil.orDie(() -> {
  try {
   return "A".equals(host.getStatistic("a"))
     && "B".equals(host.getStatistic("b"));
  } catch (IOException e) {
   throw new RuntimeException(e);
  }
 });
 assertEquals("A", host.getStatistic("a"));
 assertEquals("B", host.getStatistic("b"));
 assertNull(host.getStatistic("c"));
 host.setAddress(OTHER_ADDRESS);
 WaitUntil.orDie(() -> host.getAddress().equals(OTHER_ADDRESS));
 assertEquals(OTHER_ADDRESS, host.getAddress());
}