Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-18220 - Addendum as per Duo suggestion for readability (Ram)

This commit is contained in:
Ramkrishna 2017-06-16 12:34:08 +05:30
parent 8653823ac4
commit c20d9cb1a2
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
View File

@ -190,6 +190,11 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
if (get) { if (get) {
this.readType = Scan.ReadType.PREAD; this.readType = Scan.ReadType.PREAD;
this.scanUsePread = true; this.scanUsePread = true;
} else if(scanType != scanType.USER_SCAN) {
// For compaction scanners never use Pread as already we have stream based scanners on the
// store files to be compacted
this.readType = Scan.ReadType.STREAM;
this.scanUsePread = false;
} else { } else {
if (scan.getReadType() == Scan.ReadType.DEFAULT) { if (scan.getReadType() == Scan.ReadType.DEFAULT) {
this.readType = scanInfo.isUsePread() ? Scan.ReadType.PREAD : Scan.ReadType.DEFAULT; this.readType = scanInfo.isUsePread() ? Scan.ReadType.PREAD : Scan.ReadType.DEFAULT;
@ -198,12 +203,7 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
} }
// Always start with pread unless user specific stream. Will change to stream later if // Always start with pread unless user specific stream. Will change to stream later if
// readType is default if the scan keeps running for a long time. // readType is default if the scan keeps running for a long time.
if (scanType != ScanType.COMPACT_DROP_DELETES this.scanUsePread = this.readType != Scan.ReadType.STREAM;
&& scanType != ScanType.COMPACT_RETAIN_DELETES) {
// For compaction scanners never use Pread as already we have stream based scanners on the
// store files to be compacted
this.scanUsePread = this.readType != Scan.ReadType.STREAM;
}
} }
this.preadMaxBytes = scanInfo.getPreadMaxBytes(); this.preadMaxBytes = scanInfo.getPreadMaxBytes();
this.cellsPerHeartbeatCheck = scanInfo.getCellsPerTimeoutCheck(); this.cellsPerHeartbeatCheck = scanInfo.getCellsPerTimeoutCheck();