org.apache.hive.jdbc.ZooKeeperHiveClientException.<init>()方法的使用及代码示例

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

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

ZooKeeperHiveClientException.<init>介绍

暂无

代码示例

代码示例来源：origin: apache/hive

private static List<String> getServerHosts(JdbcConnectionParams connParams, CuratorFramework
  zooKeeperClient) throws Exception {
 List<String> serverHosts = zooKeeperClient.getChildren().forPath("/" + getZooKeeperNamespace(connParams));
 // Remove the znodes we've already tried from this list
 serverHosts.removeAll(connParams.getRejectedHostZnodePaths());
 if (serverHosts.isEmpty()) {
  throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 }
 return serverHosts;
}

代码示例来源：origin: apache/hive

private static void updateParamsWithZKServerNode(JdbcConnectionParams connParams,
  CuratorFramework zooKeeperClient, String serverNode) throws Exception {
 String zooKeeperNamespace = getZooKeeperNamespace(connParams);
 connParams.setCurrentHostZnodePath(serverNode);
 // Read data from the znode for this server node
 // This data could be either config string (new releases) or server end
 // point (old releases)
 String dataStr =
   new String(
     zooKeeperClient.getData().forPath("/" + zooKeeperNamespace + "/" + serverNode),
     Charset.forName("UTF-8"));
 // If dataStr is not null and dataStr is not a KV pattern,
 // it must be the server uri added by an older version HS2
 Matcher matcher = kvPattern.matcher(dataStr);
 if ((dataStr != null) && (!matcher.find())) {
  String[] split = dataStr.split(":");
  if (split.length != 2) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper: "
     + dataStr);
  }
  connParams.setHost(split[0]);
  connParams.setPort(Integer.parseInt(split[1]));
 } else {
  applyConfs(dataStr, connParams);
 }
}

代码示例来源：origin: apache/hive

static List<JdbcConnectionParams> getDirectParamsList(JdbcConnectionParams connParams)
  throws ZooKeeperHiveClientException {
 CuratorFramework zooKeeperClient = null;
 try {
  zooKeeperClient = getZkClient(connParams);
  List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
  final List<JdbcConnectionParams> directParamsList = new ArrayList<>();
  // For each node
  for (String serverNode : serverHosts) {
   JdbcConnectionParams directConnParams = new JdbcConnectionParams(connParams);
   directParamsList.add(directConnParams);
   updateParamsWithZKServerNode(directConnParams, zooKeeperClient, serverNode);
  }
  return directParamsList;
 } catch (Exception e) {
  throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
 } finally {
  // Close the client connection with ZooKeeper
  if (zooKeeperClient != null) {
   zooKeeperClient.close();
  }
 }
}

代码示例来源：origin: apache/hive

static void configureConnParams(JdbcConnectionParams connParams) throws ZooKeeperHiveClientException {
 if (isZkHADynamicDiscoveryMode(connParams.getSessionVars())) {
  configureConnParamsHA(connParams);
 } else {
  CuratorFramework zooKeeperClient = null;
  try {
   zooKeeperClient = getZkClient(connParams);
   List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
   // Now pick a server node randomly
   String serverNode = serverHosts.get(new Random().nextInt(serverHosts.size()));
   updateParamsWithZKServerNode(connParams, zooKeeperClient, serverNode);
  } catch (Exception e) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
  } finally {
   // Close the client connection with ZooKeeper
   if (zooKeeperClient != null) {
    zooKeeperClient.close();
   }
  }
 }
}

代码示例来源：origin: apache/hive

throw new ZooKeeperHiveClientException("Unable to connect to HiveServer2 Active host (No leader found!) after" +
  " " + maxRetries + " retries.");
throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);

代码示例来源：origin: org.apache.hive/hive-jdbc

private static List<String> getServerHosts(JdbcConnectionParams connParams, CuratorFramework
  zooKeeperClient) throws Exception {
 List<String> serverHosts = zooKeeperClient.getChildren().forPath("/" + getZooKeeperNamespace(connParams));
 // Remove the znodes we've already tried from this list
 serverHosts.removeAll(connParams.getRejectedHostZnodePaths());
 if (serverHosts.isEmpty()) {
  throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 }
 return serverHosts;
}

