diff options
| author | Adrien Grand <jpountz@gmail.com> | 2017-06-15 13:40:48 +0200 |
|---|---|---|
| committer | Adrien Grand <jpountz@gmail.com> | 2017-06-15 13:51:46 +0200 |
| commit | 1b90c46a53c0b072f969a3d5bd6d0340c594709e (patch) | |
| tree | 110c9ac6647125649e5b3d0169ba611039f62d13 /core/src/test/java/org/elasticsearch/common | |
| parent | 0036f28a6a1bae06ac703a97cbf42006a934157a (diff) | |
Allow reader wrappers to have different live docs but the same cache key.
Relates to #19856
Diffstat (limited to 'core/src/test/java/org/elasticsearch/common')
| -rw-r--r-- | core/src/test/java/org/elasticsearch/common/lucene/uid/VersionLookupTests.java | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/core/src/test/java/org/elasticsearch/common/lucene/uid/VersionLookupTests.java b/core/src/test/java/org/elasticsearch/common/lucene/uid/VersionLookupTests.java index ccede9dea5..e1ca837997 100644 --- a/core/src/test/java/org/elasticsearch/common/lucene/uid/VersionLookupTests.java +++ b/core/src/test/java/org/elasticsearch/common/lucene/uid/VersionLookupTests.java @@ -56,21 +56,21 @@ public class VersionLookupTests extends ESTestCase { writer.addDocument(new Document()); DirectoryReader reader = DirectoryReader.open(writer); LeafReaderContext segment = reader.leaves().get(0); - PerThreadIDVersionAndSeqNoLookup lookup = new PerThreadIDVersionAndSeqNoLookup(segment, IdFieldMapper.NAME); + PerThreadIDVersionAndSeqNoLookup lookup = new PerThreadIDVersionAndSeqNoLookup(segment.reader(), IdFieldMapper.NAME); // found doc - DocIdAndVersion result = lookup.lookupVersion(new BytesRef("6")); + DocIdAndVersion result = lookup.lookupVersion(new BytesRef("6"), segment); assertNotNull(result); assertEquals(87, result.version); assertEquals(0, result.docId); // not found doc - assertNull(lookup.lookupVersion(new BytesRef("7"))); + assertNull(lookup.lookupVersion(new BytesRef("7"), segment)); // deleted doc writer.deleteDocuments(new Term(IdFieldMapper.NAME, "6")); reader.close(); reader = DirectoryReader.open(writer); segment = reader.leaves().get(0); - lookup = new PerThreadIDVersionAndSeqNoLookup(segment, IdFieldMapper.NAME); - assertNull(lookup.lookupVersion(new BytesRef("6"))); + lookup = new PerThreadIDVersionAndSeqNoLookup(segment.reader(), IdFieldMapper.NAME); + assertNull(lookup.lookupVersion(new BytesRef("6"), segment)); reader.close(); writer.close(); dir.close(); @@ -91,9 +91,9 @@ public class VersionLookupTests extends ESTestCase { writer.addDocument(new Document()); DirectoryReader reader = DirectoryReader.open(writer); LeafReaderContext segment = reader.leaves().get(0); - PerThreadIDVersionAndSeqNoLookup lookup = new PerThreadIDVersionAndSeqNoLookup(segment, IdFieldMapper.NAME); + PerThreadIDVersionAndSeqNoLookup lookup = new PerThreadIDVersionAndSeqNoLookup(segment.reader(), IdFieldMapper.NAME); // return the last doc when there are duplicates - DocIdAndVersion result = lookup.lookupVersion(new BytesRef("6")); + DocIdAndVersion result = lookup.lookupVersion(new BytesRef("6"), segment); assertNotNull(result); assertEquals(87, result.version); assertEquals(1, result.docId); @@ -102,8 +102,8 @@ public class VersionLookupTests extends ESTestCase { reader.close(); reader = DirectoryReader.open(writer); segment = reader.leaves().get(0); - lookup = new PerThreadIDVersionAndSeqNoLookup(segment, IdFieldMapper.NAME); - result = lookup.lookupVersion(new BytesRef("6")); + lookup = new PerThreadIDVersionAndSeqNoLookup(segment.reader(), IdFieldMapper.NAME); + result = lookup.lookupVersion(new BytesRef("6"), segment); assertNotNull(result); assertEquals(87, result.version); assertEquals(1, result.docId); @@ -112,8 +112,8 @@ public class VersionLookupTests extends ESTestCase { reader.close(); reader = DirectoryReader.open(writer); segment = reader.leaves().get(0); - lookup = new PerThreadIDVersionAndSeqNoLookup(segment, IdFieldMapper.NAME); - assertNull(lookup.lookupVersion(new BytesRef("6"))); + lookup = new PerThreadIDVersionAndSeqNoLookup(segment.reader(), IdFieldMapper.NAME); + assertNull(lookup.lookupVersion(new BytesRef("6"), segment)); reader.close(); writer.close(); dir.close(); |