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 2014/02/14 03:21:59 UTC
svn commit: r1568189 - in
/hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master:
AssignmentManager.java LoadBalancer.java balancer/BaseLoadBalancer.java
Author: rajeshbabu
Date: Fri Feb 14 02:21:59 2014
New Revision: 1568189
URL: http://svn.apache.org/r1568189
Log:
HBASE-10498 Add new APIs to load balancer interface(Rajesh)
Modified:
hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/LoadBalancer.java
hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java
Modified: hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java?rev=1568189&r1=1568188&r2=1568189&view=diff
==============================================================================
--- hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java (original)
+++ hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java Fri Feb 14 02:21:59 2014
@@ -1274,6 +1274,7 @@ public class AssignmentManager extends Z
clearRegionPlan(regionInfo);
// Add the server to serversInUpdatingTimer
addToServersInUpdatingTimer(sn);
+ balancer.regionOnline(regionInfo, sn);
}
/**
@@ -2662,6 +2663,7 @@ public class AssignmentManager extends Z
if (!disabledOrEnablingTables.contains(tableName)) {
regionStates.updateRegionState(regionInfo, State.OPEN, regionLocation);
regionStates.regionOnline(regionInfo, regionLocation);
+ balancer.regionOnline(regionInfo, regionLocation);
}
// need to enable the table if not disabled or disabling or enabling
// this will be used in rolling restarts
@@ -3509,6 +3511,7 @@ public class AssignmentManager extends Z
removeClosedRegion(regionInfo);
// remove the region plan as well just in case.
clearRegionPlan(regionInfo);
+ balancer.regionOffline(regionInfo);
}
/**
Modified: hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/LoadBalancer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/LoadBalancer.java?rev=1568189&r1=1568188&r2=1568189&view=diff
==============================================================================
--- hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/LoadBalancer.java (original)
+++ hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/LoadBalancer.java Fri Feb 14 02:21:59 2014
@@ -117,4 +117,17 @@ public interface LoadBalancer extends Co
* @throws HBaseIOException
*/
void initialize() throws HBaseIOException;
+
+ /**
+ * Marks the region as online at balancer.
+ * @param regionInfo
+ * @param sn
+ */
+ void regionOnline(HRegionInfo regionInfo, ServerName sn);
+
+ /**
+ * Marks the region as offline at balancer.
+ * @param regionInfo
+ */
+ void regionOffline(HRegionInfo regionInfo);
}
Modified: hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java?rev=1568189&r1=1568188&r2=1568189&view=diff
==============================================================================
--- hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java (original)
+++ hbase/branches/0.98/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.java Fri Feb 14 02:21:59 2014
@@ -586,6 +586,14 @@ public abstract class BaseLoadBalancer i
}
@Override
+ public void regionOnline(HRegionInfo regionInfo, ServerName sn) {
+ }
+
+ @Override
+ public void regionOffline(HRegionInfo regionInfo) {
+ }
+
+ @Override
public boolean isStopped() {
return stopped;
}