You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ra...@apache.org on 2012/01/13 20:41:38 UTC
svn commit: r1231269 - in /hbase/branches/0.90: CHANGES.txt
src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
Author: ramkrishna
Date: Fri Jan 13 19:41:38 2012
New Revision: 1231269
URL: http://svn.apache.org/viewvc?rev=1231269&view=rev
Log:
HBASE-5160 Addendum adding the removed method in AssignmentManager (Ram)
Modified:
hbase/branches/0.90/CHANGES.txt
hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
Modified: hbase/branches/0.90/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/CHANGES.txt?rev=1231269&r1=1231268&r2=1231269&view=diff
==============================================================================
--- hbase/branches/0.90/CHANGES.txt (original)
+++ hbase/branches/0.90/CHANGES.txt Fri Jan 13 19:41:38 2012
@@ -23,6 +23,7 @@ Release 0.90.6 - Unreleased
initialization when doing rollback of split, it will affect read correctness (Ram)
HBASE-5160 Backport HBASE-4397 - -ROOT-, .META. tables stay offline for too long in
recovery phase after all RSs are shutdown at the same time (Ram)
+ HBASE-5160 Addendum adding the removed method in AssignmentManager (Ram)
IMPROVEMENT
HBASE-5102 Change the default value of the property "hbase.connection.per.config" to false in
Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java?rev=1231269&r1=1231268&r2=1231269&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java Fri Jan 13 19:41:38 2012
@@ -2126,6 +2126,23 @@ public class AssignmentManager extends Z
}
/**
+ * @param encodedRegionName Region encoded name.
+ * @return Null or a {@link Pair} instance that holds the full {@link HRegionInfo}
+ * and the hosting servers {@link HServerInfo}.
+ */
+ public Pair<HRegionInfo, HServerInfo> getAssignment(final byte [] encodedRegionName) {
+ String name = Bytes.toString(encodedRegionName);
+ synchronized(this.regions) {
+ for (Map.Entry<HRegionInfo, HServerInfo> e: this.regions.entrySet()) {
+ if (e.getKey().getEncodedName().equals(name)) {
+ return new Pair<HRegionInfo, HServerInfo>(e.getKey(), e.getValue());
+ }
+ }
+ }
+ return null;
+ }
+
+ /**
* @param plan Plan to execute.
*/
void balance(final RegionPlan plan) {