Toggle navigation
Home
org.apache.phoenix.hbase.index.scanner.Scanner to org.apache.phoenix.hbase.index.scanner.ScannerBuilder.CoveredDeleteScanner
No. of Instances - 14
No. of Commits - 1
No. of Projects - {'pheonix'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
Pair<Scanner,IndexUpdate>
to
Pair<CoveredDeleteScanner,IndexUpdate>
Update argument list (Method invocation)
getFilteredScanner
to
getFilteredScanner
Cascading Type Change (Similar)
Pair<Scanner,IndexUpdate>
to
Pair<CoveredDeleteScanner,IndexUpdate>
Scanner
to
CoveredDeleteScanner
Update Class Instacne Creation
new EmptyScanner()
to
new EmptyScanner(deleteTracker)
Update Anonymous class
{ @Override public Cell next(){ try { return kvScanner.next(); } catch ( IOException e) { throw new RuntimeException("Error reading kvs from local memstore!"); } } @Override public boolean seek( Cell next) throws IOException { Cell peek=kvScanner.peek(); if (peek != null) { int compare=KeyValue.COMPARATOR.compare(peek,next); if (compare < 0) { return kvScanner.reseek(next); } else if (compare == 0) { return true; } } return kvScanner.seek(next); } @Override public Cell peek() throws IOException { return kvScanner.peek(); } @Override public void close() throws IOException { kvScanner.close(); } }
to
{ @Override public Cell next(){ try { return kvScanner.next(); } catch ( IOException e) { throw new RuntimeException("Error reading kvs from local memstore!"); } } @Override public boolean seek( Cell next) throws IOException { Cell peek=kvScanner.peek(); if (peek != null) { int compare=KeyValue.COMPARATOR.compare(peek,next); if (compare < 0) { return kvScanner.reseek(next); } else if (compare == 0) { return true; } } return kvScanner.seek(next); } @Override public Cell peek() throws IOException { return kvScanner.peek(); } @Override public void close() throws IOException { kvScanner.close(); } @Override public DeleteTracker getDeleteTracker(){ return deleteTracker; } }