You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2010/11/03 22:21:48 UTC
svn commit: r1030694 -
/hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java
Author: stack
Date: Wed Nov 3 21:21:47 2010
New Revision: 1030694
URL: http://svn.apache.org/viewvc?rev=1030694&view=rev
Log:
HBASE-2828 HTable unnecessarily coupled with HMaster; missing piece
Modified:
hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java
Modified: hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java?rev=1030694&r1=1030693&r2=1030694&view=diff
==============================================================================
--- hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java (original)
+++ hbase/trunk/src/main/java/org/apache/hadoop/hbase/client/HTable.java Wed Nov 3 21:21:47 2010
@@ -54,6 +54,8 @@ import org.apache.hadoop.hbase.client.Me
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.Pair;
import org.apache.hadoop.hbase.util.Writables;
+import org.apache.hadoop.hbase.zookeeper.ZKUtil;
+import org.apache.zookeeper.KeeperException;
/**
* Used to communicate with a single HBase table.
@@ -201,8 +203,12 @@ public class HTable implements HTableInt
* @throws IOException if a remote or network exception occurs
*/
int getCurrentNrHRS() throws IOException {
- HBaseAdmin admin = new HBaseAdmin(this.configuration);
- return admin.getClusterStatus().getServers();
+ try {
+ return ZKUtil.getNumberOfChildren(this.connection.getZooKeeperWatcher(),
+ this.connection.getZooKeeperWatcher().rsZNode);
+ } catch (KeeperException ke) {
+ throw new IOException("Unexpected ZooKeeper exception", ke);
+ }
}
/**