Repository: hbase Updated Branches: refs/heads/master 3b63f701e -> 287358ba6
HBASE-17054 Compactor#preCreateCoprocScanner should be passed user Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/287358ba Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/287358ba Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/287358ba Branch: refs/heads/master Commit: 287358ba6cf558102989945416d3c6d34ae300e9 Parents: 3b63f70 Author: tedyu <[email protected]> Authored: Wed Nov 9 06:57:43 2016 -0800 Committer: tedyu <[email protected]> Committed: Wed Nov 9 06:57:43 2016 -0800 ---------------------------------------------------------------------- .../hadoop/hbase/regionserver/compactions/Compactor.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/287358ba/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java index a5a48f3..3c79e56 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/Compactor.java @@ -294,7 +294,7 @@ public abstract class Compactor<T extends CellSink> { try { /* Include deletes, unless we are doing a major compaction */ ScanType scanType = scannerFactory.getScanType(request); - scanner = preCreateCoprocScanner(request, scanType, fd.earliestPutTs, scanners); + scanner = preCreateCoprocScanner(request, scanType, fd.earliestPutTs, scanners, user); if (scanner == null) { scanner = scannerFactory.createScanner(scanners, scanType, fd, smallestReadPoint); } @@ -344,14 +344,10 @@ public abstract class Compactor<T extends CellSink> { * @param scanType Scan type. * @param earliestPutTs Earliest put ts. * @param scanners File scanners for compaction files. + * @param user the User * @return Scanner override by coprocessor; null if not overriding. */ protected InternalScanner preCreateCoprocScanner(final CompactionRequest request, - ScanType scanType, long earliestPutTs, List<StoreFileScanner> scanners) throws IOException { - return preCreateCoprocScanner(request, scanType, earliestPutTs, scanners, null); - } - - protected InternalScanner preCreateCoprocScanner(final CompactionRequest request, final ScanType scanType, final long earliestPutTs, final List<StoreFileScanner> scanners, User user) throws IOException { if (store.getCoprocessorHost() == null) {
