code: @Override
      public void rebalance() {
          double target = evenDistribution();
          final double myLoad = myLoad();
          if (myLoad > target) {
              LOG.info("Smart Rebalance triggered. Load: %s. Target: %s", myLoad, target);
              drainToLoad((long) target);
          }
      }
docs: Performs a "smart rebalance." The target load is set to (cluster load / node count),
  where "load" is determined by the sum of all work unit meters in the cluster.