ParallelReader.h

Go to the documentation of this file.

// Copyright (c) 2009-2014 Alan Wright. All rights reserved.
// Distributable under the terms of either the Apache License (Version 2.0)
// or the GNU Lesser General Public License.

#ifndef PARALLELREADER_H
#define PARALLELREADER_H

#include "IndexReader.h"

namespace Lucene {

class LPPAPI ParallelReader : public IndexReader {
public:
    ParallelReader(bool closeSubReaders = true);

    virtual ~ParallelReader();

    LUCENE_CLASS(ParallelReader);

protected:
    Collection<IndexReaderPtr> readers;
    Collection<uint8_t> decrefOnClose; // remember which subreaders to decRef on close
    bool incRefReaders;
    MapStringIndexReader fieldToReader;
    MapIndexReaderSetString readerToFields;
    Collection<IndexReaderPtr> storedFieldReaders;

    int32_t _maxDoc;
    int32_t _numDocs;
    bool _hasDeletions;

public:
    void add(const IndexReaderPtr& reader);

    void add(const IndexReaderPtr& reader, bool ignoreStoredFields);

    virtual LuceneObjectPtr clone(const LuceneObjectPtr& other = LuceneObjectPtr());

    virtual IndexReaderPtr reopen();

    virtual int32_t numDocs();

    virtual int32_t maxDoc();

    virtual bool hasDeletions();

    virtual bool isDeleted(int32_t n);

    virtual DocumentPtr document(int32_t n, const FieldSelectorPtr& fieldSelector);

    virtual Collection<TermFreqVectorPtr> getTermFreqVectors(int32_t docNumber);

    virtual TermFreqVectorPtr getTermFreqVector(int32_t docNumber, const String& field);

    virtual void getTermFreqVector(int32_t docNumber, const String& field, const TermVectorMapperPtr& mapper);

    virtual void getTermFreqVector(int32_t docNumber, const TermVectorMapperPtr& mapper);

    virtual bool hasNorms(const String& field);

    virtual ByteArray norms(const String& field);

    virtual void norms(const String& field, ByteArray norms, int32_t offset);

    virtual TermEnumPtr terms();

    virtual TermEnumPtr terms(const TermPtr& t);

    virtual int32_t docFreq(const TermPtr& t);

    virtual TermDocsPtr termDocs(const TermPtr& term);

    virtual TermDocsPtr termDocs();

    virtual TermPositionsPtr termPositions(const TermPtr& term);

    virtual TermPositionsPtr termPositions();

    virtual bool isCurrent();

    virtual bool isOptimized();

    virtual int64_t getVersion();

    Collection<IndexReaderPtr> getSubReaders();

    virtual HashSet<String> getFieldNames(FieldOption fieldOption);

protected:
    IndexReaderPtr doReopen(bool doClone);

    virtual void doDelete(int32_t docNum);

    virtual void doUndeleteAll();

    virtual void doSetNorm(int32_t doc, const String& field, uint8_t value);

    virtual void doCommit(MapStringString commitUserData);

    virtual void doClose();

    friend class ParallelTermEnum;
    friend class ParallelTermDocs;
    friend class ParallelTermPositions;
};

}

#endif