org.apache.hive.service.server.HiveServer2类的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(9.0k)|赞(0)|评价(0)|浏览(421)

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

HiveServer2介绍

[英]HiveServer2.
[中]HiveServer2。

代码示例

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

private void startHiveServer() throws InterruptedException {
 // Start hive server2
 server = new HiveServer2();
 server.init(hiveConf);
 server.start();
 Thread.sleep(5000);
 System.out.println("## HiveServer started");
}

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

scheduleClearDanglingScratchDir(hiveConf, new Random().nextInt(600));
server = new HiveServer2();
server.init(hiveConf);
server.start();
if (server != null) {
 try {
  server.stop();
 } catch (Throwable t) {
  LOG.info("Exception caught when calling stop of HiveServer2 before retrying start", t);

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

@Override
 public void notLeader() {
  LOG.info("HS2 instance {} LOST LEADERSHIP. Stopping/Disconnecting tez sessions..", hiveServer2.serviceUri);
  hiveServer2.isLeader.set(false);
  hiveServer2.closeAndDisallowHiveSessions();
  hiveServer2.stopOrDisconnectTezSessions();
  LOG.info("Stopped/Disconnected tez sessions.");
  // resolve futures used for testing
  if (HiveConf.getBoolVar(hiveServer2.getHiveConf(), ConfVars.HIVE_IN_TEST)) {
   hiveServer2.notLeaderTestFuture.set(true);
   hiveServer2.resetIsLeaderTestFuture();
  }
 }
}

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

private void startOrReconnectTezSessions() {
 LOG.info("Starting/Reconnecting tez sessions..");
 // TODO: add tez session reconnect after TEZ-3875
 WMFullResourcePlan resourcePlan = null;
 if (!StringUtils.isEmpty(wmQueue)) {
  try {
   resourcePlan = sessionHive.getActiveResourcePlan();
  } catch (HiveException e) {
   if (!HiveConf.getBoolVar(getHiveConf(), ConfVars.HIVE_IN_TEST_SSL)) {
    throw new RuntimeException(e);
   } else {
    resourcePlan = null; // Ignore errors in SSL tests where the connection is misconfigured.
   }
  }
  if (resourcePlan == null && HiveConf.getBoolVar(
    getHiveConf(), ConfVars.HIVE_IN_TEST)) {
   LOG.info("Creating a default resource plan for test");
   resourcePlan = createTestResourcePlan();
  }
 }
 initAndStartTezSessionPoolManager(resourcePlan);
 initAndStartWorkloadManager(resourcePlan);
}

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

conf.get(HiveConf.ConfVars.HIVE_SERVER2_TRANSPORT_MODE.varname));
if (HiveServer2.isHTTPTransportMode(conf)) {
 confsToPublish.put(HiveConf.ConfVars.HIVE_SERVER2_THRIFT_HTTP_PORT.varname,
  conf.get(HiveConf.ConfVars.HIVE_SERVER2_THRIFT_HTTP_PORT.varname));
if (HiveServer2.isKerberosAuthMode(conf)) {
 confsToPublish.put(HiveConf.ConfVars.HIVE_SERVER2_KERBEROS_PRINCIPAL.varname,
  conf.get(HiveConf.ConfVars.HIVE_SERVER2_KERBEROS_PRINCIPAL.varname));

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

@Override
 public void run() {
  hiveServer2.stop();
 }
};

代码示例来源：origin: linkedin/transport

private void createHiveServer() {
 HiveServer2 server = new HiveServer2();
 server.init(new HiveConf());
 for (Service service : server.getServices()) {
  if (service instanceof CLIService) {
   _client = (CLIService) service;
  }
 }
 Preconditions.checkNotNull(_client, "CLI service not found in local Hive server");
 try {
  _sessionHandle = _client.openSession(null, null, null);
  _functionRegistry = SessionState.getRegistryForWrite();
  // "map_from_entries" UDF is required to create maps with non-primitive key types
  _functionRegistry.registerGenericUDF("map_from_entries", MapFromEntriesWrapper.class);
  // TODO: This is a hack. Hive's public API does not have a way to register an already created GenericUDF object
  // It only accepts a class name after which the parameterless constructor of the class is called to create a
  // GenericUDF object. This does not work for HiveTestStdUDFWrapper as it accepts the UDF classes as parameters.
  // However, Hive has an internal method which does allow passing GenericUDF objects instead of classes.
  _functionRegistryAddFunctionMethod =
    _functionRegistry.getClass().getDeclaredMethod("addFunction", String.class, FunctionInfo.class);
  _functionRegistryAddFunctionMethod.setAccessible(true);
 } catch (HiveSQLException | NoSuchMethodException e) {
  throw new RuntimeException(e);
 }
}

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

@Test
public void testSslIsFalse() {
 thrown.expect(IllegalArgumentException.class);
 thrown.expectMessage(is(ConfVars.HIVE_SERVER2_WEBUI_USE_SSL.varname
   + " has false value. It is recommended to set to true when PAM is used."));
 hiveConf.setVar(ConfVars.HIVE_SERVER2_PAM_SERVICES, "sshd");
 hiveConf.setBoolVar(ConfVars.HIVE_SERVER2_WEBUI_USE_SSL, false);
 hiveServer2 = new HiveServer2();
 hiveServer2.init(hiveConf);
}

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

static void startHiveServer2WithConf(HiveConf hiveConf) throws Exception {
 hiveServer2.init(hiveConf);
 // Start HiveServer2 with given config
 // Fail if server doesn't start
 try {
  hiveServer2.start();
 } catch (Throwable t) {
  t.printStackTrace();
  fail();
 }
 // Wait for startup to complete
 Thread.sleep(2000);
 System.out.println("HiveServer2 started on port " + port);
}

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

addService(cliService);
final HiveServer2 hiveServer2 = this;
Runnable oomHook = new Runnable() {
if (isHTTPTransportMode(hiveConf)) {
 thriftCLIService = new ThriftHttpCLIService(cliService, oomHook);
} else {
 thriftCLIService = new ThriftBinaryCLIService(cliService, oomHook);
addService(thriftCLIService);
super.init(hiveConf);
 hiveConf.set(HiveConf.ConfVars.HIVE_SERVER2_THRIFT_BIND_HOST.varname, getServerHost());
} catch (Throwable t) {
 throw new Error("Unable to initialize HiveServer2", t);
  serviceUri = getServerInstanceURI();
  addConfsToPublish(hiveConf, confsToPublish, serviceUri);
  if (activePassiveHA) {
   hiveConf.set(INSTANCE_URI_CONFIG, serviceUri);
 maybeStartCompactorThreads(hiveConf);
} catch (Exception e) {
 throw new RuntimeException(e);
ShutdownHookManager.addShutdownHook(() -> hiveServer2.stop());

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

/**
 * @throws java.lang.Exception
 */
@BeforeClass
public static void setUpBeforeClass() throws Exception {
 // Find a free port
 port = MetaStoreTestUtils.findFreePort();
 hiveServer2 = new HiveServer2();
 hiveConf = new HiveConf();
}

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

@Override
public synchronized void init(HiveConf hiveConf) {
 cliService = new CLIService(this);
 addService(cliService);
 if (isHTTPTransportMode(hiveConf)) {
  thriftCLIService = new ThriftHttpCLIService(cliService);
 } else {
  thriftCLIService = new ThriftBinaryCLIService(cliService);
 }
 addService(thriftCLIService);
 super.init(hiveConf);
 // Add a shutdown hook for catching SIGTERM & SIGINT
 final HiveServer2 hiveServer2 = this;
 Runtime.getRuntime().addShutdownHook(new Thread() {
  @Override
  public void run() {
   hiveServer2.stop();
  }
 });
}

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

HiveConf hiveConf = getHiveConf();
if (!serviceDiscovery || !activePassiveHA) {
 allowClientSessions();
   boolean publishConfigs =
       hiveConf.getBoolVar(HiveConf.ConfVars.HIVE_SERVER2_ZOOKEEPER_PUBLISH_CONFIGS);
   String instanceURI = getServerInstanceURI();
   String znodeData;
   if (publishConfigs) {
    addConfsToPublish(hiveConf, confsToPublish, getServerInstanceURI());
    znodeData = Joiner.on(';').withKeyValueSeparator("=").join(confsToPublish);
   } else {
 startPrivilegeSynchronizer(hiveConf);
} catch (Exception e) {
 LOG.error("Error starting priviledge synchronizer: ", e);
  LOG.info("HS2 interactive HA not enabled. Starting tez sessions..");
  try {
   startOrReconnectTezSessions();
  } catch (Exception e) {
   LOG.error("Error starting  Tez sessions: ", e);

代码示例来源：origin: org.springframework.data/spring-data-hadoop-hive

@Override
public void start() {
  if (!isRunning()) {
    server.start();
  }
}

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

@Override
public synchronized void stop() {
 LOG.info("Shutting down HiveServer2");
 HiveConf hiveConf = this.getHiveConf();
 super.stop();
   removeServerInstanceFromZooKeeper();
  } catch (Exception e) {
   LOG.error("Error removing znode for this HiveServer2 instance from ZooKeeper.", e);

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

if (HiveServer2.isHTTPTransportMode(hiveConf)) {
 workerKeepAliveTime =
   hiveConf.getTimeVar(ConfVars.HIVE_SERVER2_THRIFT_HTTP_WORKER_KEEPALIVE_TIME,

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

@Override
public synchronized void stop() {
 LOG.info("Shutting down HiveServer2");
 HiveConf hiveConf = this.getHiveConf();
 super.stop();
 if (hs2HARegistry != null) {
  hs2HARegistry.stop();
  shutdownExecutor(leaderActionsExecutorService);
  LOG.info("HS2 HA registry stopped");
  hs2HARegistry = null;
 stopOrDisconnectTezSessions();

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

@Override
public synchronized void stop() {
 LOG.info("Shutting down HiveServer2");
 HiveConf hiveConf = this.getHiveConf();
 super.stop();
 if (hs2HARegistry != null) {
  hs2HARegistry.stop();
  shutdownExecutor(leaderActionsExecutorService);
  LOG.info("HS2 HA registry stopped");
  hs2HARegistry = null;
   removeServerInstanceFromZooKeeper();
  } catch (Exception e) {
   LOG.error("Error removing znode for this HiveServer2 instance from ZooKeeper.", e);
 stopOrDisconnectTezSessions();

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

HiveConf hiveConf = getHiveConf();
if (serviceDiscovery) {
 try {
   LOG.info("HS2 HA registry started");
  } else {
   addServerInstanceToZooKeeper(hiveConf, confsToPublish);
 startPrivilegeSynchonizer(hiveConf);
} catch (Exception e) {
 LOG.error("Error starting priviledge synchonizer: ", e);
 LOG.info("HS2 interactive HA not enabled. Starting tez sessions..");
 try {
  startOrReconnectTezSessions();
 } catch (Exception e) {
  LOG.error("Error starting  Tez sessions: ", e);

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

protected static void stopHiveServer2() throws Exception {
 if (hiveServer2 != null) {
  hiveServer2.stop();
 }
}

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

HiveServer2

相关文章

    查看更多

    热门标签

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

    最新文章

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