- Atomicity: when you make changes (adding, removing
documents) in an
IndexWritersession, and then commit, either all (if the commit succeeds) or none (if the commit fails) of your changes will be visible, never something in-between. Some methods have their own atomic behavior: if you callupdateDocument, which is implemented as a delete followed by an add, you'll never see the delete without the add, even if you open a near-real-time (NRT) reader or commit from a separate thread. Similarly if you add a block of documents, using the relatively newaddDocumentsmethod, you'll see either none or all of the documents in any reader you obtain.
- Consistency: if the computer or OS crashes, or the JVM
crashes or is killed, or power is lost, your index will remain intact
(ie, not corrupt). Note that other problems, such as bad RAM, a
bit-flipping CPU or file system corruption, can still easily corrupt
the index!
- Isolation: while
IndexWriteris making changes, nothing is visible to anyIndexReadersearching the index, until you commit or open a new NRT reader. Only oneIndexWriterinstance at a time can change the index.
- Durability: once
commitreturns, all changes have been written to durable storage (assuming your I/O system correctly implementsfsync). If the computer or OS crashes, or the JVM crashes or is killed, or power is lost to the computer, all changes will still be present in the index.
Lucene provides
a two-phased
commit API: call the prepareCommit method to do all of the hard work
(applying buffered deletes, writing buffered documents, fsyncing files). If something
is going to go wrong (e.g., disk fills up) it'll almost certainly happen during
this first phase. Then, call
commit to complete the transaction.
When you close the IndexWriter, it calls commit under
the hood. If, instead, you want to discard all changes since the last
commit, call the rollback method instead, which also
closes the writer. You can even rollback a CREATE: if
you have an existing index, and you open an IndexWriter
on it with OpenMode.CREATE, and then rollback, the index will
be unchanged. Likewise, if you call deleteAll and then
rollback.
Note that merely opening an IndexWriter on a new
directory does not create an empty commit; ie, you cannot open an IndexReader on
the directory until you've called commit yourself.
Lucene does not implement
a transaction
log itself, but it's easy to build that layer out on top. For example, popular search servers such
as Solr and
ElasticSearch, do so.
Multiple commits in one index
A single Lucene index is free to contain more than one commit; this is
a powerful yet often overlooked feature. Each commit holds a
point-in-time view of the index as it existed when the commit was
created.
This is similar to the snapshots
and writable clones available in modern filesystems like
ZFS and the
up-and-coming Btrfs. In
fact, Lucene is able to efficiently expose multiple commits for the
very same underlying reason: all index segments and files are write-once, just
like the file blocks in ZFS and Btrfs.
To save multiple commits in your index, just implement your
own IndexDeletionPolicy and pass it to IndexWriter. This is the class Lucene uses
to know which commits should be deleted: IndexWriter invokes it on opening an index
and whenever a commit succeeds. The default
policy, KeepOnlyLastCommitDeletionPolicy, deletes all but
the last commit. If you use NoDeletionPolicy then every
commit is retained!
You can pass a userData
(Map<String,String>) to commit, to record custom
information (opaque to Lucene) about that commit, and then use IndexReader.listCommits to
find all commits in the index. Once you've found a commit, you can
open an IndexReader on it to search the index as of that commit.
You can also open an IndexWriter on a prior commit, to effectively roll back all
changes after it: this is just like the rollback
method, except it enables you to rollback across commits and
not just the changes made in the current IndexWriter session.
Old commits are still kept even when you open an index
with OpenMode.CREATE. It's also fine to
pass OpenMode.CREATE when IndexReaders are still
searching the old commits. This enables fun use cases, such as
fully re-indexing your content between each commit without affecting
any open readers.
Combining all of these fun transactional features, you can do some cool things:
- Hot
backups, using
SnapshotDeletionPolicyorPersistentSnapshotDeletionPolicy: these deletion policies make it trivial to take a "live" backup of the index without blocking ongoing changes withIndexWriter. The backup can easily be incremental (just copy the new files, remove the deleted ones), and you can freely throttle the IO to minimize any interference with searching.
- Searching different catalog versions: perhaps you run an e-commerce site, and but you ship multiple
versions of your catalog. In this case you can keep older commits
around, each searching a specific version of your catalog, enabling
users to choose which catalog to search.
- Repeatable indexing tests from the same initial index: maybe you
want to run a bunch of performance tests, perhaps trying different
RAM buffer sizes or merge factors, starting from a large initial
index. To do this, simply run each test, but in the end, instead of
closing the
IndexWriter, use therollbackmethod to quickly return the index to its initial state, ready for the next test.
- Force all index segments to be merged down to a single segment, but
also keep the prior multi-segment commit. Then you can do
tests to compare multi-segment vs single-segment performance.
- Indexing and searching over the NFS
file system: because NFS does not protect still-open files from
deletion, you must use an
IndexDeletionPolicyto keep each commit around until all open readers have finished with the commit (ie, reopened to a newer commit). The simple approach is time-based, for example: don't delete the commit until it is 15 minutes old, and then always reopen your readers every 5 minutes. Without this you'll hit all sorts of scary exceptions when searching over NFS.
- Distributed commit: if you have other resources that must commit
atomically along with the changes to your Lucene index, you can use
the two-phased commit API. This is simple, but vulnerable to failures during the 2nd phaes; to also recover from such cases, for example if Lucene completed its 2nd phase
commit but the database's 2nd phase hit some error or crash or power loss, you can easily
rollback Lucene's commit by opening an
IndexWriteron the prior commit.
- Experimental index changes: maybe you want to try re-indexing some
subset of your index in a new way, but you're not sure it'll work
out. In this case, just keep the old commit around, and then
rollback if it didn't work out, or delete the old commit if it did.
- Time-based snapshots: maybe you'd like the freedom to roll back to your index as it existed 1 day ago, 1 week ago, 1 month ago, etc., so you preserve commits based on their age.
The "different catalog versions" example and the "Experimental index changes" ideas sound really practical.
ReplyDeleteI think you're absolutely right when you call the multiple commits feature "overlooked" (i didn't know this before), because this allows an index to be versioned, correct?
Is it even possible to identify the differences between two commits on the document- or even field-level (like the diff feature in revision control systems) or am i mislead?
Hi Stefan,
ReplyDeleteExactly, this allows versioning the index; your app gets to decide when to take a point-in-time snapshot to create a new version (ie, by committing).
You could in theory compute a diff between two commits... Lucene doesn't have such an "index differ" (hmm maybe in our test-framework we might have something closish), but the app could build out that diffing on top of Lucene's public APIs. At that point you could diff two separate indices (ie, different directories), or two commits within a single index.
It's fun stuff!
Nice Blog. BTW, I was wondering what would be the reason that someone would want to implementa a transactional log for Lucene, if Lucene already supports all these transactional semantics ?
ReplyDeleteHi Saravanan,
ReplyDeleteTransactional log would mean if the app/OS/computer crashed, on startup the log could be replayed to catch the index up to whatever the app had indexed.
Without a transactional log, if the app/OS/computer crashes, the index will fall back to the last successful commit, so you've lost any changes you'd made after that commit.
Awesome usecases explained Mike, I have a query: What happens if I perform a commit( ) on an IndexWriter which is opened on a prior commit in Lucene?
ReplyDeleteDoes it create some kind of a branch internally for the new commit performed on a prior commit or does it just replace all the newer commits after that prior commit and just retaining the recent commit that I just performed on that prior commit?!
I am very curious to know its answer as it can be useful to me in some future use case.
I have also posted the same question on stackoverflow http://goo.gl/rczlt so you may answer it there also if you like!
Hi Atharva,
ReplyDeleteIn fact it creates a branch: the new commit will reflect the old one you had opened, plus any changes you made during the indexing session. What happens to the future commits (after the one you had opened) is up to your deletion policy. If it saves those commits, then at any time you are free to open a writer against one of them, making a branch from them as well.
(I also answered on StackOverflow).
Thanks for Mike !
DeleteGreat article, thank you!
ReplyDeleteI'm not sure if I understood "Isolation" right in Lucene.
Am I right that if multiple threads share an IndexWriter concurrently, it is possible that one thread commits or rolls back the changes another thread has made? Therefore Lucene doesn't implement "Isolation" in a way that multiple threads sharing one IndexWriter don't see the changes made by other threads until they commit.
So what's the best approach for gaining "real" transaction isolation if multiple threads need to update an index concurrently (e.g. in a web application)?
I've currently identified two approaches:
- Synchronize on a single IndexWriter instance whenever needed.
- Open a new IndexWriter at the beginning of a transaction - Lucene will prevent multiple IndexWriters being opened at the same time on a single index.
Johannnes,
ReplyDeleteThat's correct: there is no Isolation between multiple writer threads, only between writers and readers. Every writer thread sees all changes made by the other writer threads.
If you need Isolation between writers, those two approaches will work. You can have each writer write to its own private index directory, and in the end (if necessary) use IndexWriter.addIndexes to copy over that writer's private index into the main index.
Thanks! I will think about that... I'll also take a look at Neo4j - it seems they have added some transactional semantics to Lucene.
Delete