BucketOperatorImpl implements BucketOperator { @Override public boolean removeBucket(InternalDistributedMember targetMember, int bucketId, Map<String, Long> colocatedRegionBytes) { return rebalanceOp.removeRedundantBucketForRegion(targetMember, bucketId); } BucketOperatorImpl(PartitionedRegionRebalanceOp rebalanceOp); @Override boolean moveBucket(InternalDistributedMember source, InternalDistributedMember target,
      int bucketId, Map<String, Long> colocatedRegionBytes); @Override boolean movePrimary(InternalDistributedMember source, InternalDistributedMember target,
      int bucketId); @Override void createRedundantBucket(InternalDistributedMember targetMember, int bucketId,
      Map<String, Long> colocatedRegionBytes, Completion completion); @Override void waitForOperations(); @Override boolean removeBucket(InternalDistributedMember targetMember, int bucketId,
      Map<String, Long> colocatedRegionBytes);  }
@Test public void removeBucketShouldDelegateToParRegRebalanceOpRemoveRedundantBucketForRegion() { doReturn(true).when(rebalanceOp).removeRedundantBucketForRegion(targetMember, bucketId); operator.removeBucket(targetMember, bucketId, colocatedRegionBytes); verify(rebalanceOp, times(1)).removeRedundantBucketForRegion(targetMember, bucketId); }