Home
last modified time | relevance | path

Searched refs:getBalancer (Results 1 – 7 of 7) sorted by relevance

/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/
H A DRWQueueRpcExecutor.java133 this.writeBalancer = getBalancer(numWriteQueues); in RWQueueRpcExecutor()
134 this.readBalancer = getBalancer(numReadQueues); in RWQueueRpcExecutor()
135 this.scanBalancer = getBalancer(numScanQueues); in RWQueueRpcExecutor()
H A DBalancedQueueRpcExecutor.java63 this.balancer = getBalancer(numQueues); in BalancedQueueRpcExecutor()
H A DRpcExecutor.java179 public static QueueBalancer getBalancer(int queueSize) { in getBalancer() method in RpcExecutor
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/s/balancer/
H A Dbalancer.cpp82 const auto getBalancer = ServiceContext::declareDecoration<std::unique_ptr<Balancer>>(); variable
174 invariant(!getBalancer(serviceContext)); in create()
175 getBalancer(serviceContext) = stdx::make_unique<Balancer>(serviceContext); in create()
179 return getBalancer(serviceContext).get(); in get()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/handler/
H A DEnableTableHandler.java210 this.assignmentManager.getBalancer().roundRobinAssignment(unrecordedReplicas, in handleEnableTable()
228 this.assignmentManager.getBalancer().retainAssignment(regionsToAssign, onlineServers); in handleEnableTable()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/
H A DEnableTableProcedure.java435 assignmentManager.getBalancer().roundRobinAssignment(unrecordedReplicas, in markRegionsOnline()
455 env.getMasterServices().getAssignmentManager().getBalancer() in markRegionsOnline()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/
H A DAssignmentManager.java4419 public LoadBalancer getBalancer() { in getBalancer() method in AssignmentManager