/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/index/ |
H A D | SerialMergeScheduler.java | 22 /** A {@link MergeScheduler} that simply does each merge 28 * multiple threads, only one merge may run at a time. */ 30 synchronized public void merge(IndexWriter writer) method in class:SerialMergeScheduler 34 MergePolicy.OneMerge merge = writer.getNextMerge(); 35 if (merge == null) 37 writer.merge(merge);
|
H A D | MergeScheduler.java | 32 public abstract void merge(IndexWriter writer) method in class:MergeScheduler
|
H A D | ConcurrentMergeScheduler.java | 29 /** A {@link MergeScheduler} that runs each merge using a 52 // Max number of merge threads allowed to be running at 79 /** Sets the max # simultaneous merge threads that should 98 * If a merge is necessary yet we already have this many 100 * add/updateDocument) will block until a merge thread 118 /** Return the priority that merge threads run at. By 121 * calls merge. */ 127 /** Set the base priority that merge threads run at. 128 * Note that CMS may increase priority of some merge 155 * threads. This method sorts the merge thread 294 public void merge(IndexWriter writer) throws IOException { method in class:ConcurrentMergeScheduler 387 doMerge(MergePolicy.OneMerge merge) argument 392 getMergeThread(IndexWriter writer, MergePolicy.OneMerge merge) argument 412 setRunningMerge(MergePolicy.OneMerge merge) argument [all...] |
H A D | IndexWriter.java | 371 * index-to-search delay after a large merge. </p> 476 /** Forcefully clear changes for the specified segments. This is called on successful merge. */ 548 // after a successful merge. 708 // needed to merge it, we didn't load the terms 792 throw new IllegalArgumentException("this method can only be called when the merge policy is the default LogMergePolicy"); 1117 // instead of later when merge, applyDeletes, getReader 1262 * Expert: set the merge policy used by this writer. 1297 * Expert: set the merge scheduler used by this writer. 1345 * <p>The default merge policy ({@link 1791 * for very long, because this can result in "merge 3673 ensureValidMerge(MergePolicy.OneMerge merge) argument 3690 commitMergedDeletes(MergePolicy.OneMerge merge, SegmentReader mergedReader) argument 3771 commitMerge(MergePolicy.OneMerge merge, SegmentReader mergedReader) argument 3847 handleMergeException(Throwable t, MergePolicy.OneMerge merge) argument 3885 merge(MergePolicy.OneMerge merge) argument 3936 mergeSuccess(MergePolicy.OneMerge merge) argument 3945 registerMerge(MergePolicy.OneMerge merge) argument 3998 mergeInit(MergePolicy.OneMerge merge) argument 4013 _mergeInit(MergePolicy.OneMerge merge) argument 4126 mergeFinish(MergePolicy.OneMerge merge) argument 4148 closeMergeReaders(MergePolicy.OneMerge merge, boolean suppressExceptions) argument 4197 mergeMiddle(MergePolicy.OneMerge merge) argument 4395 addMergeException(MergePolicy.OneMerge merge) argument [all...] |
H A D | NoMergeScheduler.java | 45 public void merge(IndexWriter writer) throws CorruptIndexException, IOException {} method in class:NoMergeScheduler
|
H A D | MergeDocIDRemapper.java | 20 /** Remaps docIDs after a merge has completed, where the 23 * merge of segments with deletions commits. */ 31 int docShift; // total # deleted docs that were compacted by this merge 33 public MergeDocIDRemapper(SegmentInfos infos, int[][] docMaps, int[] delCounts, MergePolicy.OneMerge merge, int mergedDocCount) { argument 35 SegmentInfo firstSegment = merge.segments.get(0); 48 assert infos.info(i).equals(merge.segments.get(j)); 58 final int lastDocCount = merge.segments.get(i-1).docCount; 72 assert docShift == maxDocID - (newStarts[docMaps.length-1] + merge.segments.get(docMaps.length-1).docCount - delCounts[docMaps.length-1]); 77 // Unaffected by merge 80 // This doc was "after" the merge, s [all...] |
H A D | TieredMergePolicy.java | 32 * to {@link LogByteSizeMergePolicy}, except this merge 33 * policy is able to merge non-adjacent segment, and 36 * per tier ({@link #setSegmentsPerTier}). This merge 37 * policy also does not over-merge (i.e. cascade merges). 43 * deletes), and then finds the least-cost merge. Merge 45 * merge (size of largest segment divided by smallest segment), 46 * total merge size and percent deletes reclaimed, 51 * <p>If a merge will produce a segment that's larger than 53 * merge fewer segments (down to 1 at once, if that one has 70 // merge i [all...] |
/lucene-3.6.0/solr/core/src/test/org/apache/solr/analysis/ |
H A D | TestSlowSynonymFilter.java | 80 boolean merge = true; 81 map.add(strings("a b"), tokens("ab"), orig, merge); 82 map.add(strings("a c"), tokens("ac"), orig, merge); 83 map.add(strings("a"), tokens("aa"), orig, merge); 84 map.add(strings("b"), tokens("bb"), orig, merge); 85 map.add(strings("z x c v"), tokens("zxcv"), orig, merge); 86 map.add(strings("x c"), tokens("xc"), orig, merge); 98 map.add(strings("a b"), tokens("ab"), orig, merge); 99 map.add(strings("a b"), tokens("ab"), orig, merge); 105 map.add(strings("zoo"), tokens("zoo"), orig, merge); [all...] |
/lucene-3.6.0/solr/client/ruby/solr-ruby/lib/solr/request/ |
H A D | index_info.rb | 20 {:numTerms => 0}.merge(super.to_hash)
|
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/ |
H A D | TestMergeSchedulerExternal.java | 50 public MyMergeThread(IndexWriter writer, MergePolicy.OneMerge merge) throws IOException { argument 51 super(writer, merge); 57 protected MergeThread getMergeThread(IndexWriter writer, MergePolicy.OneMerge merge) throws IOException { argument 58 MergeThread thread = new MyMergeThread(writer, merge); 71 protected void doMerge(MergePolicy.OneMerge merge) throws IOException { argument 73 super.doMerge(merge); 83 throw new IOException("now failing during merge"); 117 public void merge(IndexWriter writer) throws CorruptIndexException, IOException { method in class:TestMergeSchedulerExternal.ReportingMergeScheduler 118 OneMerge merge = null; 119 while ((merge [all...] |
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/ |
H A D | TestMergeSchedulerExternal.java | 50 public MyMergeThread(IndexWriter writer, MergePolicy.OneMerge merge) throws IOException { argument 51 super(writer, merge); 57 protected MergeThread getMergeThread(IndexWriter writer, MergePolicy.OneMerge merge) throws IOException { argument 58 MergeThread thread = new MyMergeThread(writer, merge); 71 protected void doMerge(MergePolicy.OneMerge merge) throws IOException { argument 73 super.doMerge(merge); 83 throw new IOException("now failing during merge"); 117 public void merge(IndexWriter writer) throws CorruptIndexException, IOException { method in class:TestMergeSchedulerExternal.ReportingMergeScheduler 118 OneMerge merge = null; 119 while ((merge [all...] |
/lucene-3.6.0/lucene/contrib/facet/src/java/org/apache/lucene/facet/index/attributes/ |
H A D | CategoryProperty.java | 45 * The category property to merge. 49 public void merge(CategoryProperty other) method in interface:CategoryProperty
|
H A D | OrdinalProperty.java | 66 public void merge(CategoryProperty other) { method in class:OrdinalProperty
|
/lucene-3.6.0/lucene/contrib/facet/src/test/org/apache/lucene/facet/index/ |
H A D | DummyProperty.java | 40 public void merge(CategoryProperty other) { method in class:DummyProperty
|
/lucene-3.6.0/solr/client/ruby/solr-ruby/lib/solr/importer/ |
H A D | array_mapper.rb | 18 # TODO: make merge conflict handling configurable. as is, the last map fields win. 22 mapped_data.merge!(@mapping[i].map(data))
|
/lucene-3.6.0/lucene/contrib/facet/src/examples/org/apache/lucene/facet/example/merge/ |
H A D | TaxonomyMergeUtils.java | 1 package org.apache.lucene.facet.example.merge; 46 * {@link #merge(Directory, Directory, IndexWriter, DirectoryTaxonomyWriter)} 49 * @see #merge(Directory, Directory, IndexWriter, DirectoryTaxonomyWriter) 51 public static void merge(Directory srcIndexDir, Directory srcTaxDir, method in class:TaxonomyMergeUtils 56 merge(srcIndexDir, srcTaxDir, new MemoryOrdinalMap(), destIndexWriter, destTaxWriter); 65 * {@link #merge(Directory, Directory, DirectoryTaxonomyWriter.OrdinalMap, IndexWriter, DirectoryTaxonomyWriter)} 68 * @see #merge(Directory, Directory, DirectoryTaxonomyWriter.OrdinalMap, IndexWriter, DirectoryTaxonomyWriter) 70 public static void merge(Directory srcIndexDir, Directory srcTaxDir, method in class:TaxonomyMergeUtils 73 merge(srcIndexDir, srcTaxDir, new MemoryOrdinalMap(), destIndexWriter, destTaxWriter); 80 public static void merge(Director method in class:TaxonomyMergeUtils [all...] |
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/index/ |
H A D | TestForceMergeForever.java | 43 public void merge(MergePolicy.OneMerge merge) throws CorruptIndexException, IOException { argument 44 if (merge.maxNumSegments != -1 && (first || merge.segments.size() == 1)) { 47 System.out.println("TEST: maxNumSegments merge"); 51 super.merge(merge); 100 assertTrue("merge count is " + w.mergeCount.get(), w.mergeCount.get() <= 1);
|
H A D | TestDoc.java | 118 SegmentInfo siMerge = merge(si1, si2, "merge", false); 121 SegmentInfo siMerge2 = merge(si1, si2, "merge2", false); 124 SegmentInfo siMerge3 = merge(siMerge, siMerge2, "merge3", false); 153 siMerge = merge(si1, si2, "merge", true); 156 siMerge2 = merge(si1, si2, "merge2", true); 159 siMerge3 = merge(siMerge, siMerge2, "merge3", true); 182 private SegmentInfo merge(SegmentInfo si1, SegmentInfo si2, String merged, boolean useCompoundFile) method in class:TestDoc 191 merger.merge(); [all...] |
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/index/ |
H A D | TestForceMergeForever.java | 43 public void merge(MergePolicy.OneMerge merge) throws CorruptIndexException, IOException { argument 44 if (merge.maxNumSegments != -1 && (first || merge.segments.size() == 1)) { 47 System.out.println("TEST: maxNumSegments merge"); 51 super.merge(merge); 100 assertTrue("merge count is " + w.mergeCount.get(), w.mergeCount.get() <= 1);
|
H A D | TestDoc.java | 125 SegmentInfo siMerge = merge(si1, si2, "merge", false); 128 SegmentInfo siMerge2 = merge(si1, si2, "merge2", false); 131 SegmentInfo siMerge3 = merge(siMerge, siMerge2, "merge3", false); 159 siMerge = merge(si1, si2, "merge", true); 162 siMerge2 = merge(si1, si2, "merge2", true); 165 siMerge3 = merge(siMerge, siMerge2, "merge3", true); 188 private SegmentInfo merge(SegmentInfo si1, SegmentInfo si2, String merged, boolean useCompoundFile) method in class:TestDoc 197 merger.merge(); [all...] |
/lucene-3.6.0/lucene/contrib/analyzers/stempel/src/java/org/egothor/stemmer/ |
H A D | Optimizer2.java | 81 public Cell merge(Cell m, Cell e) { method in class:Optimizer2
|
/lucene-3.6.0/lucene/contrib/facet/src/java/org/apache/lucene/facet/enhancements/association/ |
H A D | AssociationIntProperty.java | 55 public void merge(CategoryProperty other) { method in class:AssociationIntProperty
|
H A D | AssociationFloatProperty.java | 58 public void merge(CategoryProperty other) { method in class:AssociationFloatProperty
|
/lucene-3.6.0/lucene/contrib/facet/src/test/org/apache/lucene/facet/enhancements/association/ |
H A D | AssociationPropertyTest.java | 37 aa1.merge(aa2); 47 aa1.merge(aa2);
|
/lucene-3.6.0/lucene/contrib/highlighter/src/java/org/apache/lucene/search/highlight/ |
H A D | TextFragment.java | 62 public void merge(TextFragment frag2) method in class:TextFragment
|