作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中com.moz.fiji.schema.zookeeper.ZooKeeperUtils.newTableUsersTracker()
方法的一些代码示例,展示了ZooKeeperUtils.newTableUsersTracker()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperUtils.newTableUsersTracker()
方法的具体详情如下:
包路径:com.moz.fiji.schema.zookeeper.ZooKeeperUtils
类名称: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 {
本文整理了Java中com.moz.fiji.schema.zookeeper.ZooKeeperUtils.newTableUsersTracker()方法的一些代码示例,展示了ZooKeeperU
我是一名优秀的程序员,十分优秀!