class BucketOperatorImpl implements BucketOperator {

  @Override
  public void createRedundantBucket(InternalDistributedMember targetMember, int bucketId,
      Map<String, Long> colocatedRegionBytes, Completion completion) {
    boolean result = false;
    try {
      result = rebalanceOp.createRedundantBucketForRegion(targetMember, bucketId);
    } finally {
      if (result) {
        completion.onSuccess();
      } else {
        completion.onFailure();
      }
    }
  }

  public  BucketOperatorImpl(PartitionedRegionRebalanceOp rebalanceOp);

}