/lucene-3.6.0/lucene/test-framework/src/java/org/apache/lucene/index/ |
H A D | MockRandomMergePolicy.java | 42 public MergeSpecification findMerges(SegmentInfos segmentInfos) { argument 44 //System.out.println("MRMP: findMerges sis=" + segmentInfos); 46 if (segmentInfos.size() > 1 && random.nextInt(5) == 3) { 48 List<SegmentInfo> segments = new ArrayList<SegmentInfo>(segmentInfos.asList()); 53 final int segsToMerge = _TestUtil.nextInt(random, 1, segmentInfos.size()); 62 SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) 66 for(SegmentInfo info : segmentInfos) { 72 //System.out.println("MRMP: findMerges sis=" + segmentInfos + " eligible=" + eligibleSegments); 100 SegmentInfos segmentInfos) 102 return findMerges(segmentInfos); 61 findForcedMerges( SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) argument 99 findForcedDeletesMerges( SegmentInfos segmentInfos) argument [all...] |
/lucene-3.6.0/lucene/backwards/src/test-framework/java/org/apache/lucene/index/ |
H A D | MockRandomMergePolicy.java | 39 public MergeSpecification findMerges(SegmentInfos segmentInfos) { argument 41 //System.out.println("MRMP: findMerges sis=" + segmentInfos); 43 if (segmentInfos.size() > 1 && random.nextInt(5) == 3) { 45 List<SegmentInfo> segments = new ArrayList<SegmentInfo>(segmentInfos.asList()); 50 final int segsToMerge = _TestUtil.nextInt(random, 1, segmentInfos.size()); 59 SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) 63 for(SegmentInfo info : segmentInfos) { 69 //System.out.println("MRMP: findMerges sis=" + segmentInfos + " eligible=" + eligibleSegments); 97 SegmentInfos segmentInfos) 99 return findMerges(segmentInfos); 58 findForcedMerges( SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) argument 96 findForcedDeletesMerges( SegmentInfos segmentInfos) argument [all...] |
/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/index/ |
H A D | NoMergePolicy.java | 57 public MergeSpecification findMerges(SegmentInfos segmentInfos) argument 61 public MergeSpecification findForcedMerges(SegmentInfos segmentInfos, argument 66 public MergeSpecification findForcedDeletesMerges(SegmentInfos segmentInfos) argument
|
H A D | UpgradeIndexMergePolicy.java | 77 public MergeSpecification findMerges(SegmentInfos segmentInfos) throws CorruptIndexException, IOException { argument 78 return base.findMerges(segmentInfos); 82 public MergeSpecification findForcedMerges(SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) throws CorruptIndexException, IOException { argument 85 for (final SegmentInfo si : segmentInfos) { 97 MergeSpecification spec = base.findForcedMerges(segmentInfos, maxSegmentCount, oldSegments); 113 for (final SegmentInfo si : segmentInfos) { 129 public MergeSpecification findForcedDeletesMerges(SegmentInfos segmentInfos) throws CorruptIndexException, IOException { argument 130 return base.findForcedDeletesMerges(segmentInfos);
|
H A D | BufferedDeletesStream.java | 277 // assert infos != segmentInfos || !any() : "infos=" + infos + " segmentInfos=" + segmentInfos + " any=" + any; 290 public synchronized void prune(SegmentInfos segmentInfos) { argument 293 for(SegmentInfo info : segmentInfos) { 298 message("prune sis=" + segmentInfos + " minGen=" + minGen + " packetCount=" + deletes.size());
|
H A D | IndexFileDeleter.java | 136 public IndexFileDeleter(Directory directory, IndexDeletionPolicy policy, SegmentInfos segmentInfos, PrintStream infoStream, IndexWriter writer) argument 142 final String currentSegmentsFile = segmentInfos.getSegmentsFileName(); 153 long currentGen = segmentInfos.getGeneration(); 207 if (sis.getGeneration() == segmentInfos.getGeneration()) { 223 // corresponding to the segmentInfos that was passed 236 message("forced open of current segments file " + segmentInfos.getSegmentsFileName()); 266 // Always protect the incoming segmentInfos since 268 checkpoint(segmentInfos, false); 441 public void checkpoint(SegmentInfos segmentInfos, boolean isCommit) throws IOException { argument 445 message("now checkpoint \"" + segmentInfos 476 incRef(SegmentInfos segmentInfos, boolean isCommit) argument 522 decRef(SegmentInfos segmentInfos) argument 648 CommitPoint(Collection<CommitPoint> commitsToDelete, Directory directory, SegmentInfos segmentInfos) argument [all...] |
H A D | LogMergePolicy.java | 414 public MergeSpecification findForcedDeletesMerges(SegmentInfos segmentInfos) argument 416 final List<SegmentInfo> segments = segmentInfos.asList(); 427 final SegmentInfo info = segmentInfos.info(i);
|
H A D | MergePolicy.java | 278 * @param segmentInfos 281 public abstract MergeSpecification findMerges(SegmentInfos segmentInfos) argument 291 * @param segmentInfos 306 SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) 313 * @param segmentInfos 317 SegmentInfos segmentInfos) throws CorruptIndexException, IOException; 305 findForcedMerges( SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) argument 316 findForcedDeletesMerges( SegmentInfos segmentInfos) argument
|
H A D | CheckIndex.java | 92 public List<SegmentInfoStatus> segmentInfos = new ArrayList<SegmentInfoStatus>(); field in class:CheckIndex.Status 125 * See {@link #segmentInfos}. 478 result.segmentInfos.add(segInfoStat);
|
H A D | DirectoryReader.java | 50 private final SegmentInfos segmentInfos; field in class:DirectoryReader 64 // > our current segmentInfos version in case we were 89 this.segmentInfos = sis; 134 segmentInfos = (SegmentInfos) infos.clone(); 148 segmentInfos.remove(infosUpto); 169 this.segmentInfos = infos; 300 final String segmentsFile = segmentInfos.getSegmentsFileName(); 351 DirectoryReader newReader = doOpenIfChanged((SegmentInfos) segmentInfos.clone(), true, openReadOnly); 409 if (writer.nrtIsCurrent(segmentInfos)) { 416 if (reader.getVersion() == segmentInfos [all...] |
H A D | DocumentsWriter.java | 481 private void pushDeletes(SegmentInfo newSegment, SegmentInfos segmentInfos) { argument 485 if (segmentInfos.size() > 0 || newSegment != null) { 517 synchronized SegmentInfo flush(IndexWriter writer, IndexFileDeleter deleter, MergePolicy mergePolicy, SegmentInfos segmentInfos) throws IOException { argument 521 // We change writer's segmentInfos: 532 pushDeletes(null, segmentInfos); 593 if (mergePolicy.useCompoundFile(segmentInfos, newSegment)) { 666 pushDeletes(newSegment, segmentInfos);
|
H A D | IndexWriter.java | 276 final SegmentInfos segmentInfos = new SegmentInfos(); // the segments field in class:IndexWriter 445 // Prevent segmentInfos from changing while opening the 451 r = new ReadOnlyDirectoryReader(this, segmentInfos, termInfosIndexDivisor, applyAllDeletes); 494 int idx = segmentInfos.indexOf(info); 496 assert segmentInfos.info(idx) == info: "info=" + info + " doesn't match live info in segmentInfos"; 501 int idx = segmentInfos.indexOf(info); 503 info = segmentInfos.info(idx); 611 deleter.checkpoint(segmentInfos, false); 643 deleter.checkpoint(segmentInfos, fals [all...] |
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/index/ |
H A D | TestPerSegmentDeletes.java | 54 assertEquals(1, writer.segmentInfos.size()); 61 assertEquals(2, writer.segmentInfos.size()); 93 assertEquals(2, writer.segmentInfos.size()); 128 System.out.println("maybeMerge "+writer.segmentInfos); 130 SegmentInfo info0 = writer.segmentInfos.info(0); 131 SegmentInfo info1 = writer.segmentInfos.info(1); 134 System.out.println("maybeMerge after "+writer.segmentInfos); 140 assertEquals(2, writer.segmentInfos.size()); 141 assertFalse(segThere(info0, writer.segmentInfos)); 142 assertFalse(segThere(info1, writer.segmentInfos)); 249 findMerges(SegmentInfos segmentInfos) argument 262 findForcedMerges(SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) argument 269 findForcedDeletesMerges( SegmentInfos segmentInfos) argument [all...] |
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/index/ |
H A D | TestPerSegmentDeletes.java | 53 assertEquals(1, writer.segmentInfos.size()); 60 assertEquals(2, writer.segmentInfos.size()); 92 assertEquals(2, writer.segmentInfos.size()); 127 System.out.println("maybeMerge "+writer.segmentInfos); 129 SegmentInfo info0 = writer.segmentInfos.info(0); 130 SegmentInfo info1 = writer.segmentInfos.info(1); 133 System.out.println("maybeMerge after "+writer.segmentInfos); 139 assertEquals(2, writer.segmentInfos.size()); 140 assertFalse(segThere(info0, writer.segmentInfos)); 141 assertFalse(segThere(info1, writer.segmentInfos)); 248 findMerges(SegmentInfos segmentInfos) argument 261 findForcedMerges(SegmentInfos segmentInfos, int maxSegmentCount, Map<SegmentInfo,Boolean> segmentsToMerge) argument 268 findForcedDeletesMerges( SegmentInfos segmentInfos) argument [all...] |