gpt4 book ai didi

com.moz.fiji.schema.zookeeper.ZooKeeperUtils.newTableUsersTracker()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-18 23:15:31 25 4
gpt4 key购买 nike

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

ZooKeeperUtils.newTableUsersTracker介绍

[英]Gets a users tracker for a table.
[中]获取表的用户跟踪器。

代码示例

代码示例来源:origin: com.moz.fiji.schema/fiji-schema

/**
 * Attempt to delete a table from this System_2_0 Fiji instance.
 *
 * @param tableName to delete
 * @throws IOException on unrecoverable error.
 */
private void deleteTableSystem_2_0(String tableName) throws IOException {
 final FijiURI tableURI = FijiURI.newBuilder(mURI).withTableName(tableName).build();
 final String tableZKPath = ZooKeeperUtils.getTableDir(tableURI).getPath();
 final UsersTracker usersTracker = ZooKeeperUtils.newTableUsersTracker(mZKClient, tableURI);
 try {
  usersTracker.start();
  final Set<String> users = usersTracker.getUsers().keySet();
  if (!users.isEmpty()) {
   LOG.warn(
     "Uninstalling Fiji table '{}' with registered users."
       + " Current registered users: {}. Stale table metadata will remain in"
       + " ZooKeeper at path {}.", tableName, users, tableZKPath);
  }
 } finally {
  usersTracker.close();
 }
 // The delete of tables from HBase is the same as System_1_0
 deleteTableSystem_1_0(tableName);
 // Delete ZNodes from ZooKeeper if table delete was successful
 ZooKeeperUtils.atomicRecursiveDelete(mZKClient, tableZKPath);
}
// CSON

代码示例来源:origin: com.moz.fiji.schema/fiji-schema

final UsersTracker usersTracker =
  ZooKeeperUtils
    .newTableUsersTracker(mZKClient, mTableURI)
    .registerUpdateHandler(mUsersUpdateHandler);
try {

代码示例来源:origin: com.moz.fiji.schema/fiji-schema-cassandra

new TableLayoutTracker(mZKClient, mTableURI, mLayoutUpdateHandler).start();
try {
 final UsersTracker usersTracker = ZooKeeperUtils.newTableUsersTracker(mZKClient, mTableURI);
 usersTracker.registerUpdateHandler(mUsersUpdateHandler);
 try {

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com