8990919293949596979899
public static void oneTimeTearDown() throws Exception { // In HBase 0.90.1 and above we can use util.shutdownMiniHBaseCluster() // here instead. MiniHBaseCluster hbc = util.getHBaseCluster(); if (hbc != null) { hbc.shutdown(); hbc.join(); } util.shutdownMiniZKCluster(); cluster.shutDown(); }
8889909192939495969798
public static void oneTimeTearDown() throws Exception { // In HBase 0.90.1 and above we can use util.shutdownMiniHBaseCluster() // here instead. MiniHBaseCluster hbc = util.getHBaseCluster(); if (hbc != null) { hbc.shutdown(); hbc.join(); } util.shutdownMiniZKCluster(); }
287288289290291292293294295296297
util.deleteTable(Bytes.toBytesBinary("test_table")); // In HBase 0.90.1 and above we can use util.shutdownMiniHBaseCluster() // here instead. MiniHBaseCluster hbc = util.getHBaseCluster(); if (hbc != null) { hbc.shutdown(); hbc.join(); } util.shutdownMiniZKCluster(); }
178179180181182183184185186187188
} finally { s.close(); } } finally { HConnectionManager.deleteConnectionInfo(conf, false); cluster.shutdown(); } } /* * Wait till the startcode changes before we put up a scanner. Otherwise
227228229230231232233234235236237
// continue } } assertTrue(verified); } finally { cluster.shutdown(); } } public static String toU8Str(byte[] bytes) throws UnsupportedEncodingException { return new String(bytes, HConstants.UTF8_ENCODING);
109110111112113114115116117118119
153154155156157158159160161162163
} finally { s.close(); } } finally { HConnectionManager.deleteConnectionInfo(conf, false); cluster.shutdown(); try { zooKeeperCluster.shutdown(); } catch (IOException e) { LOG.warn("Shutting down ZooKeeper cluster", e); }
603604605606607608609610611612613
105106107108109110111112113114115
// continue } } assertTrue(verified); } finally { cluster.shutdown(); } } }
256257258259260261262263264265266