代码示例来源：origin: com.github.hyukjinkwon/hive-jdbc

throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 return serverUri;
} catch (Exception e) {
 throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper", e);
} finally {

代码示例来源：origin: org.spark-project.hive/hive-jdbc

throw new ZooKeeperHiveClientException(
    "Tried all existing HiveServer2 uris from ZooKeeper.");
 return serverUri;
} catch (Exception e) {
 throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper", e);
} finally {

代码示例来源：origin: org.apache.hive/hive-jdbc

private static void updateParamsWithZKServerNode(JdbcConnectionParams connParams,
  CuratorFramework zooKeeperClient, String serverNode) throws Exception {
 String zooKeeperNamespace = getZooKeeperNamespace(connParams);
 connParams.setCurrentHostZnodePath(serverNode);
 // Read data from the znode for this server node
 // This data could be either config string (new releases) or server end
 // point (old releases)
 String dataStr =
   new String(
     zooKeeperClient.getData().forPath("/" + zooKeeperNamespace + "/" + serverNode),
     Charset.forName("UTF-8"));
 // If dataStr is not null and dataStr is not a KV pattern,
 // it must be the server uri added by an older version HS2
 Matcher matcher = kvPattern.matcher(dataStr);
 if ((dataStr != null) && (!matcher.find())) {
  String[] split = dataStr.split(":");
  if (split.length != 2) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 uri from ZooKeeper: "
     + dataStr);
  }
  connParams.setHost(split[0]);
  connParams.setPort(Integer.parseInt(split[1]));
 } else {
  applyConfs(dataStr, connParams);
 }
}

代码示例来源：origin: org.apache.hive/hive-jdbc

static List<JdbcConnectionParams> getDirectParamsList(JdbcConnectionParams connParams)
  throws ZooKeeperHiveClientException {
 CuratorFramework zooKeeperClient = null;
 try {
  zooKeeperClient = getZkClient(connParams);
  List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
  final List<JdbcConnectionParams> directParamsList = new ArrayList<>();
  // For each node
  for (String serverNode : serverHosts) {
   JdbcConnectionParams directConnParams = new JdbcConnectionParams(connParams);
   directParamsList.add(directConnParams);
   updateParamsWithZKServerNode(directConnParams, zooKeeperClient, serverNode);
  }
  return directParamsList;
 } catch (Exception e) {
  throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
 } finally {
  // Close the client connection with ZooKeeper
  if (zooKeeperClient != null) {
   zooKeeperClient.close();
  }
 }
}

代码示例来源：origin: org.apache.hive/hive-jdbc

static void configureConnParams(JdbcConnectionParams connParams) throws ZooKeeperHiveClientException {
 if (isZkHADynamicDiscoveryMode(connParams.getSessionVars())) {
  configureConnParamsHA(connParams);
 } else {
  CuratorFramework zooKeeperClient = null;
  try {
   zooKeeperClient = getZkClient(connParams);
   List<String> serverHosts = getServerHosts(connParams, zooKeeperClient);
   // Now pick a server node randomly
   String serverNode = serverHosts.get(new Random().nextInt(serverHosts.size()));
   updateParamsWithZKServerNode(connParams, zooKeeperClient, serverNode);
  } catch (Exception e) {
   throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);
  } finally {
   // Close the client connection with ZooKeeper
   if (zooKeeperClient != null) {
    zooKeeperClient.close();
   }
  }
 }
}

代码示例来源：origin: org.apache.hive/hive-jdbc

throw new ZooKeeperHiveClientException("Unable to connect to HiveServer2 Active host (No leader found!) after" +
  " " + maxRetries + " retries.");
throw new ZooKeeperHiveClientException("Unable to read HiveServer2 configs from ZooKeeper", e);

代码示例来源：origin: com.github.hyukjinkwon/hive-jdbc

throw new ZooKeeperHiveClientException(e);

代码示例来源：origin: org.spark-project.hive/hive-jdbc

throw new ZooKeeperHiveClientException(e);

内容来源于网络，如有侵权，请联系作者删除！

ZooKeeperHiveClientException

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com