本文整理了Java中org.apache.samza.zk.ZkUtils.subscribeChildChanges()
方法的一些代码示例,展示了ZkUtils.subscribeChildChanges()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZkUtils.subscribeChildChanges()
方法的具体详情如下:
包路径:org.apache.samza.zk.ZkUtils
类名称:ZkUtils
方法名:subscribeChildChanges
暂无
代码示例来源:origin: apache/samza
/**
* Creates a shared barrier sub-tree in ZK
*
* @param version Version associated with the Barrier
* @param participants List of expected participated for this barrier to complete
*/
public void create(final String version, List<String> participants) {
LOG.info(String.format("Creating barrier with version: %s, participants: %s.", version, participants));
String barrierRoot = keyBuilder.getBarrierRoot();
String barrierParticipantsPath = keyBuilder.getBarrierParticipantsPath(version);
String barrierStatePath = keyBuilder.getBarrierStatePath(version);
zkUtils.validatePaths(new String[]{
barrierRoot,
keyBuilder.getBarrierPath(version),
barrierParticipantsPath,
barrierStatePath});
LOG.info("Marking the barrier state: {} as {}.", barrierStatePath, State.NEW);
zkUtils.writeData(barrierStatePath, State.NEW);
LOG.info("Subscribing child changes on the path: {} for barrier version: {}.", barrierParticipantsPath, version);
zkUtils.subscribeChildChanges(barrierParticipantsPath, new ZkBarrierChangeHandler(version, participants, zkUtils));
barrierListenerOptional.ifPresent(zkBarrierListener -> zkBarrierListener.onBarrierCreated(version));
}
代码示例来源:origin: org.apache.samza/samza-core_2.12
/**
* Creates a shared barrier sub-tree in ZK
*
* @param version Version associated with the Barrier
* @param participants List of expected participated for this barrier to complete
*/
public void create(final String version, List<String> participants) {
LOG.info(String.format("Creating barrier with version: %s, participants: %s.", version, participants));
String barrierRoot = keyBuilder.getBarrierRoot();
String barrierParticipantsPath = keyBuilder.getBarrierParticipantsPath(version);
String barrierStatePath = keyBuilder.getBarrierStatePath(version);
zkUtils.validatePaths(new String[]{
barrierRoot,
keyBuilder.getBarrierPath(version),
barrierParticipantsPath,
barrierStatePath});
LOG.info("Marking the barrier state: {} as {}.", barrierStatePath, State.NEW);
zkUtils.writeData(barrierStatePath, State.NEW);
LOG.info("Subscribing child changes on the path: {} for barrier version: {}.", barrierParticipantsPath, version);
zkUtils.subscribeChildChanges(barrierParticipantsPath, new ZkBarrierChangeHandler(version, participants, zkUtils));
barrierListenerOptional.ifPresent(zkBarrierListener -> zkBarrierListener.onBarrierCreated(version));
}
代码示例来源:origin: org.apache.samza/samza-core_2.10
/**
* Creates a shared barrier sub-tree in ZK
*
* @param version Version associated with the Barrier
* @param participants List of expected participated for this barrier to complete
*/
public void create(final String version, List<String> participants) {
LOG.info(String.format("Creating barrier with version: %s, participants: %s.", version, participants));
String barrierRoot = keyBuilder.getBarrierRoot();
String barrierParticipantsPath = keyBuilder.getBarrierParticipantsPath(version);
String barrierStatePath = keyBuilder.getBarrierStatePath(version);
zkUtils.validatePaths(new String[]{
barrierRoot,
keyBuilder.getBarrierPath(version),
barrierParticipantsPath,
barrierStatePath});
LOG.info("Marking the barrier state: {} as {}.", barrierStatePath, State.NEW);
zkUtils.writeData(barrierStatePath, State.NEW);
LOG.info("Subscribing child changes on the path: {} for barrier version: {}.", barrierParticipantsPath, version);
zkUtils.subscribeChildChanges(barrierParticipantsPath, new ZkBarrierChangeHandler(version, participants, zkUtils));
barrierListenerOptional.ifPresent(zkBarrierListener -> zkBarrierListener.onBarrierCreated(version));
}
代码示例来源:origin: org.apache.samza/samza-core
/**
* Creates a shared barrier sub-tree in ZK
*
* @param version Version associated with the Barrier
* @param participants List of expected participated for this barrier to complete
*/
public void create(final String version, List<String> participants) {
LOG.info(String.format("Creating barrier with version: %s, participants: %s.", version, participants));
String barrierRoot = keyBuilder.getBarrierRoot();
String barrierParticipantsPath = keyBuilder.getBarrierParticipantsPath(version);
String barrierStatePath = keyBuilder.getBarrierStatePath(version);
zkUtils.validatePaths(new String[]{
barrierRoot,
keyBuilder.getBarrierPath(version),
barrierParticipantsPath,
barrierStatePath});
LOG.info("Marking the barrier state: {} as {}.", barrierStatePath, State.NEW);
zkUtils.writeData(barrierStatePath, State.NEW);
LOG.info("Subscribing child changes on the path: {} for barrier version: {}.", barrierParticipantsPath, version);
zkUtils.subscribeChildChanges(barrierParticipantsPath, new ZkBarrierChangeHandler(version, participants, zkUtils));
barrierListenerOptional.ifPresent(zkBarrierListener -> zkBarrierListener.onBarrierCreated(version));
}
代码示例来源:origin: org.apache.samza/samza-core_2.11
/**
* Creates a shared barrier sub-tree in ZK
*
* @param version Version associated with the Barrier
* @param participants List of expected participated for this barrier to complete
*/
public void create(final String version, List<String> participants) {
LOG.info(String.format("Creating barrier with version: %s, participants: %s.", version, participants));
String barrierRoot = keyBuilder.getBarrierRoot();
String barrierParticipantsPath = keyBuilder.getBarrierParticipantsPath(version);
String barrierStatePath = keyBuilder.getBarrierStatePath(version);
zkUtils.validatePaths(new String[]{
barrierRoot,
keyBuilder.getBarrierPath(version),
barrierParticipantsPath,
barrierStatePath});
LOG.info("Marking the barrier state: {} as {}.", barrierStatePath, State.NEW);
zkUtils.writeData(barrierStatePath, State.NEW);
LOG.info("Subscribing child changes on the path: {} for barrier version: {}.", barrierParticipantsPath, version);
zkUtils.subscribeChildChanges(barrierParticipantsPath, new ZkBarrierChangeHandler(version, participants, zkUtils));
barrierListenerOptional.ifPresent(zkBarrierListener -> zkBarrierListener.onBarrierCreated(version));
}
内容来源于网络,如有侵权,请联系作者删除!