com.ngdata.sep.util.zookeeper.ZooKeeperImpl.()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 12:51:13 26 4

public static ZooKeeperItf connect(String connectString, int sessionTimeout) throws ZkConnectException {
  ZooKeeperImpl zooKeeper;
  try {
    zooKeeper = new ZooKeeperImpl(connectString, sessionTimeout);
  } catch (IOException e) {
    throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString + "'", e);
  }
  long waitUntil = System.currentTimeMillis() + sessionTimeout;
  boolean connected = (States.CONNECTED).equals(zooKeeper.getState());
  while (!connected && waitUntil > System.currentTimeMillis()) {
    try {
      Thread.sleep(100);
    } catch (InterruptedException e) {
      connected = (States.CONNECTED).equals(zooKeeper.getState());
      break;
    }
    connected = (States.CONNECTED).equals(zooKeeper.getState());
  }
  if (!connected) {
    System.out.println("Failed to connect to Zookeeper within timeout: Dumping stack: ");
    Thread.dumpStack();
    zooKeeper.close();
    throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString +
        "' within timeout " + sessionTimeout);
  }
  return zooKeeper;
}

public static ZooKeeperItf connect(String connectString, int sessionTimeout) throws ZkConnectException {
  ZooKeeperImpl zooKeeper;
  try {
    zooKeeper = new ZooKeeperImpl(connectString, sessionTimeout, new DefaultACLProvider());
  } catch (IOException e) {
    throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString + "'", e);
  }
  long waitUntil = System.currentTimeMillis() + sessionTimeout;
  boolean connected = (States.CONNECTED).equals(zooKeeper.getState());
  while (!connected && waitUntil > System.currentTimeMillis()) {
    try {
      Thread.sleep(100);
    } catch (InterruptedException e) {
      connected = (States.CONNECTED).equals(zooKeeper.getState());
      break;
    }
    connected = (States.CONNECTED).equals(zooKeeper.getState());
  }
  if (!connected) {
    System.out.println("Failed to connect to Zookeeper within timeout: Dumping stack: ");
    Thread.dumpStack();
    zooKeeper.close();
    throw new ZkConnectException("Failed to connect with Zookeeper @ '" + connectString +
        "' within timeout " + sessionTimeout);
  }
  return zooKeeper;
}

26 4 0

• Python:为什么 partition(sep) 比 split(sep, maxsplit=1) 快

  我发现一个有趣的事情，当在分隔符之后获取整个子字符串时，partition 比 split 更快。我已经在 Python 3.5 和 3.6 (Cpython) 中测试过 In [1]: s = 'v

• python - pandas 数据框 to_csv 适用于 sep ='\n' 但不适用于 sep ='\t'

  我尝试将我的大数据框打印到 csv 文件，但制表符分隔 sep='\t'不起作用。然后我用换行符进行测试 sep='\n' ，看起来工作正常，用换行符打破所有元素。这里可能有什么问题？ 代码很简单 d

