Examples of MultiReader

org.apache.accumulo.server.tabletserver.log.MultiReader
Provide simple Map.Reader methods over multiple Maps. Presently only supports next() and seek() and works on all the Map directories within a directory. The primary purpose of this class is to merge the results of multiple Reduce jobs that result in Map output files.
org.apache.accumulo.tserver.log.MultiReader
Provide simple Map.Reader methods over multiple Maps. Presently only supports next() and seek() and works on all the Map directories within a directory. The primary purpose of this class is to merge the results of multiple Reduce jobs that result in Map output files.
org.apache.lucene.index.MultiReader
An IndexReader which reads multiple indexes, appending their content.
org.codehaus.commons.io.MultiReader
Similar to {@link FilterReader}, but when the first delegate is at end-of-input, it continues with reading from the next delegate.
This {@link Reader} does not support MARK.

Examples of org.apache.lucene.index.MultiReader

    this.conf = conf;
    this.fs = FileSystem.get(conf);
    for (int i = 0; i < indexDirs.length; i++) {
      readers[i] = IndexReader.open(getDirectory(indexDirs[i]));
    }
    init(new MultiReader(readers), conf);
  }

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

        unsortedReaders = super.getMergeReaders();
        final AtomicReader atomicView;
        if (unsortedReaders.size() == 1) {
          atomicView = unsortedReaders.get(0);
        } else {
          final IndexReader multiReader = new MultiReader(unsortedReaders.toArray(new AtomicReader[unsortedReaders.size()]));
          atomicView = SlowCompositeReaderWrapper.wrap(multiReader);
        }
        docMap = sorter.sort(atomicView);
        sortedView = SortingAtomicReader.wrap(atomicView, docMap);
      }

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

    query.add(new TermQuery(new Term("field", "foo")), BooleanClause.Occur.MUST);
    WildcardQuery wildcardQuery = new WildcardQuery(new Term("field", "ba*"));
    wildcardQuery.setRewriteMethod(MultiTermQuery.SCORING_BOOLEAN_QUERY_REWRITE);
    query.add(wildcardQuery, BooleanClause.Occur.MUST_NOT);
    
    MultiReader multireader = new MultiReader(reader1, reader2);
    IndexSearcher searcher = newSearcher(multireader);
    assertEquals(0, searcher.search(query, 10).totalHits);
    
    final ExecutorService es = Executors.newCachedThreadPool(new NamedThreadFactory("NRT search threads"));
    searcher = new IndexSearcher(multireader, es);
    if (VERBOSE)
      System.out.println("rewritten form: " + searcher.rewrite(query));
    assertEquals(0, searcher.search(query, 10).totalHits);
    es.shutdown();
    es.awaitTermination(1, TimeUnit.SECONDS);


    multireader.close();
    reader1.close();
    reader2.close();
    dir1.close();
    dir2.close();
  }

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

            System.out.println("  searcher expired during mock reader init: " + see);
          }
          continue;
        }


        final IndexReader mockReader = new MultiReader(subs);
        final IndexSearcher mockSearcher = new IndexSearcher(mockReader);


        Query query;
        Sort sort;


        if (prevSearchState != null) {
          query = prevSearchState.query;
          sort = prevSearchState.sort;
        } else {
          if (terms == null && docCount > minDocsToMakeTerms) {
            // TODO: try to "focus" on high freq terms sometimes too
            // TODO: maybe also periodically reset the terms...?
            final TermsEnum termsEnum = MultiFields.getTerms(mockReader, "body").iterator(null);
            terms = new ArrayList<BytesRef>();
            while(termsEnum.next() != null) {
              terms.add(BytesRef.deepCopyOf(termsEnum.term()));
            }
            if (VERBOSE) {
              System.out.println("TEST: init terms: " + terms.size() + " terms");
            }
            if (terms.size() == 0) {
              terms = null;
            }
          }


          if (VERBOSE) {
            System.out.println("  maxDoc=" + mockReader.maxDoc());
          }


          if (terms != null) {
            if (random().nextBoolean()) {
              query = new TermQuery(new Term("body", terms.get(random().nextInt(terms.size()))));

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

   * Test that complements works with MultiReader
   */
  @Test
  public void testComplementsWithMultiReader() throws Exception {
    final IndexReader origReader = indexReader; 
    indexReader = new MultiReader(origReader);
    try {
      doTestComplements();
    } finally {
      indexReader = origReader;
    }

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

    }
    
    IndexWriter writer = new IndexWriter(indexDir, newIndexWriterConfig(TEST_VERSION_CURRENT, null));
    writer.deleteAll();
    try {
      writer.addIndexes(new MultiReader(wrappedLeaves));
      writer.commit();
    } finally {
      reader.close();
      writer.close();
    }

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

    d.close();
  }
  
  /** test sorts when there's nothing in the index */
  public void testEmptyIndex() throws Exception {
    IndexSearcher empty = newSearcher(new MultiReader());
    Query query = new TermQuery(new Term("contents", "foo"));
  
    Sort sort = new Sort();
    TopDocs td = empty.search(query, null, 10, sort, true, true);
    assertEquals(0, td.totalHits);

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

    AtomicReader wrappedLeaves[] = new AtomicReader[numReaders];
    for (int i = 0; i < numReaders; i++) {
      wrappedLeaves[i] = new OrdinalMappingAtomicReader(leaves.get(i).reader(), ordinalMap, params);
    }
    try {
      destIndexWriter.addIndexes(new MultiReader(wrappedLeaves));
      
      // commit changes to taxonomy and index respectively.
      destTaxWriter.commit();
      destIndexWriter.commit();
    } finally {

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

    IndexReader in;
    if (inputs.size() == 1) {
      in = inputs.get(0);
    } else {
      //in = new MultiReader((IndexReader[])inputs.toArray(new IndexReader[inputs.size()]), true); 
      in = new MultiReader((IndexReader[])inputs.toArray(new IndexReader[inputs.size()]));
    }
    if (in.hasDeletions()) {
      System.err.println("WARN: input index(es) with deletions - document ID-s will NOT be preserved!");
    }
    IndexReader pruning = null;

View Full Code Here

Examples of org.apache.lucene.index.MultiReader

    this.conf = conf;
    this.fs = FileSystem.get(conf);
    for (int i = 0; i < indexDirs.length; i++) {
      readers[i] = IndexReader.open(getDirectory(indexDirs[i]));
    }
    init(new MultiReader(readers), conf, blacklistFile);
  }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.