Skip to content

Commit

Permalink
Merge pull request #623 from sduskis/update_heapsize_test
Browse files Browse the repository at this point in the history
Removing @VisibleForTesting from BigtableBufferedMutator.
  • Loading branch information
sduskis committed Jan 7, 2016
2 parents 3b2ba92 + 68faa5e commit 6cefa81
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,6 @@
import com.google.cloud.bigtable.grpc.async.AsyncExecutor;
import com.google.cloud.bigtable.grpc.async.HeapSizeManager;
import com.google.cloud.bigtable.hbase.adapters.HBaseRequestAdapter;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
Expand All @@ -48,7 +47,6 @@
/**
* Bigtable's {@link BufferedMutator} implementation.
*/
// TODO: Cleanup the interface so that @VisibleForTesting can be reduced.
public class BigtableBufferedMutator implements BufferedMutator {

protected static final Logger LOG = new Logger(BigtableBufferedMutator.class);
Expand Down Expand Up @@ -170,7 +168,7 @@ public void mutate(final Mutation mutation) throws IOException {
}
}

private void doMutation(final Mutation mutation) throws RetriesExhaustedWithDetailsException {
private void doMutation(final Mutation mutation) {
Futures.addCallback(issueRequest(mutation), new ExceptionCallback(mutation));
}

Expand Down Expand Up @@ -255,7 +253,6 @@ public void onSuccess(GeneratedMessage ignored) {
}
}

@VisibleForTesting
public boolean hasInflightRequests() {
return this.asyncExecutor.hasInflightRequests();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ public <T> FutureCallback<T> addCallback(ListenableFuture<T> future, Long id) {
}

@Test
public void testNoMutation() throws IOException {
public void testNoMutation() {
Assert.assertFalse(underTest.hasInflightRequests());
}

Expand Down

0 comments on commit 6cefa81

Please sign in to comment.