• javascript - fullcalendar 周日期格式为 : 23 - 29 Sep 2012 instead of: Sep 23 - 29 2012

  使用 titleFormat 我有: $calendar.fullCalendar({ titleFormat: { month: 'MMMM yyyy',

• python - 为什么 os.path.join 不使用 os.path.sep 或 os.sep？

  正如我们所知，Windows 接受 "\" 和 "/" 作为分隔符。但是在python中，使用的是"\"。例如，调用 os.path.join("foo","bar")，将返回 'foo\\bar'。

• regex - 使用正则表达式从 "S9.98"中删除 S，但不从字符串 "Sep"中的 "S9.98 Sep"中删除 S

  从以下字符串“test S9.98 Sep”中，我想删除数字前面的 S。但不是来自使用 RegEx 的“test”或“Sep”。 我试过了 string result = Regex.Replace(

• r - Error R csv : Error in read. table(file = file, header = header, sep = sep, quote = quote, : 'file' 必须是字符串或连接

  我正在为 MiRLAB 包的 R 教程苦苦挣扎，尽管我不确定问题是否与包的功能有关。 我想使用函数 Pearson()，它只接受 .csv 文件。我已经完美地加载了一个文件，但是当我尝试使用 Pear

• java - 使用 CDL : possible to replace comma-sep. 通过 Java 将 JSon 转换为 CSV，由半列 sep。值(value)观？

  一切都在标题中:) 我正在使用 org.json.CDL 将 JSONArray 转换为 CSV 数据，但它会呈现一个以“,”作为分隔符的字符串。我想知道是否可以用';'代替？ 这是我正在做的一个简单

• org.lilyproject.sep.ZooKeeperItfAdapter类的使用及代码示例

  本文整理了Java中org.lilyproject.sep.ZooKeeperItfAdapter类的一些代码示例，展示了ZooKeeperItfAdapter类的具体用法。这些代码示例主要来源于Gi

• java - 如何告诉自由标记在列表迭代中跳过 指令？

  我试图在 Freemarker 中的 迭代中迭代 JSON 对象，并以不同的形式写出相同的 JSON。对于某些情况，我想跳过迭代并且不写出任何内容，但 Freemakrer 仍然写出逗号，因为我使用

• linux - awk sep 数据提取特定变量后的行

  我有一个大文件，有一些规则的模式 snaps1: Counter: 4966 Opens: Counter:

• html - 奇怪的符号出现在网站上 (L SEP)？

  我在我的网站上注意到，http://www.cscc.org.sg/ , 出现了这个奇怪的符号。 它说 L SEP。在 HTML 代码中，它显示相同的内容。 有人可以告诉我如何删除它们吗？ 最佳答案

• python - 我应该使用哪一个SEP或OS.PATH.SEP？

  他们是一样的，但是我应该使用哪一个？ http://docs.python.org/library/os.html : os.sep The character used by the operati

• javascript - Dust.js @sep 示例不起作用

  我尝试在第一页 hello world 中使用 Dust.js 模板引擎，但未能使用 {@sep} 标记，模板已编译并生成输出，但不是逗号 {@sep},{/sep} http://jsfiddle.

• r - tidyr 使用 sep 括号时出现单独错误

  我无法使用括号作为分隔符来分隔列: d = data.frame(a = c('af(dsf', 'sdf (asdf', 'sdf(df')) d %>% separate(a, c('a','b'

• R:无效的 'sep' 值:必须是一个字节

  我正在尝试读取使用 :: 作为列分隔符的文件: userID::MovieID::Rating::Timestamp 1::1193::5::978300760 1::661::3::97830210

• MYSQL:如何搜索保存值 sep 的字段。用逗号？

  标签 (id_tag,name) 新闻(id、标题、数据、标签) 字段 news>tags 是一个 varchar(255)。我打算将这样的数据放在该字段中:“1,7,34” 这意味着 news 中的

• python - 使用打印函数的 "*"参数打印由破折号分隔的 "sep"个字符

  我正在学习 Python，只是想弄清楚如何打印多个 "*" 字符，这些字符由破折号分隔，但星号和破折号的数量可以通过用户。 这是我目前所拥有的: print('*' * n, sep = '-' *

• python - 在 Python 中乘以字符串时使用 sep

  这个问题在这里已经有了答案: Create list of single item repeated N times (9 个回答) How to print a list using splat-

• python - Pandas read_csv 不遵守正则表达式 sep

  数据: from io import StringIO import pandas as pd s = '''ID,Level,QID,Text,ResponseID,responseText,dat

• php - 我应该为我的案例将 com-sep 数据存储在数据库中吗？

  我知道这通常是个坏主意，我已经阅读了 - 特别是 this question . 然而，总的规范化路线似乎更复杂，并且会给我和我的代码更多的障碍来跳过。这是我的场景: 我正在构建一个测试创建系统，用户