Interface ChangedReadersObserver
- All Known Implementing Classes:
MobStoreScanner
,ReversedMobStoreScanner
,ReversedStoreScanner
,StoreScanner
If set of MapFile.Readers in Store change, implementors are notified.
-
Method Summary
Modifier and TypeMethodDescriptionlong
Returns the read point of the current scanvoid
updateReaders
(List<HStoreFile> sfs, List<KeyValueScanner> memStoreScanners) Notify observers.
-
Method Details
-
getReadPoint
long getReadPoint()Returns the read point of the current scan -
updateReaders
Notify observers.
NOTE:Before we invoke this method,HStoreFile.increaseRefCount()
is invoked for everyHStoreFile
in 'sfs' input parameter to preventHStoreFile
is archived after a concurrent compaction, and after this method is invoked,HStoreFile.decreaseRefCount()
is invoked.So if you open theStoreFileReader
orStoreFileScanner
asynchronously in this method,you may need to invokeHStoreFile.increaseRefCount()
orHStoreFile.decreaseRefCount()
by yourself to prevent theHStoreFile
s be archived.- Parameters:
sfs
- The new filesmemStoreScanners
- scanner of current memstore- Throws:
IOException
- e
-