Return-Path:
X-Original-To: apmail-lucene-commits-archive@www.apache.org
Delivered-To: apmail-lucene-commits-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
by minotaur.apache.org (Postfix) with SMTP id DEDAA11F26
for ;
Wed, 24 Sep 2014 01:21:42 +0000 (UTC)
Received: (qmail 34260 invoked by uid 500); 24 Sep 2014 01:21:42 -0000
Mailing-List: contact commits-help@lucene.apache.org; run by ezmlm
Precedence: bulk
List-Help:
List-Unsubscribe:
List-Post:
List-Id:
Reply-To: dev@lucene.apache.org
Delivered-To: mailing list commits@lucene.apache.org
Received: (qmail 34251 invoked by uid 99); 24 Sep 2014 01:21:42 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Sep 2014 01:21:42 +0000
X-ASF-Spam-Status: No, hits=-2000.0 required=5.0
tests=ALL_TRUSTED
X-Spam-Check-By: apache.org
Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4)
by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 24 Sep 2014 01:21:09 +0000
Received: from eris.apache.org (localhost [127.0.0.1])
by eris.apache.org (Postfix) with ESMTP id 2510A23889E1;
Wed, 24 Sep 2014 01:21:06 +0000 (UTC)
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r1627188 [3/13] - in /lucene/dev/branches/branch_5x: ./
dev-tools/ lucene/ lucene/analysis/
lucene/analysis/common/src/java/org/apache/lucene/analysis/miscellaneous/
lucene/analysis/common/src/java/org/apache/lucene/analysis/standard/std40/...
Date: Wed, 24 Sep 2014 01:20:45 -0000
To: commits@lucene.apache.org
From: rjernst@apache.org
X-Mailer: svnmailer-1.0.9
Message-Id: <20140924012106.2510A23889E1@eris.apache.org>
X-Virus-Checked: Checked by ClamAV on apache.org
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiDocValues.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiDocValues.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiDocValues.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiDocValues.java Wed Sep 24 01:20:36 2014
@@ -57,11 +57,11 @@ public class MultiDocValues {
/** Returns a NumericDocValues for a reader's norms (potentially merging on-the-fly).
*
* This is a slow way to access normalization values. Instead, access them per-segment
- * with {@link AtomicReader#getNormValues(String)}
+ * with {@link LeafReader#getNormValues(String)}
*
*/
public static NumericDocValues getNormValues(final IndexReader r, final String field) throws IOException {
- final List leaves = r.leaves();
+ final List leaves = r.leaves();
final int size = leaves.size();
if (size == 0) {
return null;
@@ -77,7 +77,7 @@ public class MultiDocValues {
final NumericDocValues[] values = new NumericDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = leaves.get(i);
+ LeafReaderContext context = leaves.get(i);
NumericDocValues v = context.reader().getNormValues(field);
if (v == null) {
v = DocValues.emptyNumeric();
@@ -103,11 +103,11 @@ public class MultiDocValues {
/** Returns a NumericDocValues for a reader's docvalues (potentially merging on-the-fly)
*
* This is a slow way to access numeric values. Instead, access them per-segment
- * with {@link AtomicReader#getNumericDocValues(String)}
+ * with {@link LeafReader#getNumericDocValues(String)}
*
* */
public static NumericDocValues getNumericValues(final IndexReader r, final String field) throws IOException {
- final List leaves = r.leaves();
+ final List leaves = r.leaves();
final int size = leaves.size();
if (size == 0) {
return null;
@@ -119,7 +119,7 @@ public class MultiDocValues {
final NumericDocValues[] values = new NumericDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = leaves.get(i);
+ LeafReaderContext context = leaves.get(i);
NumericDocValues v = context.reader().getNumericDocValues(field);
if (v == null) {
v = DocValues.emptyNumeric();
@@ -147,11 +147,11 @@ public class MultiDocValues {
/** Returns a Bits for a reader's docsWithField (potentially merging on-the-fly)
*
* This is a slow way to access this bitset. Instead, access them per-segment
- * with {@link AtomicReader#getDocsWithField(String)}
+ * with {@link LeafReader#getDocsWithField(String)}
*
* */
public static Bits getDocsWithField(final IndexReader r, final String field) throws IOException {
- final List leaves = r.leaves();
+ final List leaves = r.leaves();
final int size = leaves.size();
if (size == 0) {
return null;
@@ -164,7 +164,7 @@ public class MultiDocValues {
final Bits[] values = new Bits[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = leaves.get(i);
+ LeafReaderContext context = leaves.get(i);
Bits v = context.reader().getDocsWithField(field);
if (v == null) {
v = new Bits.MatchNoBits(context.reader().maxDoc());
@@ -192,11 +192,11 @@ public class MultiDocValues {
/** Returns a BinaryDocValues for a reader's docvalues (potentially merging on-the-fly)
*
* This is a slow way to access binary values. Instead, access them per-segment
- * with {@link AtomicReader#getBinaryDocValues(String)}
+ * with {@link LeafReader#getBinaryDocValues(String)}
*
*/
public static BinaryDocValues getBinaryValues(final IndexReader r, final String field) throws IOException {
- final List leaves = r.leaves();
+ final List leaves = r.leaves();
final int size = leaves.size();
if (size == 0) {
@@ -209,7 +209,7 @@ public class MultiDocValues {
final BinaryDocValues[] values = new BinaryDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = leaves.get(i);
+ LeafReaderContext context = leaves.get(i);
BinaryDocValues v = context.reader().getBinaryDocValues(field);
if (v == null) {
v = DocValues.emptyBinary();
@@ -237,11 +237,11 @@ public class MultiDocValues {
/** Returns a SortedNumericDocValues for a reader's docvalues (potentially merging on-the-fly)
*
* This is a slow way to access sorted numeric values. Instead, access them per-segment
- * with {@link AtomicReader#getSortedNumericDocValues(String)}
+ * with {@link LeafReader#getSortedNumericDocValues(String)}
*
* */
public static SortedNumericDocValues getSortedNumericValues(final IndexReader r, final String field) throws IOException {
- final List leaves = r.leaves();
+ final List leaves = r.leaves();
final int size = leaves.size();
if (size == 0) {
return null;
@@ -253,7 +253,7 @@ public class MultiDocValues {
final SortedNumericDocValues[] values = new SortedNumericDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = leaves.get(i);
+ LeafReaderContext context = leaves.get(i);
SortedNumericDocValues v = context.reader().getSortedNumericDocValues(field);
if (v == null) {
v = DocValues.emptySortedNumeric(context.reader().maxDoc());
@@ -294,11 +294,11 @@ public class MultiDocValues {
/** Returns a SortedDocValues for a reader's docvalues (potentially doing extremely slow things).
*
* This is an extremely slow way to access sorted values. Instead, access them per-segment
- * with {@link AtomicReader#getSortedDocValues(String)}
+ * with {@link LeafReader#getSortedDocValues(String)}
*
*/
public static SortedDocValues getSortedValues(final IndexReader r, final String field) throws IOException {
- final List leaves = r.leaves();
+ final List leaves = r.leaves();
final int size = leaves.size();
if (size == 0) {
@@ -311,7 +311,7 @@ public class MultiDocValues {
final SortedDocValues[] values = new SortedDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = leaves.get(i);
+ LeafReaderContext context = leaves.get(i);
SortedDocValues v = context.reader().getSortedDocValues(field);
if (v == null) {
v = DocValues.emptySorted();
@@ -334,11 +334,11 @@ public class MultiDocValues {
/** Returns a SortedSetDocValues for a reader's docvalues (potentially doing extremely slow things).
*
* This is an extremely slow way to access sorted values. Instead, access them per-segment
- * with {@link AtomicReader#getSortedSetDocValues(String)}
+ * with {@link LeafReader#getSortedSetDocValues(String)}
*
*/
public static SortedSetDocValues getSortedSetValues(final IndexReader r, final String field) throws IOException {
- final List leaves = r.leaves();
+ final List leaves = r.leaves();
final int size = leaves.size();
if (size == 0) {
@@ -351,7 +351,7 @@ public class MultiDocValues {
final SortedSetDocValues[] values = new SortedSetDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = leaves.get(i);
+ LeafReaderContext context = leaves.get(i);
SortedSetDocValues v = context.reader().getSortedSetDocValues(field);
if (v == null) {
v = DocValues.emptySortedSet();
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiFields.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiFields.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiFields.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/MultiFields.java Wed Sep 24 01:20:36 2014
@@ -60,7 +60,7 @@ public final class MultiFields extends F
* It's better to get the sub-readers and iterate through them
* yourself. */
public static Fields getFields(IndexReader reader) throws IOException {
- final List leaves = reader.leaves();
+ final List leaves = reader.leaves();
switch (leaves.size()) {
case 0:
// no fields
@@ -71,8 +71,8 @@ public final class MultiFields extends F
default:
final List fields = new ArrayList<>();
final List slices = new ArrayList<>();
- for (final AtomicReaderContext ctx : leaves) {
- final AtomicReader r = ctx.reader();
+ for (final LeafReaderContext ctx : leaves) {
+ final LeafReader r = ctx.reader();
final Fields f = r.fields();
if (f != null) {
fields.add(f);
@@ -101,7 +101,7 @@ public final class MultiFields extends F
* yourself. */
public static Bits getLiveDocs(IndexReader reader) {
if (reader.hasDeletions()) {
- final List leaves = reader.leaves();
+ final List leaves = reader.leaves();
final int size = leaves.size();
assert size > 0 : "A reader with deletions must have at least one leave";
if (size == 1) {
@@ -111,7 +111,7 @@ public final class MultiFields extends F
final int[] starts = new int[size + 1];
for (int i = 0; i < size; i++) {
// record all liveDocs, even if they are null
- final AtomicReaderContext ctx = leaves.get(i);
+ final LeafReaderContext ctx = leaves.get(i);
liveDocs[i] = ctx.reader().getLiveDocs();
starts[i] = ctx.docBase;
}
@@ -254,7 +254,7 @@ public final class MultiFields extends F
*/
public static FieldInfos getMergedFieldInfos(IndexReader reader) {
final FieldInfos.Builder builder = new FieldInfos.Builder();
- for(final AtomicReaderContext ctx : reader.leaves()) {
+ for(final LeafReaderContext ctx : reader.leaves()) {
builder.add(ctx.reader().getFieldInfos());
}
return builder.finish();
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelCompositeReader.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelCompositeReader.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelCompositeReader.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelCompositeReader.java Wed Sep 24 01:20:36 2014
@@ -96,7 +96,7 @@ public class ParallelCompositeReader ext
for (int i = 0; i < noSubs; i++) {
final IndexReader r = firstSubReaders.get(i);
childMaxDoc[i] = r.maxDoc();
- childAtomic[i] = r instanceof AtomicReader;
+ childAtomic[i] = r instanceof LeafReader;
}
validate(readers, maxDoc, childMaxDoc, childAtomic);
validate(storedFieldsReaders, maxDoc, childMaxDoc, childAtomic);
@@ -104,18 +104,18 @@ public class ParallelCompositeReader ext
// hierarchically build the same subreader structure as the first CompositeReader with Parallel*Readers:
final IndexReader[] subReaders = new IndexReader[noSubs];
for (int i = 0; i < subReaders.length; i++) {
- if (firstSubReaders.get(i) instanceof AtomicReader) {
- final AtomicReader[] atomicSubs = new AtomicReader[readers.length];
+ if (firstSubReaders.get(i) instanceof LeafReader) {
+ final LeafReader[] atomicSubs = new LeafReader[readers.length];
for (int j = 0; j < readers.length; j++) {
- atomicSubs[j] = (AtomicReader) readers[j].getSequentialSubReaders().get(i);
+ atomicSubs[j] = (LeafReader) readers[j].getSequentialSubReaders().get(i);
}
- final AtomicReader[] storedSubs = new AtomicReader[storedFieldsReaders.length];
+ final LeafReader[] storedSubs = new LeafReader[storedFieldsReaders.length];
for (int j = 0; j < storedFieldsReaders.length; j++) {
- storedSubs[j] = (AtomicReader) storedFieldsReaders[j].getSequentialSubReaders().get(i);
+ storedSubs[j] = (LeafReader) storedFieldsReaders[j].getSequentialSubReaders().get(i);
}
// We pass true for closeSubs and we prevent closing of subreaders in doClose():
// By this the synthetic throw-away readers used here are completely invisible to ref-counting
- subReaders[i] = new ParallelAtomicReader(true, atomicSubs, storedSubs) {
+ subReaders[i] = new ParallelLeafReader(true, atomicSubs, storedSubs) {
@Override
protected void doClose() {}
};
@@ -157,7 +157,7 @@ public class ParallelCompositeReader ext
if (r.maxDoc() != childMaxDoc[subIDX]) {
throw new IllegalArgumentException("All readers must have same corresponding subReader maxDoc");
}
- if (!(childAtomic[subIDX] ? (r instanceof AtomicReader) : (r instanceof CompositeReader))) {
+ if (!(childAtomic[subIDX] ? (r instanceof LeafReader) : (r instanceof CompositeReader))) {
throw new IllegalArgumentException("All readers must have same corresponding subReader types (atomic or composite)");
}
}
Copied: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelLeafReader.java (from r1627177, lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelAtomicReader.java)
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelLeafReader.java?p2=lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelLeafReader.java&p1=lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelAtomicReader.java&r1=1627177&r2=1627188&rev=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelAtomicReader.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ParallelLeafReader.java Wed Sep 24 01:20:36 2014
@@ -29,7 +29,7 @@ import java.util.TreeMap;
import org.apache.lucene.util.Bits;
-/** An {@link AtomicReader} which reads multiple, parallel indexes. Each index
+/** An {@link LeafReader} which reads multiple, parallel indexes. Each index
* added must have the same number of documents, but typically each contains
* different fields. Deletions are taken from the first reader.
* Each document contains the union of the fields of all documents
@@ -47,41 +47,41 @@ import org.apache.lucene.util.Bits;
* same order to the other indexes. Failure to do so will result in
* undefined behavior.
*/
-public class ParallelAtomicReader extends AtomicReader {
+public class ParallelLeafReader extends LeafReader {
private final FieldInfos fieldInfos;
private final ParallelFields fields = new ParallelFields();
- private final AtomicReader[] parallelReaders, storedFieldsReaders;
- private final Set completeReaderSet =
- Collections.newSetFromMap(new IdentityHashMap());
+ private final LeafReader[] parallelReaders, storedFieldsReaders;
+ private final Set completeReaderSet =
+ Collections.newSetFromMap(new IdentityHashMap());
private final boolean closeSubReaders;
private final int maxDoc, numDocs;
private final boolean hasDeletions;
- private final SortedMap fieldToReader = new TreeMap<>();
- private final SortedMap tvFieldToReader = new TreeMap<>();
+ private final SortedMap fieldToReader = new TreeMap<>();
+ private final SortedMap tvFieldToReader = new TreeMap<>();
/** Create a ParallelAtomicReader based on the provided
* readers; auto-closes the given readers on {@link #close()}. */
- public ParallelAtomicReader(AtomicReader... readers) throws IOException {
+ public ParallelLeafReader(LeafReader... readers) throws IOException {
this(true, readers);
}
/** Create a ParallelAtomicReader based on the provided
* readers. */
- public ParallelAtomicReader(boolean closeSubReaders, AtomicReader... readers) throws IOException {
+ public ParallelLeafReader(boolean closeSubReaders, LeafReader... readers) throws IOException {
this(closeSubReaders, readers, readers);
}
/** Expert: create a ParallelAtomicReader based on the provided
* readers and storedFieldReaders; when a document is
* loaded, only storedFieldsReaders will be used. */
- public ParallelAtomicReader(boolean closeSubReaders, AtomicReader[] readers, AtomicReader[] storedFieldsReaders) throws IOException {
+ public ParallelLeafReader(boolean closeSubReaders, LeafReader[] readers, LeafReader[] storedFieldsReaders) throws IOException {
this.closeSubReaders = closeSubReaders;
if (readers.length == 0 && storedFieldsReaders.length > 0)
throw new IllegalArgumentException("There must be at least one main reader if storedFieldsReaders are used.");
this.parallelReaders = readers.clone();
this.storedFieldsReaders = storedFieldsReaders.clone();
if (parallelReaders.length > 0) {
- final AtomicReader first = parallelReaders[0];
+ final LeafReader first = parallelReaders[0];
this.maxDoc = first.maxDoc();
this.numDocs = first.numDocs();
this.hasDeletions = first.hasDeletions();
@@ -93,7 +93,7 @@ public class ParallelAtomicReader extend
Collections.addAll(completeReaderSet, this.storedFieldsReaders);
// check compatibility:
- for(AtomicReader reader : completeReaderSet) {
+ for(LeafReader reader : completeReaderSet) {
if (reader.maxDoc() != maxDoc) {
throw new IllegalArgumentException("All readers must have same maxDoc: "+maxDoc+"!="+reader.maxDoc());
}
@@ -102,7 +102,7 @@ public class ParallelAtomicReader extend
// TODO: make this read-only in a cleaner way?
FieldInfos.Builder builder = new FieldInfos.Builder();
// build FieldInfos and fieldToReader map:
- for (final AtomicReader reader : this.parallelReaders) {
+ for (final LeafReader reader : this.parallelReaders) {
final FieldInfos readerFieldInfos = reader.getFieldInfos();
for (FieldInfo fieldInfo : readerFieldInfos) {
// NOTE: first reader having a given field "wins":
@@ -118,7 +118,7 @@ public class ParallelAtomicReader extend
fieldInfos = builder.finish();
// build Fields instance
- for (final AtomicReader reader : this.parallelReaders) {
+ for (final LeafReader reader : this.parallelReaders) {
final Fields readerFields = reader.fields();
if (readerFields != null) {
for (String field : readerFields) {
@@ -131,7 +131,7 @@ public class ParallelAtomicReader extend
}
// do this finally so any Exceptions occurred before don't affect refcounts:
- for (AtomicReader reader : completeReaderSet) {
+ for (LeafReader reader : completeReaderSet) {
if (!closeSubReaders) {
reader.incRef();
}
@@ -142,7 +142,7 @@ public class ParallelAtomicReader extend
@Override
public String toString() {
final StringBuilder buffer = new StringBuilder("ParallelAtomicReader(");
- for (final Iterator iter = completeReaderSet.iterator(); iter.hasNext();) {
+ for (final Iterator iter = completeReaderSet.iterator(); iter.hasNext();) {
buffer.append(iter.next());
if (iter.hasNext()) buffer.append(", ");
}
@@ -226,7 +226,7 @@ public class ParallelAtomicReader extend
@Override
public void document(int docID, StoredFieldVisitor visitor) throws IOException {
ensureOpen();
- for (final AtomicReader reader: storedFieldsReaders) {
+ for (final LeafReader reader: storedFieldsReaders) {
reader.document(docID, visitor);
}
}
@@ -235,7 +235,7 @@ public class ParallelAtomicReader extend
public Fields getTermVectors(int docID) throws IOException {
ensureOpen();
ParallelFields fields = null;
- for (Map.Entry ent : tvFieldToReader.entrySet()) {
+ for (Map.Entry ent : tvFieldToReader.entrySet()) {
String fieldName = ent.getKey();
Terms vector = ent.getValue().getTermVector(docID, fieldName);
if (vector != null) {
@@ -252,7 +252,7 @@ public class ParallelAtomicReader extend
@Override
protected synchronized void doClose() throws IOException {
IOException ioe = null;
- for (AtomicReader reader : completeReaderSet) {
+ for (LeafReader reader : completeReaderSet) {
try {
if (closeSubReaders) {
reader.close();
@@ -270,49 +270,49 @@ public class ParallelAtomicReader extend
@Override
public NumericDocValues getNumericDocValues(String field) throws IOException {
ensureOpen();
- AtomicReader reader = fieldToReader.get(field);
+ LeafReader reader = fieldToReader.get(field);
return reader == null ? null : reader.getNumericDocValues(field);
}
@Override
public BinaryDocValues getBinaryDocValues(String field) throws IOException {
ensureOpen();
- AtomicReader reader = fieldToReader.get(field);
+ LeafReader reader = fieldToReader.get(field);
return reader == null ? null : reader.getBinaryDocValues(field);
}
@Override
public SortedDocValues getSortedDocValues(String field) throws IOException {
ensureOpen();
- AtomicReader reader = fieldToReader.get(field);
+ LeafReader reader = fieldToReader.get(field);
return reader == null ? null : reader.getSortedDocValues(field);
}
@Override
public SortedNumericDocValues getSortedNumericDocValues(String field) throws IOException {
ensureOpen();
- AtomicReader reader = fieldToReader.get(field);
+ LeafReader reader = fieldToReader.get(field);
return reader == null ? null : reader.getSortedNumericDocValues(field);
}
@Override
public SortedSetDocValues getSortedSetDocValues(String field) throws IOException {
ensureOpen();
- AtomicReader reader = fieldToReader.get(field);
+ LeafReader reader = fieldToReader.get(field);
return reader == null ? null : reader.getSortedSetDocValues(field);
}
@Override
public Bits getDocsWithField(String field) throws IOException {
ensureOpen();
- AtomicReader reader = fieldToReader.get(field);
+ LeafReader reader = fieldToReader.get(field);
return reader == null ? null : reader.getDocsWithField(field);
}
@Override
public NumericDocValues getNormValues(String field) throws IOException {
ensureOpen();
- AtomicReader reader = fieldToReader.get(field);
+ LeafReader reader = fieldToReader.get(field);
NumericDocValues values = reader == null ? null : reader.getNormValues(field);
return values;
}
@@ -320,7 +320,7 @@ public class ParallelAtomicReader extend
@Override
public void checkIntegrity() throws IOException {
ensureOpen();
- for (AtomicReader reader : completeReaderSet) {
+ for (LeafReader reader : completeReaderSet) {
reader.checkIntegrity();
}
}
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ReaderUtil.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ReaderUtil.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ReaderUtil.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/ReaderUtil.java Wed Sep 24 01:20:36 2014
@@ -70,7 +70,7 @@ public final class ReaderUtil {
* Returns index of the searcher/reader for document n
in the
* array used to construct this searcher/reader.
*/
- public static int subIndex(int n, List leaves) { // find
+ public static int subIndex(int n, List leaves) { // find
// searcher/reader for doc n:
int size = leaves.size();
int lo = 0; // search starts array
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentCoreReaders.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentCoreReaders.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentCoreReaders.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentCoreReaders.java Wed Sep 24 01:20:36 2014
@@ -26,13 +26,12 @@ import java.util.Set;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.lucene.codecs.Codec;
-import org.apache.lucene.codecs.DocValuesProducer;
import org.apache.lucene.codecs.FieldsProducer;
import org.apache.lucene.codecs.NormsProducer;
import org.apache.lucene.codecs.PostingsFormat;
import org.apache.lucene.codecs.StoredFieldsReader;
import org.apache.lucene.codecs.TermVectorsReader;
-import org.apache.lucene.index.AtomicReader.CoreClosedListener;
+import org.apache.lucene.index.LeafReader.CoreClosedListener;
import org.apache.lucene.store.AlreadyClosedException;
import org.apache.lucene.store.CompoundFileDirectory;
import org.apache.lucene.store.Directory;
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentMerger.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentMerger.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentMerger.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentMerger.java Wed Sep 24 01:20:36 2014
@@ -50,11 +50,11 @@ final class SegmentMerger {
private final FieldInfos.Builder fieldInfosBuilder;
// note, just like in codec apis Directory 'dir' is NOT the same as segmentInfo.dir!!
- SegmentMerger(List readers, SegmentInfo segmentInfo, InfoStream infoStream, Directory dir,
+ SegmentMerger(List readers, SegmentInfo segmentInfo, InfoStream infoStream, Directory dir,
MergeState.CheckAbort checkAbort, FieldInfos.FieldNumbers fieldNumbers, IOContext context, boolean validate) throws IOException {
// validate incoming readers
if (validate) {
- for (AtomicReader reader : readers) {
+ for (LeafReader reader : readers) {
reader.checkIntegrity();
}
}
@@ -182,7 +182,7 @@ final class SegmentMerger {
}
public void mergeFieldInfos() throws IOException {
- for (AtomicReader reader : mergeState.readers) {
+ for (LeafReader reader : mergeState.readers) {
FieldInfos readerFieldInfos = reader.getFieldInfos();
for (FieldInfo fi : readerFieldInfos) {
fieldInfosBuilder.add(fi);
@@ -250,7 +250,7 @@ final class SegmentMerger {
int i = 0;
while(i < mergeState.readers.size()) {
- final AtomicReader reader = mergeState.readers.get(i);
+ final LeafReader reader = mergeState.readers.get(i);
mergeState.docBase[i] = docBase;
final MergeState.DocMap docMap = MergeState.DocMap.build(reader);
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentReader.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentReader.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentReader.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SegmentReader.java Wed Sep 24 01:20:36 2014
@@ -50,7 +50,7 @@ import org.apache.lucene.util.RamUsageEs
* may share the same core data.
* @lucene.experimental
*/
-public final class SegmentReader extends AtomicReader implements Accountable {
+public final class SegmentReader extends LeafReader implements Accountable {
private static final long BASE_RAM_BYTES_USED =
RamUsageEstimator.shallowSizeOfInstance(SegmentReader.class)
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SimpleMergedSegmentWarmer.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SimpleMergedSegmentWarmer.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SimpleMergedSegmentWarmer.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SimpleMergedSegmentWarmer.java Wed Sep 24 01:20:36 2014
@@ -38,7 +38,7 @@ public class SimpleMergedSegmentWarmer e
}
@Override
- public void warm(AtomicReader reader) throws IOException {
+ public void warm(LeafReader reader) throws IOException {
long startTime = System.currentTimeMillis();
int indexedCount = 0;
int docValuesCount = 0;
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SlowCompositeReaderWrapper.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SlowCompositeReaderWrapper.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SlowCompositeReaderWrapper.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/SlowCompositeReaderWrapper.java Wed Sep 24 01:20:36 2014
@@ -23,12 +23,10 @@ import java.util.Map;
import org.apache.lucene.util.Bits;
-import org.apache.lucene.index.DirectoryReader; // javadoc
import org.apache.lucene.index.FieldInfo.DocValuesType;
import org.apache.lucene.index.MultiDocValues.MultiSortedDocValues;
import org.apache.lucene.index.MultiDocValues.MultiSortedSetDocValues;
import org.apache.lucene.index.MultiDocValues.OrdinalMap;
-import org.apache.lucene.index.MultiReader; // javadoc
/**
* This class forces a composite reader (eg a {@link
@@ -45,22 +43,22 @@ import org.apache.lucene.index.MultiRead
* atomic leaves and then operate per-AtomicReader,
* instead of using this class.
*/
-public final class SlowCompositeReaderWrapper extends AtomicReader {
+public final class SlowCompositeReaderWrapper extends LeafReader {
private final CompositeReader in;
private final Fields fields;
private final Bits liveDocs;
- /** This method is sugar for getting an {@link AtomicReader} from
+ /** This method is sugar for getting an {@link LeafReader} from
* an {@link IndexReader} of any kind. If the reader is already atomic,
* it is returned unchanged, otherwise wrapped by this class.
*/
- public static AtomicReader wrap(IndexReader reader) throws IOException {
+ public static LeafReader wrap(IndexReader reader) throws IOException {
if (reader instanceof CompositeReader) {
return new SlowCompositeReaderWrapper((CompositeReader) reader);
} else {
- assert reader instanceof AtomicReader;
- return (AtomicReader) reader;
+ assert reader instanceof LeafReader;
+ return (LeafReader) reader;
}
}
@@ -143,7 +141,7 @@ public final class SlowCompositeReaderWr
final SortedDocValues[] values = new SortedDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = in.leaves().get(i);
+ LeafReaderContext context = in.leaves().get(i);
SortedDocValues v = context.reader().getSortedDocValues(field);
if (v == null) {
v = DocValues.emptySorted();
@@ -182,7 +180,7 @@ public final class SlowCompositeReaderWr
final SortedSetDocValues[] values = new SortedSetDocValues[size];
final int[] starts = new int[size+1];
for (int i = 0; i < size; i++) {
- AtomicReaderContext context = in.leaves().get(i);
+ LeafReaderContext context = in.leaves().get(i);
SortedSetDocValues v = context.reader().getSortedSetDocValues(field);
if (v == null) {
v = DocValues.emptySortedSet();
@@ -259,7 +257,7 @@ public final class SlowCompositeReaderWr
@Override
public void checkIntegrity() throws IOException {
ensureOpen();
- for (AtomicReaderContext ctx : in.leaves()) {
+ for (LeafReaderContext ctx : in.leaves()) {
ctx.reader().checkIntegrity();
}
}
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/StandardDirectoryReader.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/StandardDirectoryReader.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/StandardDirectoryReader.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/StandardDirectoryReader.java Wed Sep 24 01:20:36 2014
@@ -37,7 +37,7 @@ final class StandardDirectoryReader exte
private final boolean applyAllDeletes;
/** called only from static open() methods */
- StandardDirectoryReader(Directory directory, AtomicReader[] readers, IndexWriter writer,
+ StandardDirectoryReader(Directory directory, LeafReader[] readers, IndexWriter writer,
SegmentInfos sis, boolean applyAllDeletes) {
super(directory, readers);
this.writer = writer;
@@ -128,7 +128,7 @@ final class StandardDirectoryReader exte
}
/** This constructor is only used for {@link #doOpenIfChanged(SegmentInfos)} */
- private static DirectoryReader open(Directory directory, SegmentInfos infos, List extends AtomicReader> oldReaders) throws IOException {
+ private static DirectoryReader open(Directory directory, SegmentInfos infos, List extends LeafReader> oldReaders) throws IOException {
// we put the old SegmentReaders in a map, that allows us
// to lookup a reader using its segment name
@@ -234,7 +234,7 @@ final class StandardDirectoryReader exte
if (writer != null) {
buffer.append(":nrt");
}
- for (final AtomicReader r : getSequentialSubReaders()) {
+ for (final LeafReader r : getSequentialSubReaders()) {
buffer.append(' ');
buffer.append(r);
}
@@ -351,7 +351,7 @@ final class StandardDirectoryReader exte
@Override
protected void doClose() throws IOException {
Throwable firstExc = null;
- for (final AtomicReader r : getSequentialSubReaders()) {
+ for (final LeafReader r : getSequentialSubReaders()) {
// try to close each reader, even if an exception is thrown
try {
r.decRef();
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/TermContext.java
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/TermContext.java?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/TermContext.java (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/TermContext.java Wed Sep 24 01:20:36 2014
@@ -85,7 +85,7 @@ public final class TermContext {
final BytesRef bytes = term.bytes();
final TermContext perReaderTermState = new TermContext(context);
//if (DEBUG) System.out.println("prts.build term=" + term);
- for (final AtomicReaderContext ctx : context.leaves()) {
+ for (final LeafReaderContext ctx : context.leaves()) {
//if (DEBUG) System.out.println(" r=" + leaves[i].reader);
final Fields fields = ctx.reader().fields();
if (fields != null) {
Modified: lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/package.html
URL: http://svn.apache.org/viewvc/lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/package.html?rev=1627188&r1=1627187&r2=1627188&view=diff
==============================================================================
--- lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/package.html (original)
+++ lucene/dev/branches/branch_5x/lucene/core/src/java/org/apache/lucene/index/package.html Wed Sep 24 01:20:36 2014
@@ -254,7 +254,7 @@ its {@link org.apache.lucene.search.simi
Additional user-supplied statistics can be added to the document as DocValues fields and
-accessed via {@link org.apache.lucene.index.AtomicReader#getNumericDocValues}.
+accessed via {@link org.apache.lucene.index.LeafReader#getNumericDocValues}.