Skip to content
This repository has been archived by the owner on Nov 14, 2024. It is now read-only.

Commit

Permalink
Remove unused.
Browse files Browse the repository at this point in the history
  • Loading branch information
OStevan committed Oct 15, 2019
1 parent c224fc3 commit 2e9c61b
Showing 1 changed file with 0 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -686,23 +686,6 @@ private interface CellLoader {
ListenableFuture<Map<Cell, Value>> load(TableReference tableReference, Map<Cell, Long> toRead);
}

/**
* This will load the given keys from the underlying key value service and apply postFiltering
* so we have snapshot isolation. If the value in the key value service is the empty array
* this will be included here and needs to be filtered out.
*/
private ListenableFuture<Map<Cell, byte[]>> getFromKeyValueServiceAsync(TableReference tableRef, Set<Cell> cells) {
ImmutableMap.Builder<Cell, byte[]> result = ImmutableMap.builderWithExpectedSize(cells.size());
Map<Cell, Long> toRead = Cells.constantValueMap(cells, getStartTimestamp());
return Futures.transform(
keyValueService.getAsync(tableRef, toRead),
rawResults -> {
getWithPostFiltering(tableRef, rawResults, result, Value.GET_VALUE);
return result.build();
},
MoreExecutors.directExecutor());
}

private static byte[] getNextStartRowName(
RangeRequest range,
TokenBackedBasicResultsPage<RowResult<Value>, byte[]> prePostFilter) {
Expand Down

0 comments on commit 2e9c61b

Please sign in to comment.