本文整理了Java中com.liveramp.hank.coordinator.zk.ZkPartitionProperties
类的一些代码示例,展示了ZkPartitionProperties
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkPartitionProperties
类的具体详情如下:
包路径:com.liveramp.hank.coordinator.zk.ZkPartitionProperties
类名称:ZkPartitionProperties
暂无
代码示例来源:origin: LiveRamp/hank
@Test
public void testCreate() throws Exception {
ZkPartitionProperties pi = ZkPartitionProperties.create(getZk(), getRoot(), 1, 15000, 550);
assertEquals(1, pi.getPartitionNumber());
assertEquals(15000, pi.getNumBytes());
assertEquals(550, pi.getNumRecords());
// should not throw an exception
pi = ZkPartitionProperties.create(getZk(), getRoot(), 1, 15000, 550);
assertEquals(1, pi.getPartitionNumber());
assertEquals(15000, pi.getNumBytes());
assertEquals(550, pi.getNumRecords());
}
代码示例来源:origin: LiveRamp/hank
public static ZkPartitionProperties create(ZooKeeperPlus zk, String partsRoot, int partNum, long numBytes, long numRecords) throws KeeperException, InterruptedException {
String partPath = ZkPath.append(partsRoot, nodeName(partNum));
// if the node already exists, then don't try to create a new one
if (zk.exists(partPath, false) == null) {
zk.create(partPath, null);
zk.createLong(ZkPath.append(partPath, "num_bytes"), numBytes);
zk.createLong(ZkPath.append(partPath, "num_records"), numRecords);
zk.create(ZkPath.append(partPath, DotComplete.NODE_NAME), null);
}
return new ZkPartitionProperties(zk, partPath);
}
代码示例来源:origin: LiveRamp/hank
@Test
public void testLoad() throws Exception {
ZkPartitionProperties.create(getZk(), getRoot(), 1, 15000, 550);
ZkPartitionProperties pi = new ZkPartitionProperties(getZk(), ZkPath.append(getRoot(), "part-1"));
assertEquals(1, pi.getPartitionNumber());
assertEquals(15000, pi.getNumBytes());
assertEquals(550, pi.getNumRecords());
}
}
内容来源于网络,如有侵权,请联系作者删除!