@InterfaceAudience.Private public interface ChangedReadersObserver
Modifier and Type | Method and Description |
---|---|
long |
getReadPoint()
Returns the read point of the current scan
|
void |
updateReaders(List<HStoreFile> sfs,
List<KeyValueScanner> memStoreScanners)
Notify observers.
|
long getReadPoint()
void updateReaders(List<HStoreFile> sfs, List<KeyValueScanner> memStoreScanners) throws IOException
HStoreFile.increaseRefCount()
is invoked for every
HStoreFile
in 'sfs' input parameter to prevent HStoreFile
is archived after a
concurrent compaction, and after this method is invoked,HStoreFile.decreaseRefCount()
is
invoked.So if you open the StoreFileReader
or StoreFileScanner
asynchronously
in this method,you may need to invoke HStoreFile.increaseRefCount()
or
HStoreFile.decreaseRefCount()
by yourself to prevent the HStoreFile
s be archived.sfs
- The new filesmemStoreScanners
- scanner of current memstoreIOException
- eCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.