class BucketOperatorImpl implements BucketOperator {

  @Override
  public boolean movePrimary(InternalDistributedMember source, InternalDistributedMember target,
      int bucketId) {

    InternalResourceManager.getResourceObserver().movingPrimary(rebalanceOp.getLeaderRegion(),
        bucketId, source, target);
    return rebalanceOp.movePrimaryBucketForRegion(target, bucketId);
  }

  public  BucketOperatorImpl(PartitionedRegionRebalanceOp rebalanceOp);

}