org.apache.hadoop.hbase.zookeeper.ZKClusterId.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(2.2k)|赞(0)|评价(0)|浏览(95)

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

ZKClusterId.<init>介绍

暂无

代码示例

代码示例来源:origin: apache/hbase

/**
 * Create a new secret manager instance for generating keys.
 * @param conf Configuration to use
 * @param zk Connection to zookeeper for handling leader elections
 * @param keyUpdateInterval Time (in milliseconds) between rolling a new master key for token signing
 * @param tokenMaxLifetime Maximum age (in milliseconds) before a token expires and is no longer valid
 */
/* TODO: Restrict access to this constructor to make rogues instances more difficult.
 * For the moment this class is instantiated from
 * org.apache.hadoop.hbase.ipc.SecureServer so public access is needed.
 */
public AuthenticationTokenSecretManager(Configuration conf,
                    ZKWatcher zk, String serverName,
                    long keyUpdateInterval, long tokenMaxLifetime) {
 this.zkWatcher = new ZKSecretWatcher(conf, zk, this);
 this.keyUpdateInterval = keyUpdateInterval;
 this.tokenMaxLifetime = tokenMaxLifetime;
 this.leaderElector = new LeaderElector(zk, serverName);
 this.name = NAME_PREFIX+serverName;
 this.clusterId = new ZKClusterId(zk, zk);
}

代码示例来源:origin: harbby/presto-connectors

/**
 * Create a new secret manager instance for generating keys.
 * @param conf Configuration to use
 * @param zk Connection to zookeeper for handling leader elections
 * @param keyUpdateInterval Time (in milliseconds) between rolling a new master key for token signing
 * @param tokenMaxLifetime Maximum age (in milliseconds) before a token expires and is no longer valid
 */
/* TODO: Restrict access to this constructor to make rogues instances more difficult.
 * For the moment this class is instantiated from
 * org.apache.hadoop.hbase.ipc.SecureServer so public access is needed.
 */
public AuthenticationTokenSecretManager(Configuration conf,
  ZooKeeperWatcher zk, String serverName,
  long keyUpdateInterval, long tokenMaxLifetime) {
 this.zkWatcher = new ZKSecretWatcher(conf, zk, this);
 this.keyUpdateInterval = keyUpdateInterval;
 this.tokenMaxLifetime = tokenMaxLifetime;
 this.leaderElector = new LeaderElector(zk, serverName);
 this.name = NAME_PREFIX+serverName;
 this.clusterId = new ZKClusterId(zk, zk);
}

相关文章