Package org.apache.hadoop.hbase

Examples of org.apache.hadoop.hbase.MiniHBaseCluster.shutdown()

143
144
145
146
147
148
149
150
151
152
153
      } finally {
        s.close();
      }
    } finally {
      HConnectionManager.deleteConnectionInfo(conf, false);
      cluster.shutdown();
    }
  }

  /*
   * Wait till the startcode changes before we put up a scanner.  Otherwise
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
      } finally {
        s.close();
      }
    } finally {
      HConnectionManager.deleteConnectionInfo();
      cluster.shutdown();
    }
  }

  /*
   * Wait till the startcode changes before we put up a scanner.  Otherwise
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
    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();
    }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
  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();
    }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
        break;
      }
    }
    HRegionServer regionServer = cluster.getRegionServer(count);

    cluster.shutdown();
    ZooKeeperWatcher zkw =
      HBaseTestingUtility.createAndForceNodeToOpenedState(TEST_UTIL,
        metaRegion, regionServer.getServerName());

    TEST_UTIL.startMiniHBaseCluster(1, 1);
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
    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();
    }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
        break;
      }
    }
    HRegionServer regionServer = cluster.getRegionServer(count);

    cluster.shutdown();
    ZooKeeperWatcher zkw =
      HBaseTestingUtility.createAndForceNodeToOpenedState(TEST_UTIL,
        metaRegion, regionServer.getServerName());

    TEST_UTIL.startMiniHBaseCluster(1, 1);
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
      assertNotNull(parentBytes);
      assertTrue(parentBytes.length > 0);
      Assert.assertEquals("0001", Bytes.toString(parentBytes));
    }   finally {
      if (cluster != null) {
        cluster.shutdown();
      }
      if (zkCluster != null) {
        zkCluster.shutdown();
      }
      // clean test files
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
        break;
      }
    }
    HRegionServer regionServer = cluster.getRegionServer(count);

    cluster.shutdown();
    // Create a ZKW to use in the test
    ZooKeeperWatcher zkw =
      HBaseTestingUtility.createAndForceNodeToOpenedState(TEST_UTIL,
          metaRegion, regionServer.getServerName());
View Full Code Here
610
611
612
613
614
615
616
617
618
619
620
        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();
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.