Searched refs:merge (Results 1 - 25 of 68) sorted by relevance

123

/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/index/
H A DSerialMergeScheduler.java22 /** 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 DMergeScheduler.java32 public abstract void merge(IndexWriter writer) method in class:MergeScheduler
H A DConcurrentMergeScheduler.java29 /** 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 DIndexWriter.java371 * 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 DNoMergeScheduler.java45 public void merge(IndexWriter writer) throws CorruptIndexException, IOException {} method in class:NoMergeScheduler
H A DMergeDocIDRemapper.java20 /** 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 DTieredMergePolicy.java32 * 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 DTestSlowSynonymFilter.java80 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 Dindex_info.rb20 {:numTerms => 0}.merge(super.to_hash)
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/
H A DTestMergeSchedulerExternal.java50 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 DTestMergeSchedulerExternal.java50 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 DCategoryProperty.java45 * The category property to merge.
49 public void merge(CategoryProperty other) method in interface:CategoryProperty
H A DOrdinalProperty.java66 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 DDummyProperty.java40 public void merge(CategoryProperty other) { method in class:DummyProperty
/lucene-3.6.0/solr/client/ruby/solr-ruby/lib/solr/importer/
H A Darray_mapper.rb18 # 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 DTaxonomyMergeUtils.java1 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 DTestForceMergeForever.java43 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 DTestDoc.java118 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 DTestForceMergeForever.java43 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 DTestDoc.java125 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 DOptimizer2.java81 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 DAssociationIntProperty.java55 public void merge(CategoryProperty other) { method in class:AssociationIntProperty
H A DAssociationFloatProperty.java58 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 DAssociationPropertyTest.java37 aa1.merge(aa2);
47 aa1.merge(aa2);
/lucene-3.6.0/lucene/contrib/highlighter/src/java/org/apache/lucene/search/highlight/
H A DTextFragment.java62 public void merge(TextFragment frag2) method in class:TextFragment

Completed in 41 milliseconds

123