本文整理了Java中org.apache.hive.service.server.HiveServer2.stop()
方法的一些代码示例,展示了HiveServer2.stop()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HiveServer2.stop()
方法的具体详情如下:
包路径:org.apache.hive.service.server.HiveServer2
类名称:HiveServer2
方法名:stop
暂无
代码示例来源:origin: apache/hive
@Override
public void run() {
hiveServer2.stop();
}
};
代码示例来源:origin: apache/hive
private void stopHiveServer() {
if (server != null) {
// kill server
server.stop();
}
}
代码示例来源:origin: apache/hive
protected static void stopHiveServer2() throws Exception {
if (hiveServer2 != null) {
hiveServer2.stop();
}
}
代码示例来源:origin: apache/hive
protected static void stopHiveServer2() throws Exception {
if (hiveServer2 != null) {
hiveServer2.stop();
}
}
代码示例来源:origin: apache/hive
@Override
public void process(WatchedEvent event) {
super.process(event);
if (event.getType().equals(Watcher.Event.EventType.NodeDeleted)) {
// If there are no more active client sessions, stop the server
if (cliService.getSessionManager().getOpenSessionCount() == 0) {
LOG.warn("This instance of HiveServer2 has been removed from the list of server "
+ "instances available for dynamic service discovery. "
+ "The last client session has ended - will shutdown now.");
HiveServer2.this.stop();
}
}
}
}
代码示例来源:origin: apache/hive
@AfterClass
public static void afterTests() throws Exception {
hiveServer2.stop();
}
}
代码示例来源:origin: apache/hive
@AfterClass public static void afterTests() {
hiveServer2.stop();
}
}
代码示例来源:origin: apache/hive
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
ShutdownHookManager.addShutdownHook(() -> hiveServer2.stop());
代码示例来源:origin: org.apache.hive/hive-service
@Override
public void run() {
hiveServer2.stop();
}
};
代码示例来源:origin: com.hotels/beeju
@Override
protected void afterTest() {
if (hiveServer2 != null) {
hiveServer2.stop();
}
}
代码示例来源:origin: org.spark-project.hive/hive-service
@Override
public void run() {
hiveServer2.stop();
}
};
代码示例来源:origin: com.github.hyukjinkwon/hive-service
@Override
public void run() {
hiveServer2.stop();
}
};
代码示例来源:origin: org.springframework.data/spring-data-hadoop-hive
@Override
public void stop() {
if (isRunning()) {
server.stop();
}
}
代码示例来源:origin: com.github.sakserv/hadoop-mini-clusters-hiveserver2
@Override
public void stop(boolean cleanUp) throws Exception {
LOG.info("HIVESERVER2: Stopping HiveServer2 on port: {}", hiveServer2Port);
hiveServer2.stop();
if (cleanUp) {
cleanUp();
}
}
代码示例来源:origin: com.presidentio.but/hive2-unit
@Override
public void destroy() throws DestroyUnitException {
try {
statement.close();
connection.close();
} catch (SQLException e) {
throw new DestroyUnitException("Failed to close hive connection", e);
}
hiveServer.stop();
}
代码示例来源:origin: kawaa/Beetest
public void shutdownCluster() {
if (miniMR != null) {
miniMR.shutdown();
}
if (hdfsCluster != null) {
hdfsCluster.shutdown();
}
if (hiveServer2 != null) {
hiveServer2.stop();
}
}
}
代码示例来源:origin: apache/sqoop
public void stop() {
hiveServer2.stop();
HiveConf.setHiveSiteLocation(originalHiveSiteLocation);
try {
FileUtils.deleteDirectory(new File(tempFolderPath));
} catch (IOException e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: uber/hudi
public void stop() throws IOException {
resetSystemProperties();
if (tServer != null) {
tServer.stop();
}
if (hiveServer != null) {
hiveServer.stop();
}
LOG.info("Hive Minicluster service shut down.");
tServer = null;
hiveServer = null;
hadoopConf = null;
}
代码示例来源:origin: uber/hudi
@SuppressWarnings("unused")
public static void shutdown() {
if (hiveServer != null) {
hiveServer.stop();
}
if (dfsCluster != null) {
dfsCluster.shutdown();
}
if (zkServer != null) {
zkServer.shutdown();
}
}
内容来源于网络,如有侵权,请联系作者删除!