org.apache.hive.service.server.HiveServer2.stop()方法的使用及代码示例

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

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

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();
 }
}

相关文章