@InterfaceAudience.Private interface StoreFlushContext
Modifier and Type | Method and Description |
---|---|
void |
abort()
Abort the snapshot preparation.
|
boolean |
commit(MonitoredTask status)
Commit the flush - add the store file to the store and clear the
memstore snapshot.
|
void |
flushCache(MonitoredTask status)
Flush the cache (create the new store file)
A length operation which doesn't require locking out any function
of the store.
|
List<org.apache.hadoop.fs.Path> |
getCommittedFiles()
Returns the newly committed files from the flush.
|
void |
prepare()
Prepare for a store flush (create snapshot)
Requires pausing writes.
|
void |
replayFlush(List<String> fileNames,
boolean dropMemstoreSnapshot)
Similar to commit, but called in secondary region replicas for replaying the
flush cache from primary region.
|
void prepare()
void flushCache(MonitoredTask status) throws IOException
IOException
- in case the flush failsboolean commit(MonitoredTask status) throws IOException
IOException
void replayFlush(List<String> fileNames, boolean dropMemstoreSnapshot) throws IOException
fileNames
- names of the flushed filesdropMemstoreSnapshot
- whether to drop the prepared memstore snapshotIOException
void abort() throws IOException
IOException
List<org.apache.hadoop.fs.Path> getCommittedFiles()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.