LUCENE-1288: add getVersion, getGeneration to IndexCommit

git-svn-id: https://svn.apache.org/repos/asf/lucene/java/trunk@660904 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael McCandless 2008-05-28 11:00:33 +00:00
parent df7fb0f45c
commit d8c8c0e2c0
6 changed files with 55 additions and 2 deletions

View File

@ -71,6 +71,11 @@ API Changes
and remove all references to these classes from the core. Also update demos and remove all references to these classes from the core. Also update demos
and tutorials. (Michael Busch) and tutorials. (Michael Busch)
10. LUCENE-1288: Add getVersion() and getGeneration() to IndexCommit.
getVersion() returns the same value that IndexReader.getVersion()
returns when the reader is opened on the same commit. (Jason
Rutherglen via Mike McCandless)
Bug fixes Bug fixes
1. LUCENE-1134: Fixed BooleanQuery.rewrite to only optimize a single 1. LUCENE-1134: Fixed BooleanQuery.rewrite to only optimize a single

View File

@ -343,6 +343,8 @@ abstract class DirectoryIndexReader extends IndexReader {
private String segmentsFileName; private String segmentsFileName;
Collection files; Collection files;
Directory dir; Directory dir;
long generation;
long version;
ReaderCommit(SegmentInfos infos, Directory dir) throws IOException { ReaderCommit(SegmentInfos infos, Directory dir) throws IOException {
segmentsFileName = infos.getCurrentSegmentFileName(); segmentsFileName = infos.getCurrentSegmentFileName();
@ -355,6 +357,8 @@ abstract class DirectoryIndexReader extends IndexReader {
if (info.dir == dir) if (info.dir == dir)
files.addAll(info.files()); files.addAll(info.files());
} }
version = infos.getVersion();
generation = infos.getGeneration();
} }
public String getSegmentsFileName() { public String getSegmentsFileName() {
return segmentsFileName; return segmentsFileName;
@ -365,6 +369,12 @@ abstract class DirectoryIndexReader extends IndexReader {
public Directory getDirectory() { public Directory getDirectory() {
return dir; return dir;
} }
public long getVersion() {
return version;
}
public long getGeneration() {
return generation;
}
} }
/** /**

View File

@ -89,4 +89,17 @@ public abstract class IndexCommit implements IndexCommitPoint {
public int hashCode() { public int hashCode() {
return getDirectory().hashCode() + getSegmentsFileName().hashCode(); return getDirectory().hashCode() + getSegmentsFileName().hashCode();
} }
/** Returns the version for this IndexCommit. This is the
same value that {@link IndexReader#getVersion} would
return if it were opened on this commit. */
public long getVersion() {
throw new UnsupportedOperationException("This IndexCommit does not support this method.");
}
/** Returns the generation (the _N in segments_N) for this
IndexCommit */
public long getGeneration() {
throw new UnsupportedOperationException("This IndexCommit does not support this method.");
}
} }

View File

@ -577,11 +577,15 @@ final class IndexFileDeleter {
boolean deleted; boolean deleted;
Directory directory; Directory directory;
Collection commitsToDelete; Collection commitsToDelete;
long version;
long generation;
public CommitPoint(Collection commitsToDelete, Directory directory, SegmentInfos segmentInfos) throws IOException { public CommitPoint(Collection commitsToDelete, Directory directory, SegmentInfos segmentInfos) throws IOException {
this.directory = directory; this.directory = directory;
this.commitsToDelete = commitsToDelete; this.commitsToDelete = commitsToDelete;
segmentsFileName = segmentInfos.getCurrentSegmentFileName(); segmentsFileName = segmentInfos.getCurrentSegmentFileName();
version = segmentInfos.getVersion();
generation = segmentInfos.getGeneration();
int size = segmentInfos.size(); int size = segmentInfos.size();
files = new ArrayList(size); files = new ArrayList(size);
files.add(segmentsFileName); files.add(segmentsFileName);
@ -606,6 +610,14 @@ final class IndexFileDeleter {
return directory; return directory;
} }
public long getVersion() {
return version;
}
public long getGeneration() {
return generation;
}
/** /**
* Called only be the deletion policy, to remove this * Called only be the deletion policy, to remove this
* commit point from the index. * commit point from the index.

View File

@ -109,6 +109,12 @@ public class SnapshotDeletionPolicy implements IndexDeletionPolicy {
cp.delete(); cp.delete();
} }
} }
public long getVersion() {
return cp.getVersion();
}
public long getGeneration() {
return cp.getGeneration();
}
} }
private List wrapCommits(List commits) { private List wrapCommits(List commits) {

View File

@ -42,10 +42,17 @@ import org.apache.lucene.util.LuceneTestCase;
public class TestDeletionPolicy extends LuceneTestCase public class TestDeletionPolicy extends LuceneTestCase
{ {
private void verifyCommitOrder(List commits) { private void verifyCommitOrder(List commits) {
long last = SegmentInfos.generationFromSegmentsFileName(((IndexCommit) commits.get(0)).getSegmentsFileName()); final IndexCommit firstCommit = ((IndexCommit) commits.get(0));
long last = SegmentInfos.generationFromSegmentsFileName(firstCommit.getSegmentsFileName());
assertEquals(last, firstCommit.getGeneration());
long lastVersion = firstCommit.getVersion();
for(int i=1;i<commits.size();i++) { for(int i=1;i<commits.size();i++) {
long now = SegmentInfos.generationFromSegmentsFileName(((IndexCommit) commits.get(i)).getSegmentsFileName()); final IndexCommit commit = ((IndexCommit) commits.get(i));
long now = SegmentInfos.generationFromSegmentsFileName(commit.getSegmentsFileName());
long nowVersion = commit.getVersion();
assertTrue("SegmentInfos commits are out-of-order", now > last); assertTrue("SegmentInfos commits are out-of-order", now > last);
assertTrue("SegmentInfos versions are out-of-order", nowVersion > lastVersion);
assertEquals(now, commit.getGeneration());
last = now; last = now;
} }
} }