Index: src/java/org/apache/lucene/analysis/ASCIIFoldingFilter.java
===================================================================
--- src/java/org/apache/lucene/analysis/ASCIIFoldingFilter.java (revision 830378)
+++ src/java/org/apache/lucene/analysis/ASCIIFoldingFilter.java (working copy)
@@ -67,6 +67,7 @@
private int outputPos;
private TermAttribute termAtt;
+ @Override
public boolean incrementToken() throws IOException {
if (input.incrementToken()) {
final char[] buffer = termAtt.termBuffer();
Index: src/java/org/apache/lucene/analysis/BaseCharFilter.java
===================================================================
--- src/java/org/apache/lucene/analysis/BaseCharFilter.java (revision 830378)
+++ src/java/org/apache/lucene/analysis/BaseCharFilter.java (working copy)
@@ -44,6 +44,7 @@
* recently added position, as it's a simple linear
* search backwards through all offset corrections added
* by {@link #addOffCorrectMap}. */
+ @Override
protected int correct(int currentOff) {
if (pcmList == null || pcmList.isEmpty()) {
return currentOff;
@@ -78,6 +79,7 @@
this.cumulativeDiff = cumulativeDiff;
}
+ @Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append('(');
Index: src/java/org/apache/lucene/analysis/CachingTokenFilter.java
===================================================================
--- src/java/org/apache/lucene/analysis/CachingTokenFilter.java (revision 830378)
+++ src/java/org/apache/lucene/analysis/CachingTokenFilter.java (working copy)
@@ -42,6 +42,7 @@
super(input);
}
+ @Override
public final boolean incrementToken() throws IOException {
if (cache == null) {
// fill cache lazily
@@ -59,12 +60,14 @@
return true;
}
+ @Override
public final void end() throws IOException {
if (finalState != null) {
restoreState(finalState);
}
}
+ @Override
public void reset() throws IOException {
if(cache != null) {
iterator = cache.iterator();
Index: src/java/org/apache/lucene/analysis/CharArraySet.java
===================================================================
--- src/java/org/apache/lucene/analysis/CharArraySet.java (revision 830378)
+++ src/java/org/apache/lucene/analysis/CharArraySet.java (working copy)
@@ -223,14 +223,17 @@
}
+ @Override
public int size() {
return count;
}
+ @Override
public boolean isEmpty() {
return count==0;
}
+ @Override
public boolean contains(Object o) {
if (o instanceof char[]) {
final char[] text = (char[])o;
@@ -239,6 +242,7 @@
return contains(o.toString());
}
+ @Override
public boolean add(Object o) {
if (o instanceof char[]) {
return add((char[])o);
@@ -309,6 +313,7 @@
}
/** returns an iterator of new allocated Strings, this method violates the Set interface */
+ @Override
@SuppressWarnings("unchecked")
public Iterator
* @see #getMatch
*/
+ @Override
public boolean isMatch() {
Boolean m = getMatch();
return (null != m ? m.booleanValue() : super.isMatch());
}
+ @Override
protected String getSummary() {
if (null == getMatch())
return super.getSummary();
Index: src/java/org/apache/lucene/search/DefaultSimilarity.java
===================================================================
--- src/java/org/apache/lucene/search/DefaultSimilarity.java (revision 830378)
+++ src/java/org/apache/lucene/search/DefaultSimilarity.java (working copy)
@@ -31,6 +31,7 @@
*
* WARNING: This API is new and experimental, and may suddenly
* change.
*/
+ @Override
public float computeNorm(String field, FieldInvertState state) {
final int numTerms;
if (discountOverlaps)
@@ -41,31 +42,37 @@
}
/** Implemented as 1/sqrt(numTerms). */
+ @Override
public float lengthNorm(String fieldName, int numTerms) {
return (float)(1.0 / Math.sqrt(numTerms));
}
/** Implemented as 1/sqrt(sumOfSquaredWeights). */
+ @Override
public float queryNorm(float sumOfSquaredWeights) {
return (float)(1.0 / Math.sqrt(sumOfSquaredWeights));
}
/** Implemented as sqrt(freq). */
+ @Override
public float tf(float freq) {
return (float)Math.sqrt(freq);
}
/** Implemented as 1 / (distance + 1). */
+ @Override
public float sloppyFreq(int distance) {
return 1.0f / (distance + 1);
}
/** Implemented as log(numDocs/(docFreq+1)) + 1. */
+ @Override
public float idf(int docFreq, int numDocs) {
return (float)(Math.log(numDocs/(double)(docFreq+1)) + 1.0);
}
/** Implemented as overlap / maxOverlap. */
+ @Override
public float coord(int overlap, int maxOverlap) {
return overlap / (float)maxOverlap;
}
Index: src/java/org/apache/lucene/search/DocIdSet.java
===================================================================
--- src/java/org/apache/lucene/search/DocIdSet.java (revision 830378)
+++ src/java/org/apache/lucene/search/DocIdSet.java (working copy)
@@ -29,8 +29,11 @@
public static final DocIdSet EMPTY_DOCIDSET = new DocIdSet() {
private final DocIdSetIterator iterator = new DocIdSetIterator() {
+ @Override
public int advance(int target) throws IOException { return NO_MORE_DOCS; }
+ @Override
public int docID() { return NO_MORE_DOCS; }
+ @Override
public int nextDoc() throws IOException { return NO_MORE_DOCS; }
};
Index: src/java/org/apache/lucene/search/ExactPhraseScorer.java
===================================================================
--- src/java/org/apache/lucene/search/ExactPhraseScorer.java (revision 830378)
+++ src/java/org/apache/lucene/search/ExactPhraseScorer.java (working copy)
@@ -27,6 +27,7 @@
super(weight, tps, offsets, similarity, norms);
}
+ @Override
protected final float phraseFreq() throws IOException {
// sort list with pq
pq.clear();
Index: src/java/org/apache/lucene/search/Explanation.java
===================================================================
--- src/java/org/apache/lucene/search/Explanation.java (revision 830378)
+++ src/java/org/apache/lucene/search/Explanation.java (working copy)
@@ -82,6 +82,7 @@
}
/** Render an explanation as text. */
+ @Override
public String toString() {
return toString(0);
}
Index: src/java/org/apache/lucene/search/FieldCache.java
===================================================================
--- src/java/org/apache/lucene/search/FieldCache.java (revision 830378)
+++ src/java/org/apache/lucene/search/FieldCache.java (working copy)
@@ -154,6 +154,7 @@
protected Object readResolve() {
return DEFAULT_BYTE_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".DEFAULT_BYTE_PARSER";
}
@@ -167,6 +168,7 @@
protected Object readResolve() {
return DEFAULT_SHORT_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".DEFAULT_SHORT_PARSER";
}
@@ -180,6 +182,7 @@
protected Object readResolve() {
return DEFAULT_INT_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".DEFAULT_INT_PARSER";
}
@@ -193,6 +196,7 @@
protected Object readResolve() {
return DEFAULT_FLOAT_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".DEFAULT_FLOAT_PARSER";
}
@@ -206,6 +210,7 @@
protected Object readResolve() {
return DEFAULT_LONG_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".DEFAULT_LONG_PARSER";
}
@@ -219,6 +224,7 @@
protected Object readResolve() {
return DEFAULT_DOUBLE_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".DEFAULT_DOUBLE_PARSER";
}
@@ -238,6 +244,7 @@
protected Object readResolve() {
return NUMERIC_UTILS_INT_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".NUMERIC_UTILS_INT_PARSER";
}
@@ -257,6 +264,7 @@
protected Object readResolve() {
return NUMERIC_UTILS_FLOAT_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".NUMERIC_UTILS_FLOAT_PARSER";
}
@@ -276,6 +284,7 @@
protected Object readResolve() {
return NUMERIC_UTILS_LONG_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".NUMERIC_UTILS_LONG_PARSER";
}
@@ -295,6 +304,7 @@
protected Object readResolve() {
return NUMERIC_UTILS_DOUBLE_PARSER;
}
+ @Override
public String toString() {
return FieldCache.class.getName()+".NUMERIC_UTILS_DOUBLE_PARSER";
}
@@ -528,6 +538,7 @@
}
+ @Override
public String toString() {
StringBuilder b = new StringBuilder();
b.append("'").append(getReaderKey()).append("'=>");
Index: src/java/org/apache/lucene/search/FieldCacheImpl.java
===================================================================
--- src/java/org/apache/lucene/search/FieldCacheImpl.java (revision 830378)
+++ src/java/org/apache/lucene/search/FieldCacheImpl.java (working copy)
@@ -107,10 +107,15 @@
// }
}
+ @Override
public Object getReaderKey() { return readerKey; }
+ @Override
public String getFieldName() { return fieldName; }
+ @Override
public Class> getCacheType() { return cacheType; }
+ @Override
public Object getCustom() { return custom; }
+ @Override
public Object getValue() { return value; }
}
@@ -212,6 +217,7 @@
}
/** Two of these are equal iff they reference the same field and type. */
+ @Override
public boolean equals (Object o) {
if (o instanceof Entry) {
Entry other = (Entry) o;
@@ -227,6 +233,7 @@
}
/** Composes a hashcode based on the field and type. */
+ @Override
public int hashCode() {
return field.hashCode() ^ (custom==null ? 0 : custom.hashCode());
}
@@ -247,6 +254,7 @@
ByteCache(FieldCache wrapper) {
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entryKey)
throws IOException {
Entry entry = entryKey;
@@ -293,6 +301,7 @@
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entryKey)
throws IOException {
Entry entry = entryKey;
@@ -339,6 +348,7 @@
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entryKey)
throws IOException {
Entry entry = entryKey;
@@ -396,6 +406,7 @@
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entryKey)
throws IOException {
Entry entry = entryKey;
@@ -450,6 +461,7 @@
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entry)
throws IOException {
String field = entry.field;
@@ -504,6 +516,7 @@
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entryKey)
throws IOException {
Entry entry = entryKey;
@@ -553,6 +566,7 @@
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entryKey)
throws IOException {
String field = StringHelper.intern(entryKey.field);
@@ -588,6 +602,7 @@
super(wrapper);
}
+ @Override
protected Object createValue(IndexReader reader, Entry entryKey)
throws IOException {
String field = StringHelper.intern(entryKey.field);
Index: src/java/org/apache/lucene/search/FieldCacheRangeFilter.java
===================================================================
--- src/java/org/apache/lucene/search/FieldCacheRangeFilter.java (revision 830378)
+++ src/java/org/apache/lucene/search/FieldCacheRangeFilter.java (working copy)
@@ -70,6 +70,7 @@
}
/** This method is implemented for each data type */
+ @Override
public abstract DocIdSet getDocIdSet(IndexReader reader) throws IOException;
/**
@@ -79,6 +80,7 @@
*/
public static FieldCacheRangeFilter newStringRange(String field, String lowerVal, String upperVal, boolean includeLower, boolean includeUpper) {
return new FieldCacheRangeFilter(field, null, lowerVal, upperVal, includeLower, includeUpper) {
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
final FieldCache.StringIndex fcsi = FieldCache.DEFAULT.getStringIndex(reader, field);
final int lowerPoint = fcsi.binarySearchLookup(lowerVal);
@@ -120,6 +122,7 @@
// for this DocIdSet, we never need to use TermDocs,
// because deleted docs have an order of 0 (null entry in StringIndex)
return new FieldCacheDocIdSet(reader, false) {
+ @Override
final boolean matchDoc(int doc) {
return fcsi.order[doc] >= inclusiveLowerPoint && fcsi.order[doc] <= inclusiveUpperPoint;
}
@@ -144,6 +147,7 @@
*/
public static FieldCacheRangeFilter newByteRange(String field, FieldCache.ByteParser parser, Byte lowerVal, Byte upperVal, boolean includeLower, boolean includeUpper) {
return new FieldCacheRangeFilter(field, parser, lowerVal, upperVal, includeLower, includeUpper) {
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
final byte inclusiveLowerPoint, inclusiveUpperPoint;
if (lowerVal != null) {
@@ -169,6 +173,7 @@
final byte[] values = FieldCache.DEFAULT.getBytes(reader, field, (FieldCache.ByteParser) parser);
// we only request the usage of termDocs, if the range contains 0
return new FieldCacheDocIdSet(reader, (inclusiveLowerPoint <= 0 && inclusiveUpperPoint >= 0)) {
+ @Override
boolean matchDoc(int doc) {
return values[doc] >= inclusiveLowerPoint && values[doc] <= inclusiveUpperPoint;
}
@@ -193,6 +198,7 @@
*/
public static FieldCacheRangeFilter newShortRange(String field, FieldCache.ShortParser parser, Short lowerVal, Short upperVal, boolean includeLower, boolean includeUpper) {
return new FieldCacheRangeFilter(field, parser, lowerVal, upperVal, includeLower, includeUpper) {
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
final short inclusiveLowerPoint, inclusiveUpperPoint;
if (lowerVal != null) {
@@ -218,6 +224,7 @@
final short[] values = FieldCache.DEFAULT.getShorts(reader, field, (FieldCache.ShortParser) parser);
// we only request the usage of termDocs, if the range contains 0
return new FieldCacheDocIdSet(reader, (inclusiveLowerPoint <= 0 && inclusiveUpperPoint >= 0)) {
+ @Override
boolean matchDoc(int doc) {
return values[doc] >= inclusiveLowerPoint && values[doc] <= inclusiveUpperPoint;
}
@@ -242,6 +249,7 @@
*/
public static FieldCacheRangeFilter newIntRange(String field, FieldCache.IntParser parser, Integer lowerVal, Integer upperVal, boolean includeLower, boolean includeUpper) {
return new FieldCacheRangeFilter(field, parser, lowerVal, upperVal, includeLower, includeUpper) {
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
final int inclusiveLowerPoint, inclusiveUpperPoint;
if (lowerVal != null) {
@@ -267,6 +275,7 @@
final int[] values = FieldCache.DEFAULT.getInts(reader, field, (FieldCache.IntParser) parser);
// we only request the usage of termDocs, if the range contains 0
return new FieldCacheDocIdSet(reader, (inclusiveLowerPoint <= 0 && inclusiveUpperPoint >= 0)) {
+ @Override
boolean matchDoc(int doc) {
return values[doc] >= inclusiveLowerPoint && values[doc] <= inclusiveUpperPoint;
}
@@ -291,6 +300,7 @@
*/
public static FieldCacheRangeFilter newLongRange(String field, FieldCache.LongParser parser, Long lowerVal, Long upperVal, boolean includeLower, boolean includeUpper) {
return new FieldCacheRangeFilter(field, parser, lowerVal, upperVal, includeLower, includeUpper) {
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
final long inclusiveLowerPoint, inclusiveUpperPoint;
if (lowerVal != null) {
@@ -316,6 +326,7 @@
final long[] values = FieldCache.DEFAULT.getLongs(reader, field, (FieldCache.LongParser) parser);
// we only request the usage of termDocs, if the range contains 0
return new FieldCacheDocIdSet(reader, (inclusiveLowerPoint <= 0L && inclusiveUpperPoint >= 0L)) {
+ @Override
boolean matchDoc(int doc) {
return values[doc] >= inclusiveLowerPoint && values[doc] <= inclusiveUpperPoint;
}
@@ -340,6 +351,7 @@
*/
public static FieldCacheRangeFilter newFloatRange(String field, FieldCache.FloatParser parser, Float lowerVal, Float upperVal, boolean includeLower, boolean includeUpper) {
return new FieldCacheRangeFilter(field, parser, lowerVal, upperVal, includeLower, includeUpper) {
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
// we transform the floating point numbers to sortable integers
// using NumericUtils to easier find the next bigger/lower value
@@ -369,6 +381,7 @@
final float[] values = FieldCache.DEFAULT.getFloats(reader, field, (FieldCache.FloatParser) parser);
// we only request the usage of termDocs, if the range contains 0
return new FieldCacheDocIdSet(reader, (inclusiveLowerPoint <= 0.0f && inclusiveUpperPoint >= 0.0f)) {
+ @Override
boolean matchDoc(int doc) {
return values[doc] >= inclusiveLowerPoint && values[doc] <= inclusiveUpperPoint;
}
@@ -393,6 +406,7 @@
*/
public static FieldCacheRangeFilter newDoubleRange(String field, FieldCache.DoubleParser parser, Double lowerVal, Double upperVal, boolean includeLower, boolean includeUpper) {
return new FieldCacheRangeFilter(field, parser, lowerVal, upperVal, includeLower, includeUpper) {
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
// we transform the floating point numbers to sortable integers
// using NumericUtils to easier find the next bigger/lower value
@@ -422,6 +436,7 @@
final double[] values = FieldCache.DEFAULT.getDoubles(reader, field, (FieldCache.DoubleParser) parser);
// we only request the usage of termDocs, if the range contains 0
return new FieldCacheDocIdSet(reader, (inclusiveLowerPoint <= 0.0 && inclusiveUpperPoint >= 0.0)) {
+ @Override
boolean matchDoc(int doc) {
return values[doc] >= inclusiveLowerPoint && values[doc] <= inclusiveUpperPoint;
}
@@ -430,6 +445,7 @@
};
}
+ @Override
public final String toString() {
final StringBuilder sb = new StringBuilder(field).append(":");
return sb.append(includeLower ? '[' : '{')
@@ -440,6 +456,7 @@
.toString();
}
+ @Override
public final boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof FieldCacheRangeFilter)) return false;
@@ -455,6 +472,7 @@
return true;
}
+ @Override
public final int hashCode() {
int h = field.hashCode();
h ^= (lowerVal != null) ? lowerVal.hashCode() : 550356204;
@@ -516,10 +534,12 @@
return new DocIdSetIterator() {
private int doc = -1;
+ @Override
public int docID() {
return doc;
}
+ @Override
public int nextDoc() throws IOException {
do {
if (!termDocs.next())
@@ -528,6 +548,7 @@
return doc;
}
+ @Override
public int advance(int target) throws IOException {
if (!termDocs.skipTo(target))
return doc = NO_MORE_DOCS;
@@ -544,10 +565,12 @@
return new DocIdSetIterator() {
private int doc = -1;
+ @Override
public int docID() {
return doc;
}
+ @Override
public int nextDoc() {
try {
do {
@@ -559,6 +582,7 @@
}
}
+ @Override
public int advance(int target) {
try {
doc = target;
Index: src/java/org/apache/lucene/search/FieldCacheTermsFilter.java
===================================================================
--- src/java/org/apache/lucene/search/FieldCacheTermsFilter.java (revision 830378)
+++ src/java/org/apache/lucene/search/FieldCacheTermsFilter.java (working copy)
@@ -106,6 +106,7 @@
return FieldCache.DEFAULT;
}
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
return new FieldCacheTermsFilterDocIdSet(getFieldCache().getStringIndex(reader, field));
}
@@ -140,10 +141,12 @@
protected class FieldCacheTermsFilterDocIdSetIterator extends DocIdSetIterator {
private int doc = -1;
+ @Override
public int docID() {
return doc;
}
+ @Override
public int nextDoc() {
try {
while (!openBitSet.fastGet(fcsi.order[++doc])) {}
@@ -153,6 +156,7 @@
return doc;
}
+ @Override
public int advance(int target) {
try {
doc = target;
Index: src/java/org/apache/lucene/search/FieldComparator.java
===================================================================
--- src/java/org/apache/lucene/search/FieldComparator.java (revision 830378)
+++ src/java/org/apache/lucene/search/FieldComparator.java (working copy)
@@ -178,26 +178,32 @@
this.parser = (ByteParser) parser;
}
+ @Override
public int compare(int slot1, int slot2) {
return values[slot1] - values[slot2];
}
+ @Override
public int compareBottom(int doc) {
return bottom - currentReaderValues[doc];
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getBytes(reader, field, parser);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return Byte.valueOf(values[slot]);
}
@@ -213,20 +219,24 @@
docIDs = new int[numHits];
}
+ @Override
public int compare(int slot1, int slot2) {
// No overflow risk because docIDs are non-negative
return docIDs[slot1] - docIDs[slot2];
}
+ @Override
public int compareBottom(int doc) {
// No overflow risk because docIDs are non-negative
return bottom - (docBase + doc);
}
+ @Override
public void copy(int slot, int doc) {
docIDs[slot] = docBase + doc;
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) {
// TODO: can we "map" our docIDs to the current
// reader? saves having to then subtract on every
@@ -234,10 +244,12 @@
this.docBase = docBase;
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = docIDs[bottom];
}
+ @Override
public Comparable value(int slot) {
return Integer.valueOf(docIDs[slot]);
}
@@ -258,6 +270,7 @@
this.parser = (DoubleParser) parser;
}
+ @Override
public int compare(int slot1, int slot2) {
final double v1 = values[slot1];
final double v2 = values[slot2];
@@ -270,6 +283,7 @@
}
}
+ @Override
public int compareBottom(int doc) {
final double v2 = currentReaderValues[doc];
if (bottom > v2) {
@@ -281,18 +295,22 @@
}
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getDoubles(reader, field, parser);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return Double.valueOf(values[slot]);
}
@@ -313,6 +331,7 @@
this.parser = (FloatParser) parser;
}
+ @Override
public int compare(int slot1, int slot2) {
// TODO: are there sneaky non-branch ways to compute
// sign of float?
@@ -327,6 +346,7 @@
}
}
+ @Override
public int compareBottom(int doc) {
// TODO: are there sneaky non-branch ways to compute
// sign of float?
@@ -340,18 +360,22 @@
}
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getFloats(reader, field, parser);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return Float.valueOf(values[slot]);
}
@@ -372,6 +396,7 @@
this.parser = (IntParser) parser;
}
+ @Override
public int compare(int slot1, int slot2) {
// TODO: there are sneaky non-branch ways to compute
// -1/+1/0 sign
@@ -388,6 +413,7 @@
}
}
+ @Override
public int compareBottom(int doc) {
// TODO: there are sneaky non-branch ways to compute
// -1/+1/0 sign
@@ -403,18 +429,22 @@
}
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getInts(reader, field, parser);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return Integer.valueOf(values[slot]);
}
@@ -435,6 +465,7 @@
this.parser = (LongParser) parser;
}
+ @Override
public int compare(int slot1, int slot2) {
// TODO: there are sneaky non-branch ways to compute
// -1/+1/0 sign
@@ -449,6 +480,7 @@
}
}
+ @Override
public int compareBottom(int doc) {
// TODO: there are sneaky non-branch ways to compute
// -1/+1/0 sign
@@ -462,18 +494,22 @@
}
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getLongs(reader, field, parser);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return Long.valueOf(values[slot]);
}
@@ -494,34 +530,41 @@
scores = new float[numHits];
}
+ @Override
public int compare(int slot1, int slot2) {
final float score1 = scores[slot1];
final float score2 = scores[slot2];
return score1 > score2 ? -1 : (score1 < score2 ? 1 : 0);
}
+ @Override
public int compareBottom(int doc) throws IOException {
float score = scorer.score();
return bottom > score ? -1 : (bottom < score ? 1 : 0);
}
+ @Override
public void copy(int slot, int doc) throws IOException {
scores[slot] = scorer.score();
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) {
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = scores[bottom];
}
+ @Override
public void setScorer(Scorer scorer) {
// wrap with a ScoreCachingWrappingScorer so that successive calls to
// score() will not incur score computation over and over again.
this.scorer = new ScoreCachingWrappingScorer(scorer);
}
+ @Override
public Comparable value(int slot) {
return Float.valueOf(scores[slot]);
}
@@ -542,26 +585,32 @@
this.parser = (ShortParser) parser;
}
+ @Override
public int compare(int slot1, int slot2) {
return values[slot1] - values[slot2];
}
+ @Override
public int compareBottom(int doc) {
return bottom - currentReaderValues[doc];
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getShorts(reader, field, parser);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return Short.valueOf(values[slot]);
}
@@ -583,6 +632,7 @@
collator = Collator.getInstance(locale);
}
+ @Override
public int compare(int slot1, int slot2) {
final String val1 = values[slot1];
final String val2 = values[slot2];
@@ -597,6 +647,7 @@
return collator.compare(val1, val2);
}
+ @Override
public int compareBottom(int doc) {
final String val2 = currentReaderValues[doc];
if (bottom == null) {
@@ -610,18 +661,22 @@
return collator.compare(bottom, val2);
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getStrings(reader, field);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return values[slot];
}
@@ -662,6 +717,7 @@
this.field = field;
}
+ @Override
public int compare(int slot1, int slot2) {
if (readerGen[slot1] == readerGen[slot2]) {
int cmp = ords[slot1] - ords[slot2];
@@ -683,6 +739,7 @@
return val1.compareTo(val2);
}
+ @Override
public int compareBottom(int doc) {
assert bottomSlot != -1;
int order = this.order[doc];
@@ -734,6 +791,7 @@
ords[slot] = index;
}
+ @Override
public void copy(int slot, int doc) {
final int ord = order[doc];
ords[slot] = ord;
@@ -742,6 +800,7 @@
readerGen[slot] = currentReaderGen;
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
StringIndex currentReaderValues = FieldCache.DEFAULT.getStringIndex(reader, field);
currentReaderGen++;
@@ -754,6 +813,7 @@
}
}
+ @Override
public void setBottom(final int bottom) {
bottomSlot = bottom;
if (readerGen[bottom] != currentReaderGen) {
@@ -765,6 +825,7 @@
bottomValue = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return values[slot];
}
@@ -798,6 +859,7 @@
this.field = field;
}
+ @Override
public int compare(int slot1, int slot2) {
final String val1 = values[slot1];
final String val2 = values[slot2];
@@ -813,6 +875,7 @@
return val1.compareTo(val2);
}
+ @Override
public int compareBottom(int doc) {
final String val2 = currentReaderValues[doc];
if (bottom == null) {
@@ -826,18 +889,22 @@
return bottom.compareTo(val2);
}
+ @Override
public void copy(int slot, int doc) {
values[slot] = currentReaderValues[doc];
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
currentReaderValues = FieldCache.DEFAULT.getStrings(reader, field);
}
+ @Override
public void setBottom(final int bottom) {
this.bottom = values[bottom];
}
+ @Override
public Comparable value(int slot) {
return values[slot];
}
Index: src/java/org/apache/lucene/search/FieldDoc.java
===================================================================
--- src/java/org/apache/lucene/search/FieldDoc.java (revision 830378)
+++ src/java/org/apache/lucene/search/FieldDoc.java (working copy)
@@ -38,37 +38,38 @@
*/
public class FieldDoc extends ScoreDoc {
- /** Expert: The values which are used to sort the referenced document.
- * The order of these will match the original sort criteria given by a
- * Sort object. Each Object will be either an Integer, Float or String,
- * depending on the type of values in the terms of the original field.
- * @see Sort
- * @see Searcher#search(Query,Filter,int,Sort)
- */
- public Comparable[] fields;
+ /** Expert: The values which are used to sort the referenced document.
+ * The order of these will match the original sort criteria given by a
+ * Sort object. Each Object will be either an Integer, Float or String,
+ * depending on the type of values in the terms of the original field.
+ * @see Sort
+ * @see Searcher#search(Query,Filter,int,Sort)
+ */
+ public Comparable[] fields;
- /** Expert: Creates one of these objects with empty sort information. */
- public FieldDoc (int doc, float score) {
- super (doc, score);
- }
+ /** Expert: Creates one of these objects with empty sort information. */
+ public FieldDoc (int doc, float score) {
+ super (doc, score);
+ }
- /** Expert: Creates one of these objects with the given sort information. */
- public FieldDoc (int doc, float score, Comparable[] fields) {
- super (doc, score);
- this.fields = fields;
- }
-
- // A convenience method for debugging.
- public String toString() {
- // super.toString returns the doc and score information, so just add the
+ /** Expert: Creates one of these objects with the given sort information. */
+ public FieldDoc (int doc, float score, Comparable[] fields) {
+ super (doc, score);
+ this.fields = fields;
+ }
+
+ // A convenience method for debugging.
+ @Override
+ public String toString() {
+ // super.toString returns the doc and score information, so just add the
// fields information
- StringBuilder sb = new StringBuilder(super.toString());
- sb.append("[");
- for (int i = 0; i < fields.length; i++) {
+ StringBuilder sb = new StringBuilder(super.toString());
+ sb.append("[");
+ for (int i = 0; i < fields.length; i++) {
sb.append(fields[i]).append(", ");
}
- sb.setLength(sb.length() - 2); // discard last ", "
- sb.append("]");
- return super.toString();
- }
+ sb.setLength(sb.length() - 2); // discard last ", "
+ sb.append("]");
+ return super.toString();
+ }
}
Index: src/java/org/apache/lucene/search/FieldValueHitQueue.java
===================================================================
--- src/java/org/apache/lucene/search/FieldValueHitQueue.java (revision 830378)
+++ src/java/org/apache/lucene/search/FieldValueHitQueue.java (working copy)
@@ -47,6 +47,7 @@
this.score = score;
}
+ @Override
public String toString() {
return "slot:" + slot + " docID:" + docID + " score=" + score;
}
@@ -84,6 +85,7 @@
* @param b ScoreDoc
* @return true if document a should be sorted after document b.
*/
+ @Override
protected boolean lessThan(final Entry hitA, final Entry hitB) {
assert hitA != hitB;
@@ -121,6 +123,7 @@
initialize(size);
}
+ @Override
protected boolean lessThan(final Entry hitA, final Entry hitB) {
assert hitA != hitB;
@@ -190,6 +193,7 @@
protected final FieldComparator[] comparators;
protected final int[] reverseMul;
+ @Override
protected abstract boolean lessThan (final Entry a, final Entry b);
/**
Index: src/java/org/apache/lucene/search/FilteredDocIdSet.java
===================================================================
--- src/java/org/apache/lucene/search/FilteredDocIdSet.java (revision 830378)
+++ src/java/org/apache/lucene/search/FilteredDocIdSet.java (working copy)
@@ -70,6 +70,7 @@
@Override
public DocIdSetIterator iterator() throws IOException {
return new FilteredDocIdSetIterator(_innerSet.iterator()) {
+ @Override
protected boolean match(int docid) throws IOException {
return FilteredDocIdSet.this.match(docid);
}
Index: src/java/org/apache/lucene/search/FilteredDocIdSetIterator.java
===================================================================
--- src/java/org/apache/lucene/search/FilteredDocIdSetIterator.java (revision 830378)
+++ src/java/org/apache/lucene/search/FilteredDocIdSetIterator.java (working copy)
@@ -49,10 +49,12 @@
*/
abstract protected boolean match(int doc) throws IOException;
+ @Override
public int docID() {
return doc;
}
+ @Override
public int nextDoc() throws IOException {
while ((doc = _innerIter.nextDoc()) != NO_MORE_DOCS) {
if (match(doc)) {
@@ -62,6 +64,7 @@
return doc;
}
+ @Override
public int advance(int target) throws IOException {
doc = _innerIter.advance(target);
if (doc != NO_MORE_DOCS) {
Index: src/java/org/apache/lucene/search/FilteredQuery.java
===================================================================
--- src/java/org/apache/lucene/search/FilteredQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/FilteredQuery.java (working copy)
@@ -58,6 +58,7 @@
* Returns a Weight that applies the filter to the enclosed query's Weight.
* This is accomplished by overriding the Scorer returned by the Weight.
*/
+ @Override
public Weight createWeight(final Searcher searcher) throws IOException {
final Weight weight = query.createWeight (searcher);
final Similarity similarity = query.getSimilarity(searcher);
Index: src/java/org/apache/lucene/search/FilteredTermEnum.java
===================================================================
--- src/java/org/apache/lucene/search/FilteredTermEnum.java (revision 830378)
+++ src/java/org/apache/lucene/search/FilteredTermEnum.java (working copy)
@@ -60,6 +60,7 @@
* Returns the docFreq of the current Term in the enumeration.
* Returns -1 if no Term matches or all terms have been enumerated.
*/
+ @Override
public int docFreq() {
if (currentTerm == null) return -1;
assert actualEnum != null;
@@ -67,6 +68,7 @@
}
/** Increments the enumeration to the next element. True if one exists. */
+ @Override
public boolean next() throws IOException {
if (actualEnum == null) return false; // the actual enumerator is not initialized!
currentTerm = null;
@@ -87,11 +89,13 @@
/** Returns the current Term in the enumeration.
* Returns null if no Term matches or all terms have been enumerated. */
+ @Override
public Term term() {
return currentTerm;
}
/** Closes the enumeration to further activity, freeing resources. */
+ @Override
public void close() throws IOException {
if (actualEnum != null) actualEnum.close();
currentTerm = null;
Index: src/java/org/apache/lucene/search/function/ByteFieldSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/ByteFieldSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/ByteFieldSource.java (working copy)
@@ -66,27 +66,33 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#description() */
+ @Override
public String description() {
return "byte(" + super.description() + ')';
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#getCachedValues(org.apache.lucene.search.FieldCache, java.lang.String, org.apache.lucene.index.IndexReader) */
+ @Override
public DocValues getCachedFieldValues (FieldCache cache, String field, IndexReader reader) throws IOException {
final byte[] arr = cache.getBytes(reader, field, parser);
return new DocValues() {
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#floatVal(int) */
+ @Override
public float floatVal(int doc) {
return (float) arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#intVal(int) */
+ @Override
public int intVal(int doc) {
return arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#toString(int) */
+ @Override
public String toString(int doc) {
return description() + '=' + intVal(doc);
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#getInnerArray() */
+ @Override
Object getInnerArray() {
return arr;
}
@@ -94,6 +100,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceEquals(org.apache.lucene.search.function.FieldCacheSource) */
+ @Override
public boolean cachedFieldSourceEquals(FieldCacheSource o) {
if (o.getClass() != ByteFieldSource.class) {
return false;
@@ -105,6 +112,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceHashCode() */
+ @Override
public int cachedFieldSourceHashCode() {
return parser==null ?
Byte.class.hashCode() : parser.getClass().hashCode();
Index: src/java/org/apache/lucene/search/function/FieldCacheSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/FieldCacheSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/FieldCacheSource.java (working copy)
@@ -60,11 +60,13 @@
}
/* (non-Javadoc) @see org.apache.lucene.search.function.ValueSource#getValues(org.apache.lucene.index.IndexReader) */
+ @Override
public final DocValues getValues(IndexReader reader) throws IOException {
return getCachedFieldValues(FieldCache.DEFAULT, field, reader);
}
/* (non-Javadoc) @see org.apache.lucene.search.function.ValueSource#description() */
+ @Override
public String description() {
return field;
}
@@ -78,6 +80,7 @@
public abstract DocValues getCachedFieldValues(FieldCache cache, String field, IndexReader reader) throws IOException;
/*(non-Javadoc) @see java.lang.Object#equals(java.lang.Object) */
+ @Override
public final boolean equals(Object o) {
if (!(o instanceof FieldCacheSource)) {
return false;
@@ -89,6 +92,7 @@
}
/*(non-Javadoc) @see java.lang.Object#hashCode() */
+ @Override
public final int hashCode() {
return
field.hashCode() +
Index: src/java/org/apache/lucene/search/function/FieldScoreQuery.java
===================================================================
--- src/java/org/apache/lucene/search/function/FieldScoreQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/FieldScoreQuery.java (working copy)
@@ -90,6 +90,7 @@
this.typeName = name;
}
/*(non-Javadoc) @see java.lang.Object#toString() */
+ @Override
public String toString() {
return getClass().getName()+"::"+typeName;
}
Index: src/java/org/apache/lucene/search/function/FloatFieldSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/FloatFieldSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/FloatFieldSource.java (working copy)
@@ -66,23 +66,28 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#description() */
+ @Override
public String description() {
return "float(" + super.description() + ')';
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#getCachedValues(org.apache.lucene.search.FieldCache, java.lang.String, org.apache.lucene.index.IndexReader) */
+ @Override
public DocValues getCachedFieldValues (FieldCache cache, String field, IndexReader reader) throws IOException {
final float[] arr = cache.getFloats(reader, field, parser);
return new DocValues() {
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#floatVal(int) */
+ @Override
public float floatVal(int doc) {
return arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#toString(int) */
+ @Override
public String toString(int doc) {
return description() + '=' + arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#getInnerArray() */
+ @Override
Object getInnerArray() {
return arr;
}
@@ -90,6 +95,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceEquals(org.apache.lucene.search.function.FieldCacheSource) */
+ @Override
public boolean cachedFieldSourceEquals(FieldCacheSource o) {
if (o.getClass() != FloatFieldSource.class) {
return false;
@@ -101,6 +107,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceHashCode() */
+ @Override
public int cachedFieldSourceHashCode() {
return parser==null ?
Float.class.hashCode() : parser.getClass().hashCode();
Index: src/java/org/apache/lucene/search/function/IntFieldSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/IntFieldSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/IntFieldSource.java (working copy)
@@ -66,27 +66,33 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#description() */
+ @Override
public String description() {
return "int(" + super.description() + ')';
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#getCachedValues(org.apache.lucene.search.FieldCache, java.lang.String, org.apache.lucene.index.IndexReader) */
+ @Override
public DocValues getCachedFieldValues (FieldCache cache, String field, IndexReader reader) throws IOException {
final int[] arr = cache.getInts(reader, field, parser);
return new DocValues() {
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#floatVal(int) */
+ @Override
public float floatVal(int doc) {
return (float) arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#intVal(int) */
+ @Override
public int intVal(int doc) {
return arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#toString(int) */
+ @Override
public String toString(int doc) {
return description() + '=' + intVal(doc);
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#getInnerArray() */
+ @Override
Object getInnerArray() {
return arr;
}
@@ -94,6 +100,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceEquals(org.apache.lucene.search.function.FieldCacheSource) */
+ @Override
public boolean cachedFieldSourceEquals(FieldCacheSource o) {
if (o.getClass() != IntFieldSource.class) {
return false;
@@ -105,6 +112,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceHashCode() */
+ @Override
public int cachedFieldSourceHashCode() {
return parser==null ?
Integer.class.hashCode() : parser.getClass().hashCode();
Index: src/java/org/apache/lucene/search/function/MultiValueSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/MultiValueSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/MultiValueSource.java (working copy)
@@ -42,6 +42,7 @@
this.other = other;
}
+ @Override
public DocValues getValues(IndexReader reader) throws IOException {
IndexReader[] subReaders = reader.getSequentialSubReaders();
@@ -54,10 +55,12 @@
}
}
+ @Override
public String description() {
return other.description();
}
+ @Override
public boolean equals(Object o) {
if (o instanceof MultiValueSource) {
return ((MultiValueSource) o).other.equals(other);
@@ -66,6 +69,7 @@
}
}
+ @Override
public int hashCode() {
return 31 * other.hashCode();
}
@@ -86,36 +90,43 @@
}
}
+ @Override
public float floatVal(int doc) {
final int n = ReaderUtil.subIndex(doc, docStarts);
return docValues[n].floatVal(doc-docStarts[n]);
}
+ @Override
public int intVal(int doc) {
final int n = ReaderUtil.subIndex(doc, docStarts);
return docValues[n].intVal(doc-docStarts[n]);
}
+ @Override
public long longVal(int doc) {
final int n = ReaderUtil.subIndex(doc, docStarts);
return docValues[n].longVal(doc-docStarts[n]);
}
+ @Override
public double doubleVal(int doc) {
final int n = ReaderUtil.subIndex(doc, docStarts);
return docValues[n].doubleVal(doc-docStarts[n]);
}
+ @Override
public String strVal(int doc) {
final int n = ReaderUtil.subIndex(doc, docStarts);
return docValues[n].strVal(doc-docStarts[n]);
}
+ @Override
public String toString(int doc) {
final int n = ReaderUtil.subIndex(doc, docStarts);
return docValues[n].toString(doc-docStarts[n]);
}
+ @Override
public Explanation explain(int doc) {
final int n = ReaderUtil.subIndex(doc, docStarts);
return docValues[n].explain(doc-docStarts[n]);
Index: src/java/org/apache/lucene/search/function/OrdFieldSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/OrdFieldSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/OrdFieldSource.java (working copy)
@@ -67,28 +67,34 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#description() */
+ @Override
public String description() {
return "ord(" + field + ')';
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#getValues(org.apache.lucene.index.IndexReader) */
+ @Override
public DocValues getValues(IndexReader reader) throws IOException {
final int[] arr = FieldCache.DEFAULT.getStringIndex(reader, field).order;
return new DocValues() {
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#floatVal(int) */
+ @Override
public float floatVal(int doc) {
return (float)arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#strVal(int) */
+ @Override
public String strVal(int doc) {
// the string value of the ordinal, not the string itself
return Integer.toString(arr[doc]);
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#toString(int) */
+ @Override
public String toString(int doc) {
return description() + '=' + intVal(doc);
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#getInnerArray() */
+ @Override
Object getInnerArray() {
return arr;
}
@@ -96,6 +102,7 @@
}
/*(non-Javadoc) @see java.lang.Object#equals(java.lang.Object) */
+ @Override
public boolean equals(Object o) {
if (o.getClass() != OrdFieldSource.class) return false;
OrdFieldSource other = (OrdFieldSource)o;
@@ -105,6 +112,7 @@
private static final int hcode = OrdFieldSource.class.hashCode();
/*(non-Javadoc) @see java.lang.Object#hashCode() */
+ @Override
public int hashCode() {
return hcode + field.hashCode();
}
Index: src/java/org/apache/lucene/search/function/ReverseOrdFieldSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/ReverseOrdFieldSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/ReverseOrdFieldSource.java (working copy)
@@ -68,11 +68,13 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#description() */
+ @Override
public String description() {
return "rord("+field+')';
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#getValues(org.apache.lucene.index.IndexReader) */
+ @Override
public DocValues getValues(IndexReader reader) throws IOException {
final FieldCache.StringIndex sindex = FieldCache.DEFAULT.getStringIndex(reader, field);
@@ -81,23 +83,28 @@
return new DocValues() {
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#floatVal(int) */
+ @Override
public float floatVal(int doc) {
return (float)(end - arr[doc]);
}
/* (non-Javadoc) @see org.apache.lucene.search.function.DocValues#intVal(int) */
+ @Override
public int intVal(int doc) {
return end - arr[doc];
}
/* (non-Javadoc) @see org.apache.lucene.search.function.DocValues#strVal(int) */
+ @Override
public String strVal(int doc) {
// the string value of the ordinal, not the string itself
return Integer.toString(intVal(doc));
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#toString(int) */
+ @Override
public String toString(int doc) {
return description() + '=' + strVal(doc);
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#getInnerArray() */
+ @Override
Object getInnerArray() {
return arr;
}
@@ -105,6 +112,7 @@
}
/*(non-Javadoc) @see java.lang.Object#equals(java.lang.Object) */
+ @Override
public boolean equals(Object o) {
if (o.getClass() != ReverseOrdFieldSource.class) return false;
ReverseOrdFieldSource other = (ReverseOrdFieldSource)o;
@@ -114,6 +122,7 @@
private static final int hcode = ReverseOrdFieldSource.class.hashCode();
/*(non-Javadoc) @see java.lang.Object#hashCode() */
+ @Override
public int hashCode() {
return hcode + field.hashCode();
}
Index: src/java/org/apache/lucene/search/function/ShortFieldSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/ShortFieldSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/ShortFieldSource.java (working copy)
@@ -66,27 +66,33 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.ValueSource#description() */
+ @Override
public String description() {
return "short(" + super.description() + ')';
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#getCachedValues(org.apache.lucene.search.FieldCache, java.lang.String, org.apache.lucene.index.IndexReader) */
+ @Override
public DocValues getCachedFieldValues (FieldCache cache, String field, IndexReader reader) throws IOException {
final short[] arr = cache.getShorts(reader, field, parser);
return new DocValues() {
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#floatVal(int) */
+ @Override
public float floatVal(int doc) {
return (float) arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#intVal(int) */
+ @Override
public int intVal(int doc) {
return arr[doc];
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#toString(int) */
+ @Override
public String toString(int doc) {
return description() + '=' + intVal(doc);
}
/*(non-Javadoc) @see org.apache.lucene.search.function.DocValues#getInnerArray() */
+ @Override
Object getInnerArray() {
return arr;
}
@@ -94,6 +100,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceEquals(org.apache.lucene.search.function.FieldCacheSource) */
+ @Override
public boolean cachedFieldSourceEquals(FieldCacheSource o) {
if (o.getClass() != ShortFieldSource.class) {
return false;
@@ -105,6 +112,7 @@
}
/*(non-Javadoc) @see org.apache.lucene.search.function.FieldCacheSource#cachedFieldSourceHashCode() */
+ @Override
public int cachedFieldSourceHashCode() {
return parser==null ?
Short.class.hashCode() : parser.getClass().hashCode();
Index: src/java/org/apache/lucene/search/function/ValueSource.java
===================================================================
--- src/java/org/apache/lucene/search/function/ValueSource.java (revision 830378)
+++ src/java/org/apache/lucene/search/function/ValueSource.java (working copy)
@@ -54,6 +54,7 @@
public abstract String description();
/* (non-Javadoc) @see java.lang.Object#toString() */
+ @Override
public String toString() {
return description();
}
@@ -62,12 +63,14 @@
* Needed for possible caching of query results - used by {@link ValueSourceQuery#equals(Object)}.
* @see Object#equals(Object)
*/
+ @Override
public abstract boolean equals(Object o);
/**
* Needed for possible caching of query results - used by {@link ValueSourceQuery#hashCode()}.
* @see Object#hashCode()
*/
+ @Override
public abstract int hashCode();
}
Index: src/java/org/apache/lucene/search/FuzzyQuery.java
===================================================================
--- src/java/org/apache/lucene/search/FuzzyQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/FuzzyQuery.java (working copy)
@@ -109,6 +109,7 @@
return prefixLength;
}
+ @Override
protected FilteredTermEnum getEnum(IndexReader reader) throws IOException {
return new FuzzyTermEnum(reader, getTerm(), minimumSimilarity, prefixLength);
}
@@ -120,6 +121,7 @@
return term;
}
+ @Override
public void setRewriteMethod(RewriteMethod method) {
throw new UnsupportedOperationException("FuzzyQuery cannot change rewrite method");
}
@@ -172,6 +174,7 @@
return query;
}
+ @Override
public String toString(String field) {
StringBuilder buffer = new StringBuilder();
if (!term.field().equals(field)) {
Index: src/java/org/apache/lucene/search/FuzzyTermEnum.java
===================================================================
--- src/java/org/apache/lucene/search/FuzzyTermEnum.java (revision 830378)
+++ src/java/org/apache/lucene/search/FuzzyTermEnum.java (working copy)
@@ -125,6 +125,7 @@
* The termCompare method in FuzzyTermEnum uses Levenshtein distance to
* calculate the distance between the given term and the comparing term.
*/
+ @Override
protected final boolean termCompare(Term term) {
if (field == term.field() && term.text().startsWith(prefix)) {
final String target = term.text().substring(prefix.length());
@@ -136,11 +137,13 @@
}
/** {@inheritDoc} */
+ @Override
public final float difference() {
return (similarity - minimumSimilarity) * scale_factor;
}
/** {@inheritDoc} */
+ @Override
public final boolean endEnum() {
return endEnum;
}
@@ -271,6 +274,7 @@
}
/** {@inheritDoc} */
+ @Override
public void close() throws IOException {
p = d = null;
searchTerm = null;
Index: src/java/org/apache/lucene/search/HitQueue.java
===================================================================
--- src/java/org/apache/lucene/search/HitQueue.java (revision 830378)
+++ src/java/org/apache/lucene/search/HitQueue.java (working copy)
@@ -68,6 +68,7 @@
}
// Returns null if prePopulate is false.
+ @Override
protected ScoreDoc getSentinelObject() {
// Always set the doc Id to MAX_VALUE so that it won't be favored by
// lessThan. This generally should not happen since if score is not NEG_INF,
@@ -75,6 +76,7 @@
return !prePopulate ? null : new ScoreDoc(Integer.MAX_VALUE, Float.NEGATIVE_INFINITY);
}
+ @Override
protected final boolean lessThan(ScoreDoc hitA, ScoreDoc hitB) {
if (hitA.score == hitB.score)
return hitA.doc > hitB.doc;
Index: src/java/org/apache/lucene/search/IndexSearcher.java
===================================================================
--- src/java/org/apache/lucene/search/IndexSearcher.java (revision 830378)
+++ src/java/org/apache/lucene/search/IndexSearcher.java (working copy)
@@ -116,17 +116,20 @@
* If the IndexReader was supplied implicitly by specifying a directory, then
* the IndexReader gets closed.
*/
+ @Override
public void close() throws IOException {
if(closeReader)
reader.close();
}
// inherit javadoc
+ @Override
public int docFreq(Term term) throws IOException {
return reader.docFreq(term);
}
// inherit javadoc
+ @Override
public Document doc(int i) throws CorruptIndexException, IOException {
return reader.document(i);
}
@@ -137,11 +140,13 @@
}
// inherit javadoc
+ @Override
public int maxDoc() throws IOException {
return reader.maxDoc();
}
// inherit javadoc
+ @Override
public TopDocs search(Weight weight, Filter filter, final int nDocs) throws IOException {
if (nDocs <= 0) {
@@ -153,6 +158,7 @@
return collector.topDocs();
}
+ @Override
public TopFieldDocs search(Weight weight, Filter filter,
final int nDocs, Sort sort) throws IOException {
return search(weight, filter, nDocs, sort, true);
@@ -186,6 +192,7 @@
return (TopFieldDocs) collector.topDocs();
}
+ @Override
public void search(Weight weight, Filter filter, Collector collector)
throws IOException {
@@ -251,6 +258,7 @@
}
}
+ @Override
public Query rewrite(Query original) throws IOException {
Query query = original;
for (Query rewrittenQuery = query.rewrite(reader); rewrittenQuery != query;
@@ -260,6 +268,7 @@
return query;
}
+ @Override
public Explanation explain(Weight weight, int doc) throws IOException {
int n = ReaderUtil.subIndex(doc, docStarts);
int deBasedDoc = doc - docStarts[n];
Index: src/java/org/apache/lucene/search/MultiSearcher.java
===================================================================
--- src/java/org/apache/lucene/search/MultiSearcher.java (revision 830378)
+++ src/java/org/apache/lucene/search/MultiSearcher.java (working copy)
@@ -52,6 +52,7 @@
setSimilarity(similarity);
}
+ @Override
public int docFreq(Term term) {
int df;
try {
@@ -63,6 +64,7 @@
return df;
}
+ @Override
public int[] docFreqs(Term[] terms) {
int[] result = new int[terms.length];
for (int i = 0; i < terms.length; i++) {
@@ -71,10 +73,12 @@
return result;
}
+ @Override
public int maxDoc() {
return maxDoc;
}
+ @Override
public Query rewrite(Query query) {
// this is a bit of a hack. We know that a query which
// creates a Weight based on this Dummy-Searcher is
@@ -83,10 +87,12 @@
return query;
}
+ @Override
public void close() {
throw new UnsupportedOperationException();
}
+ @Override
public Document doc(int i) {
throw new UnsupportedOperationException();
}
@@ -95,18 +101,22 @@
throw new UnsupportedOperationException();
}
+ @Override
public Explanation explain(Weight weight,int doc) {
throw new UnsupportedOperationException();
}
+ @Override
public void search(Weight weight, Filter filter, Collector results) {
throw new UnsupportedOperationException();
}
+ @Override
public TopDocs search(Weight weight,Filter filter,int n) {
throw new UnsupportedOperationException();
}
+ @Override
public TopFieldDocs search(Weight weight,Filter filter,int n,Sort sort) {
throw new UnsupportedOperationException();
}
@@ -138,11 +148,13 @@
}
// inherit javadoc
+ @Override
public void close() throws IOException {
for (int i = 0; i < searchables.length; i++)
searchables[i].close();
}
+ @Override
public int docFreq(Term term) throws IOException {
int docFreq = 0;
for (int i = 0; i < searchables.length; i++)
@@ -151,6 +163,7 @@
}
// inherit javadoc
+ @Override
public Document doc(int n) throws CorruptIndexException, IOException {
int i = subSearcher(n); // find searcher index
return searchables[i].doc(n - starts[i]); // dispatch to searcher
@@ -174,10 +187,12 @@
return n - starts[subSearcher(n)];
}
+ @Override
public int maxDoc() throws IOException {
return maxDoc;
}
+ @Override
public TopDocs search(Weight weight, Filter filter, int nDocs)
throws IOException {
@@ -205,6 +220,7 @@
return new TopDocs(totalHits, scoreDocs, maxScore);
}
+ @Override
public TopFieldDocs search (Weight weight, Filter filter, int n, Sort sort)
throws IOException {
FieldDocSortedHitQueue hq = null;
@@ -247,6 +263,7 @@
}
// inherit javadoc
+ @Override
public void search(Weight weight, Filter filter, final Collector collector)
throws IOException {
for (int i = 0; i < searchables.length; i++) {
@@ -254,15 +271,19 @@
final int start = starts[i];
final Collector hc = new Collector() {
+ @Override
public void setScorer(Scorer scorer) throws IOException {
collector.setScorer(scorer);
}
+ @Override
public void collect(int doc) throws IOException {
collector.collect(doc);
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
collector.setNextReader(reader, start + docBase);
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return collector.acceptsDocsOutOfOrder();
}
@@ -272,6 +293,7 @@
}
}
+ @Override
public Query rewrite(Query original) throws IOException {
Query[] queries = new Query[searchables.length];
for (int i = 0; i < searchables.length; i++) {
@@ -280,6 +302,7 @@
return queries[0].combine(queries);
}
+ @Override
public Explanation explain(Weight weight, int doc) throws IOException {
int i = subSearcher(doc); // find searcher index
return searchables[i].explain(weight, doc - starts[i]); // dispatch to searcher
@@ -300,6 +323,7 @@
*
* @return rewritten queries
*/
+ @Override
protected Weight createWeight(Query original) throws IOException {
// step 1
Query rewrittenQuery = rewrite(original);
Index: src/java/org/apache/lucene/search/MultiTermQuery.java
===================================================================
--- src/java/org/apache/lucene/search/MultiTermQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/MultiTermQuery.java (working copy)
@@ -67,6 +67,7 @@
}
private static final class ConstantScoreFilterRewrite extends RewriteMethod implements Serializable {
+ @Override
public Query rewrite(IndexReader reader, MultiTermQuery query) {
Query result = new ConstantScoreQuery(new MultiTermQueryWrapperFilter(query));
result.setBoost(query.getBoost());
@@ -94,6 +95,7 @@
public final static RewriteMethod CONSTANT_SCORE_FILTER_REWRITE = new ConstantScoreFilterRewrite();
private static class ScoringBooleanQueryRewrite extends RewriteMethod implements Serializable {
+ @Override
public Query rewrite(IndexReader reader, MultiTermQuery query) throws IOException {
FilteredTermEnum enumerator = query.getEnum(reader);
@@ -138,6 +140,7 @@
public final static RewriteMethod SCORING_BOOLEAN_QUERY_REWRITE = new ScoringBooleanQueryRewrite();
private static class ConstantScoreBooleanQueryRewrite extends ScoringBooleanQueryRewrite implements Serializable {
+ @Override
public Query rewrite(IndexReader reader, MultiTermQuery query) throws IOException {
// strip the scores off
Query result = new ConstantScoreQuery(new QueryWrapperFilter(super.rewrite(reader, query)));
@@ -146,6 +149,7 @@
}
// Make sure we are still a singleton even after deserializing
+ @Override
protected Object readResolve() {
return CONSTANT_SCORE_BOOLEAN_QUERY_REWRITE;
}
@@ -212,6 +216,7 @@
return docCountPercent;
}
+ @Override
public Query rewrite(IndexReader reader, MultiTermQuery query) throws IOException {
// Get the enum and start visiting terms. If we
// exhaust the enum before hitting either of the
@@ -361,6 +366,7 @@
numberOfTerms += inc;
}
+ @Override
public Query rewrite(IndexReader reader) throws IOException {
return rewriteMethod.rewrite(reader, this);
}
Index: src/java/org/apache/lucene/search/MultiTermQueryWrapperFilter.java
===================================================================
--- src/java/org/apache/lucene/search/MultiTermQueryWrapperFilter.java (revision 830378)
+++ src/java/org/apache/lucene/search/MultiTermQueryWrapperFilter.java (working copy)
@@ -142,6 +142,7 @@
// else fill into a OpenBitSet
final OpenBitSet bitSet = new OpenBitSet(reader.maxDoc());
new TermGenerator() {
+ @Override
public void handleDoc(int doc) {
bitSet.set(doc);
}
Index: src/java/org/apache/lucene/search/ParallelMultiSearcher.java
===================================================================
--- src/java/org/apache/lucene/search/ParallelMultiSearcher.java (revision 830378)
+++ src/java/org/apache/lucene/search/ParallelMultiSearcher.java (working copy)
@@ -32,7 +32,7 @@
private Searchable[] searchables;
private int[] starts;
-
+
/** Creates a searchable which searches searchables. */
public ParallelMultiSearcher(Searchable... searchables) throws IOException {
super(searchables);
@@ -43,6 +43,7 @@
/**
* TODO: parallelize this one too
*/
+ @Override
public int docFreq(Term term) throws IOException {
return super.docFreq(term);
}
@@ -52,6 +53,7 @@
* Searchable, waits for each search to complete and merge
* the results back together.
*/
+ @Override
public TopDocs search(Weight weight, Filter filter, int nDocs)
throws IOException {
HitQueue hq = new HitQueue(nDocs, false);
@@ -97,6 +99,7 @@
* Searchable, waits for each search to complete and merges
* the results back together.
*/
+ @Override
public TopFieldDocs search(Weight weight, Filter filter, int nDocs, Sort sort)
throws IOException {
// don't specify the fields - we'll wait to do this until we get results
@@ -153,6 +156,7 @@
*
* TODO: parallelize this one too
*/
+ @Override
public void search(Weight weight, Filter filter, final Collector collector)
throws IOException {
for (int i = 0; i < searchables.length; i++) {
@@ -160,15 +164,22 @@
final int start = starts[i];
final Collector hc = new Collector() {
+ @Override
public void setScorer(Scorer scorer) throws IOException {
collector.setScorer(scorer);
}
+
+ @Override
public void collect(int doc) throws IOException {
collector.collect(doc);
}
+
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
collector.setNextReader(reader, start + docBase);
}
+
+ @Override
public boolean acceptsDocsOutOfOrder() {
return collector.acceptsDocsOutOfOrder();
}
@@ -176,12 +187,13 @@
searchables[i].search(weight, filter, hc);
}
- }
+ }
/*
* TODO: this one could be parallelized too
* @see org.apache.lucene.search.Searchable#rewrite(org.apache.lucene.search.Query)
*/
+ @Override
public Query rewrite(Query original) throws IOException {
return super.rewrite(original);
}
@@ -230,6 +242,7 @@
this.sort = sort;
}
+ @Override
@SuppressWarnings ("unchecked")
public void run() {
try {
Index: src/java/org/apache/lucene/search/payloads/AveragePayloadFunction.java
===================================================================
--- src/java/org/apache/lucene/search/payloads/AveragePayloadFunction.java (revision 830378)
+++ src/java/org/apache/lucene/search/payloads/AveragePayloadFunction.java (working copy)
@@ -26,14 +26,17 @@
**/
public class AveragePayloadFunction extends PayloadFunction{
+ @Override
public float currentScore(int docId, String field, int start, int end, int numPayloadsSeen, float currentScore, float currentPayloadScore) {
return currentPayloadScore + currentScore;
}
+ @Override
public float docScore(int docId, String field, int numPayloadsSeen, float payloadScore) {
return numPayloadsSeen > 0 ? (payloadScore / numPayloadsSeen) : 1;
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = 1;
@@ -41,6 +44,7 @@
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj)
return true;
Index: src/java/org/apache/lucene/search/payloads/MaxPayloadFunction.java
===================================================================
--- src/java/org/apache/lucene/search/payloads/MaxPayloadFunction.java (revision 830378)
+++ src/java/org/apache/lucene/search/payloads/MaxPayloadFunction.java (working copy)
@@ -25,14 +25,17 @@
*
**/
public class MaxPayloadFunction extends PayloadFunction {
+ @Override
public float currentScore(int docId, String field, int start, int end, int numPayloadsSeen, float currentScore, float currentPayloadScore) {
return Math.max(currentPayloadScore, currentScore);
}
+ @Override
public float docScore(int docId, String field, int numPayloadsSeen, float payloadScore) {
return numPayloadsSeen > 0 ? payloadScore : 1;
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = 1;
@@ -40,6 +43,7 @@
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj)
return true;
Index: src/java/org/apache/lucene/search/payloads/MinPayloadFunction.java
===================================================================
--- src/java/org/apache/lucene/search/payloads/MinPayloadFunction.java (revision 830378)
+++ src/java/org/apache/lucene/search/payloads/MinPayloadFunction.java (working copy)
@@ -23,14 +23,17 @@
**/
public class MinPayloadFunction extends PayloadFunction {
+ @Override
public float currentScore(int docId, String field, int start, int end, int numPayloadsSeen, float currentScore, float currentPayloadScore) {
return Math.min(currentPayloadScore, currentScore);
}
+ @Override
public float docScore(int docId, String field, int numPayloadsSeen, float payloadScore) {
return numPayloadsSeen > 0 ? payloadScore : 1;
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = 1;
@@ -38,6 +41,7 @@
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj)
return true;
Index: src/java/org/apache/lucene/search/payloads/PayloadFunction.java
===================================================================
--- src/java/org/apache/lucene/search/payloads/PayloadFunction.java (revision 830378)
+++ src/java/org/apache/lucene/search/payloads/PayloadFunction.java (working copy)
@@ -56,8 +56,10 @@
*/
public abstract float docScore(int docId, String field, int numPayloadsSeen, float payloadScore);
+ @Override
public abstract int hashCode();
+ @Override
public abstract boolean equals(Object o);
}
Index: src/java/org/apache/lucene/search/payloads/PayloadNearQuery.java
===================================================================
--- src/java/org/apache/lucene/search/payloads/PayloadNearQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/payloads/PayloadNearQuery.java (working copy)
@@ -203,6 +203,7 @@
}
//
+ @Override
protected boolean setFreqCurrentDoc() throws IOException {
if (!more) {
return false;
Index: src/java/org/apache/lucene/search/PhraseQueue.java
===================================================================
--- src/java/org/apache/lucene/search/PhraseQueue.java (revision 830378)
+++ src/java/org/apache/lucene/search/PhraseQueue.java (working copy)
@@ -24,6 +24,7 @@
initialize(size);
}
+ @Override
protected final boolean lessThan(PhrasePositions pp1, PhrasePositions pp2) {
if (pp1.doc == pp2.doc)
if (pp1.position == pp2.position)
Index: src/java/org/apache/lucene/search/PositiveScoresOnlyCollector.java
===================================================================
--- src/java/org/apache/lucene/search/PositiveScoresOnlyCollector.java (revision 830378)
+++ src/java/org/apache/lucene/search/PositiveScoresOnlyCollector.java (working copy)
@@ -35,16 +35,19 @@
this.c = c;
}
+ @Override
public void collect(int doc) throws IOException {
if (scorer.score() > 0) {
c.collect(doc);
}
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
c.setNextReader(reader, docBase);
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
// Set a ScoreCachingWrappingScorer in case the wrapped Collector will call
// score() also.
@@ -52,6 +55,7 @@
c.setScorer(this.scorer);
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return c.acceptsDocsOutOfOrder();
}
Index: src/java/org/apache/lucene/search/PrefixFilter.java
===================================================================
--- src/java/org/apache/lucene/search/PrefixFilter.java (revision 830378)
+++ src/java/org/apache/lucene/search/PrefixFilter.java (working copy)
@@ -32,6 +32,7 @@
public Term getPrefix() { return query.getPrefix(); }
/** Prints a user-readable version of this query. */
+ @Override
public String toString () {
StringBuilder buffer = new StringBuilder();
buffer.append("PrefixFilter(");
Index: src/java/org/apache/lucene/search/PrefixQuery.java
===================================================================
--- src/java/org/apache/lucene/search/PrefixQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/PrefixQuery.java (working copy)
@@ -40,6 +40,7 @@
/** Returns the prefix of this query. */
public Term getPrefix() { return prefix; }
+ @Override
protected FilteredTermEnum getEnum(IndexReader reader) throws IOException {
return new PrefixTermEnum(reader, prefix);
}
Index: src/java/org/apache/lucene/search/PrefixTermEnum.java
===================================================================
--- src/java/org/apache/lucene/search/PrefixTermEnum.java (revision 830378)
+++ src/java/org/apache/lucene/search/PrefixTermEnum.java (working copy)
@@ -41,10 +41,12 @@
setEnum(reader.terms(new Term(prefix.field(), prefix.text())));
}
+ @Override
public float difference() {
return 1.0f;
}
+ @Override
protected boolean endEnum() {
return endEnum;
}
@@ -53,6 +55,7 @@
return prefix;
}
+ @Override
protected boolean termCompare(Term term) {
if (term.field() == prefix.field() && term.text().startsWith(prefix.text())) {
return true;
Index: src/java/org/apache/lucene/search/Query.java
===================================================================
--- src/java/org/apache/lucene/search/Query.java (revision 830378)
+++ src/java/org/apache/lucene/search/Query.java (working copy)
@@ -78,6 +78,7 @@
public abstract String toString(String field);
/** Prints a query to a string. */
+ @Override
public String toString() {
return toString("");
}
@@ -204,6 +205,7 @@
}
/** Returns a clone of this query. */
+ @Override
public Object clone() {
try {
return super.clone();
@@ -212,6 +214,7 @@
}
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = 1;
@@ -219,6 +222,7 @@
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj)
return true;
Index: src/java/org/apache/lucene/search/QueryTermVector.java
===================================================================
--- src/java/org/apache/lucene/search/QueryTermVector.java (revision 830378)
+++ src/java/org/apache/lucene/search/QueryTermVector.java (working copy)
@@ -106,6 +106,7 @@
}
}
+ @Override
public final String toString() {
StringBuilder sb = new StringBuilder();
sb.append('{');
Index: src/java/org/apache/lucene/search/ScoreDoc.java
===================================================================
--- src/java/org/apache/lucene/search/ScoreDoc.java (revision 830378)
+++ src/java/org/apache/lucene/search/ScoreDoc.java (working copy)
@@ -35,6 +35,7 @@
}
// A convenience method for debugging.
+ @Override
public String toString() {
return "doc=" + doc + " score=" + score;
}
Index: src/java/org/apache/lucene/search/SimilarityDelegator.java
===================================================================
--- src/java/org/apache/lucene/search/SimilarityDelegator.java (revision 830378)
+++ src/java/org/apache/lucene/search/SimilarityDelegator.java (working copy)
@@ -34,34 +34,42 @@
this.delegee = delegee;
}
+ @Override
public float computeNorm(String fieldName, FieldInvertState state) {
return delegee.computeNorm(fieldName, state);
}
+ @Override
public float lengthNorm(String fieldName, int numTerms) {
return delegee.lengthNorm(fieldName, numTerms);
}
+ @Override
public float queryNorm(float sumOfSquaredWeights) {
return delegee.queryNorm(sumOfSquaredWeights);
}
+ @Override
public float tf(float freq) {
return delegee.tf(freq);
}
+ @Override
public float sloppyFreq(int distance) {
return delegee.sloppyFreq(distance);
}
+ @Override
public float idf(int docFreq, int numDocs) {
return delegee.idf(docFreq, numDocs);
}
+ @Override
public float coord(int overlap, int maxOverlap) {
return delegee.coord(overlap, maxOverlap);
}
+ @Override
public float scorePayload(int docId, String fieldName, int start, int end, byte [] payload, int offset, int length) {
return delegee.scorePayload(docId, fieldName, start, end, payload, offset, length);
}
Index: src/java/org/apache/lucene/search/SloppyPhraseScorer.java
===================================================================
--- src/java/org/apache/lucene/search/SloppyPhraseScorer.java (revision 830378)
+++ src/java/org/apache/lucene/search/SloppyPhraseScorer.java (working copy)
@@ -52,6 +52,7 @@
* would get same score as "g f"~2, although "c b"~2 could be matched twice.
* We may want to fix this in the future (currently not, for performance reasons).
*/
+ @Override
protected final float phraseFreq() throws IOException {
int end = initPhrasePositions();
Index: src/java/org/apache/lucene/search/Sort.java
===================================================================
--- src/java/org/apache/lucene/search/Sort.java (revision 830378)
+++ src/java/org/apache/lucene/search/Sort.java (working copy)
@@ -151,6 +151,7 @@
return fields;
}
+ @Override
public String toString() {
StringBuilder buffer = new StringBuilder();
@@ -164,6 +165,7 @@
}
/** Returns true if o is equal to this. */
+ @Override
public boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof Sort)) return false;
@@ -172,6 +174,7 @@
}
/** Returns a hash code value for this object. */
+ @Override
public int hashCode() {
// TODO in Java 1.5: switch to Arrays.hashCode(). The
// Java 1.4 workaround below calculates the same hashCode
Index: src/java/org/apache/lucene/search/SortField.java
===================================================================
--- src/java/org/apache/lucene/search/SortField.java (revision 830378)
+++ src/java/org/apache/lucene/search/SortField.java (working copy)
@@ -260,6 +260,7 @@
return reverse;
}
+ @Override
public String toString() {
StringBuilder buffer = new StringBuilder();
switch (type) {
@@ -323,6 +324,7 @@
* {@link FieldComparatorSource} or {@link
* FieldCache.Parser} was provided, it must properly
* implement equals (unless a singleton is always used). */
+ @Override
public boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof SortField)) return false;
@@ -342,6 +344,7 @@
* FieldCache.Parser} was provided, it must properly
* implement hashCode (unless a singleton is always
* used). */
+ @Override
public int hashCode() {
int hash=type^0x346565dd + Boolean.valueOf(reverse).hashCode()^0xaf5998bb;
if (field != null) hash += field.hashCode()^0xff5685dd;
Index: src/java/org/apache/lucene/search/SpanQueryFilter.java
===================================================================
--- src/java/org/apache/lucene/search/SpanQueryFilter.java (revision 830378)
+++ src/java/org/apache/lucene/search/SpanQueryFilter.java (working copy)
@@ -54,11 +54,13 @@
this.query = query;
}
+ @Override
public DocIdSet getDocIdSet(IndexReader reader) throws IOException {
SpanFilterResult result = bitSpans(reader);
return result.getDocIdSet();
}
+ @Override
public SpanFilterResult bitSpans(IndexReader reader) throws IOException {
final OpenBitSet bits = new OpenBitSet(reader.maxDoc());
@@ -86,14 +88,17 @@
return query;
}
+ @Override
public String toString() {
return "SpanQueryFilter(" + query + ")";
}
+ @Override
public boolean equals(Object o) {
return o instanceof SpanQueryFilter && this.query.equals(((SpanQueryFilter) o).query);
}
+ @Override
public int hashCode() {
return query.hashCode() ^ 0x923F64B9;
}
Index: src/java/org/apache/lucene/search/spans/FieldMaskingSpanQuery.java
===================================================================
--- src/java/org/apache/lucene/search/spans/FieldMaskingSpanQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/FieldMaskingSpanQuery.java (working copy)
@@ -79,6 +79,7 @@
this.field = maskedField;
}
+ @Override
public String getField() {
return field;
}
@@ -90,22 +91,27 @@
// :NOTE: getBoost and setBoost are not proxied to the maskedQuery
// ...this is done to be more consistent with things like SpanFirstQuery
+ @Override
public Spans getSpans(IndexReader reader) throws IOException {
return maskedQuery.getSpans(reader);
}
+ @Override
public void extractTerms(Set terms) {
maskedQuery.extractTerms(terms);
}
+ @Override
public Weight createWeight(Searcher searcher) throws IOException {
return maskedQuery.createWeight(searcher);
}
+ @Override
public Similarity getSimilarity(Searcher searcher) {
return maskedQuery.getSimilarity(searcher);
}
+ @Override
public Query rewrite(IndexReader reader) throws IOException {
FieldMaskingSpanQuery clone = null;
@@ -122,6 +128,7 @@
}
}
+ @Override
public String toString(String field) {
StringBuilder buffer = new StringBuilder();
buffer.append("mask(");
@@ -133,6 +140,7 @@
return buffer.toString();
}
+ @Override
public boolean equals(Object o) {
if (!(o instanceof FieldMaskingSpanQuery))
return false;
@@ -143,6 +151,7 @@
}
+ @Override
public int hashCode() {
return getMaskedQuery().hashCode()
^ getField().hashCode()
Index: src/java/org/apache/lucene/search/spans/NearSpansOrdered.java
===================================================================
--- src/java/org/apache/lucene/search/spans/NearSpansOrdered.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/NearSpansOrdered.java (working copy)
@@ -101,12 +101,15 @@
}
// inherit javadocs
+ @Override
public int doc() { return matchDoc; }
// inherit javadocs
+ @Override
public int start() { return matchStart; }
// inherit javadocs
+ @Override
public int end() { return matchEnd; }
public Spans[] getSubSpans() {
@@ -115,16 +118,19 @@
// TODO: Remove warning after API has been finalized
// TODO: Would be nice to be able to lazy load payloads
+ @Override
public Collection getPayload() throws IOException {
return matchPayload;
}
// TODO: Remove warning after API has been finalized
- public boolean isPayloadAvailable() {
+ @Override
+ public boolean isPayloadAvailable() {
return matchPayload.isEmpty() == false;
}
// inherit javadocs
+ @Override
public boolean next() throws IOException {
if (firstTime) {
firstTime = false;
@@ -143,6 +149,7 @@
}
// inherit javadocs
+ @Override
public boolean skipTo(int target) throws IOException {
if (firstTime) {
firstTime = false;
@@ -327,6 +334,7 @@
return match; // ordered and allowed slop
}
+ @Override
public String toString() {
return getClass().getName() + "("+query.toString()+")@"+
(firstTime?"START":(more?(doc()+":"+start()+"-"+end()):"END"));
Index: src/java/org/apache/lucene/search/spans/NearSpansUnordered.java
===================================================================
--- src/java/org/apache/lucene/search/spans/NearSpansUnordered.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/NearSpansUnordered.java (working copy)
@@ -56,6 +56,7 @@
initialize(size);
}
+ @Override
protected final boolean lessThan(SpansCell spans1, SpansCell spans2) {
if (spans1.doc() == spans2.doc()) {
return NearSpansOrdered.docSpansOrdered(spans1, spans2);
@@ -78,10 +79,12 @@
this.index = index;
}
+ @Override
public boolean next() throws IOException {
return adjust(spans.next());
}
+ @Override
public boolean skipTo(int target) throws IOException {
return adjust(spans.skipTo(target));
}
@@ -103,19 +106,27 @@
return condition;
}
+ @Override
public int doc() { return spans.doc(); }
+
+ @Override
public int start() { return spans.start(); }
+
+ @Override
public int end() { return spans.end(); }
// TODO: Remove warning after API has been finalized
+ @Override
public Collection getPayload() throws IOException {
return new ArrayList(spans.getPayload());
}
// TODO: Remove warning after API has been finalized
- public boolean isPayloadAvailable() {
+ @Override
+ public boolean isPayloadAvailable() {
return spans.isPayloadAvailable();
}
+ @Override
public String toString() { return spans.toString() + "#" + index; }
}
@@ -138,6 +149,7 @@
public Spans[] getSubSpans() {
return subSpans;
}
+ @Override
public boolean next() throws IOException {
if (firstTime) {
initList(true);
@@ -189,6 +201,7 @@
return false; // no more matches
}
+ @Override
public boolean skipTo(int target) throws IOException {
if (firstTime) { // initialize
initList(false);
@@ -213,8 +226,11 @@
private SpansCell min() { return queue.top(); }
+ @Override
public int doc() { return min().doc(); }
+ @Override
public int start() { return min().start(); }
+ @Override
public int end() { return max.end(); }
// TODO: Remove warning after API has been finalized
@@ -223,6 +239,7 @@
* @return Collection of byte[] payloads
* @throws IOException
*/
+ @Override
public Collection getPayload() throws IOException {
Set matchPayload = new HashSet();
for (SpansCell cell = first; cell != null; cell = cell.next) {
@@ -234,6 +251,7 @@
}
// TODO: Remove warning after API has been finalized
+ @Override
public boolean isPayloadAvailable() {
SpansCell pointer = min();
while (pointer != null) {
@@ -246,6 +264,7 @@
return false;
}
+ @Override
public String toString() {
return getClass().getName() + "("+query.toString()+")@"+
(firstTime?"START":(more?(doc()+":"+start()+"-"+end()):"END"));
Index: src/java/org/apache/lucene/search/spans/SpanFirstQuery.java
===================================================================
--- src/java/org/apache/lucene/search/spans/SpanFirstQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/SpanFirstQuery.java (working copy)
@@ -46,8 +46,10 @@
/** Return the maximum end position permitted in a match. */
public int getEnd() { return end; }
+ @Override
public String getField() { return match.getField(); }
+ @Override
public String toString(String field) {
StringBuilder buffer = new StringBuilder();
buffer.append("spanFirst(");
@@ -59,20 +61,24 @@
return buffer.toString();
}
+ @Override
public Object clone() {
SpanFirstQuery spanFirstQuery = new SpanFirstQuery((SpanQuery) match.clone(), end);
spanFirstQuery.setBoost(getBoost());
return spanFirstQuery;
}
+ @Override
public void extractTerms(Set terms) {
match.extractTerms(terms);
}
+ @Override
public Spans getSpans(final IndexReader reader) throws IOException {
return new Spans() {
private Spans spans = match.getSpans(reader);
+ @Override
public boolean next() throws IOException {
while (spans.next()) { // scan to next match
if (end() <= end)
@@ -81,6 +87,7 @@
return false;
}
+ @Override
public boolean skipTo(int target) throws IOException {
if (!spans.skipTo(target))
return false;
@@ -89,11 +96,15 @@
}
+ @Override
public int doc() { return spans.doc(); }
+ @Override
public int start() { return spans.start(); }
+ @Override
public int end() { return spans.end(); }
// TODO: Remove warning after API has been finalized
+ @Override
public Collection getPayload() throws IOException {
ArrayList result = null;
if (spans.isPayloadAvailable()) {
@@ -103,10 +114,12 @@
}
// TODO: Remove warning after API has been finalized
- public boolean isPayloadAvailable() {
+ @Override
+ public boolean isPayloadAvailable() {
return spans.isPayloadAvailable();
}
+ @Override
public String toString() {
return "spans(" + SpanFirstQuery.this.toString() + ")";
}
@@ -114,6 +127,7 @@
};
}
+ @Override
public Query rewrite(IndexReader reader) throws IOException {
SpanFirstQuery clone = null;
@@ -130,6 +144,7 @@
}
}
+ @Override
public boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof SpanFirstQuery)) return false;
@@ -140,6 +155,7 @@
&& this.getBoost() == other.getBoost();
}
+ @Override
public int hashCode() {
int h = match.hashCode();
h ^= (h << 8) | (h >>> 25); // reversible
Index: src/java/org/apache/lucene/search/spans/SpanNearQuery.java
===================================================================
--- src/java/org/apache/lucene/search/spans/SpanNearQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/SpanNearQuery.java (working copy)
@@ -79,8 +79,10 @@
/** Return true if matches are required to be in-order.*/
public boolean isInOrder() { return inOrder; }
+ @Override
public String getField() { return field; }
+ @Override
public void extractTerms(Set terms) {
for (final SpanQuery clause : clauses) {
clause.extractTerms(terms);
@@ -88,6 +90,7 @@
}
+ @Override
public String toString(String field) {
StringBuilder buffer = new StringBuilder();
buffer.append("spanNear([");
@@ -108,6 +111,7 @@
return buffer.toString();
}
+ @Override
public Spans getSpans(final IndexReader reader) throws IOException {
if (clauses.size() == 0) // optimize 0-clause case
return new SpanOrQuery(getClauses()).getSpans(reader);
@@ -120,6 +124,7 @@
: (Spans) new NearSpansUnordered(this, reader);
}
+ @Override
public Query rewrite(IndexReader reader) throws IOException {
SpanNearQuery clone = null;
for (int i = 0 ; i < clauses.size(); i++) {
@@ -138,6 +143,7 @@
}
}
+ @Override
public Object clone() {
int sz = clauses.size();
SpanQuery[] newClauses = new SpanQuery[sz];
@@ -151,6 +157,7 @@
}
/** Returns true iff o is equal to this. */
+ @Override
public boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof SpanNearQuery)) return false;
@@ -164,6 +171,7 @@
return getBoost() == spanNearQuery.getBoost();
}
+ @Override
public int hashCode() {
int result;
result = clauses.hashCode();
Index: src/java/org/apache/lucene/search/spans/SpanNotQuery.java
===================================================================
--- src/java/org/apache/lucene/search/spans/SpanNotQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/SpanNotQuery.java (working copy)
@@ -48,10 +48,13 @@
/** Return the SpanQuery whose matches must not overlap those returned. */
public SpanQuery getExclude() { return exclude; }
+ @Override
public String getField() { return include.getField(); }
+ @Override
public void extractTerms(Set terms) { include.extractTerms(terms); }
+ @Override
public String toString(String field) {
StringBuilder buffer = new StringBuilder();
buffer.append("spanNot(");
@@ -63,12 +66,14 @@
return buffer.toString();
}
+ @Override
public Object clone() {
SpanNotQuery spanNotQuery = new SpanNotQuery((SpanQuery)include.clone(),(SpanQuery) exclude.clone());
spanNotQuery.setBoost(getBoost());
return spanNotQuery;
}
+ @Override
public Spans getSpans(final IndexReader reader) throws IOException {
return new Spans() {
private Spans includeSpans = include.getSpans(reader);
@@ -77,6 +82,7 @@
private Spans excludeSpans = exclude.getSpans(reader);
private boolean moreExclude = excludeSpans.next();
+ @Override
public boolean next() throws IOException {
if (moreInclude) // move to next include
moreInclude = includeSpans.next();
@@ -102,6 +108,7 @@
return moreInclude;
}
+ @Override
public boolean skipTo(int target) throws IOException {
if (moreInclude) // skip include
moreInclude = includeSpans.skipTo(target);
@@ -127,11 +134,15 @@
return next(); // scan to next match
}
+ @Override
public int doc() { return includeSpans.doc(); }
+ @Override
public int start() { return includeSpans.start(); }
+ @Override
public int end() { return includeSpans.end(); }
// TODO: Remove warning after API has been finalized
+ @Override
public Collection getPayload() throws IOException {
ArrayList result = null;
if (includeSpans.isPayloadAvailable()) {
@@ -141,10 +152,12 @@
}
// TODO: Remove warning after API has been finalized
- public boolean isPayloadAvailable() {
+ @Override
+ public boolean isPayloadAvailable() {
return includeSpans.isPayloadAvailable();
}
+ @Override
public String toString() {
return "spans(" + SpanNotQuery.this.toString() + ")";
}
@@ -152,6 +165,7 @@
};
}
+ @Override
public Query rewrite(IndexReader reader) throws IOException {
SpanNotQuery clone = null;
@@ -174,6 +188,7 @@
}
/** Returns true iff o is equal to this. */
+ @Override
public boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof SpanNotQuery)) return false;
@@ -184,6 +199,7 @@
&& this.getBoost() == other.getBoost();
}
+ @Override
public int hashCode() {
int h = include.hashCode();
h = (h<<1) | (h >>> 31); // rotate left
Index: src/java/org/apache/lucene/search/spans/SpanOrQuery.java
===================================================================
--- src/java/org/apache/lucene/search/spans/SpanOrQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/SpanOrQuery.java (working copy)
@@ -57,14 +57,17 @@
return clauses.toArray(new SpanQuery[clauses.size()]);
}
+ @Override
public String getField() { return field; }
+ @Override
public void extractTerms(Set terms) {
for(final SpanQuery clause: clauses) {
clause.extractTerms(terms);
}
}
+ @Override
public Object clone() {
int sz = clauses.size();
SpanQuery[] newClauses = new SpanQuery[sz];
@@ -77,6 +80,7 @@
return soq;
}
+ @Override
public Query rewrite(IndexReader reader) throws IOException {
SpanOrQuery clone = null;
for (int i = 0 ; i < clauses.size(); i++) {
@@ -95,6 +99,7 @@
}
}
+ @Override
public String toString(String field) {
StringBuilder buffer = new StringBuilder();
buffer.append("spanOr([");
@@ -111,6 +116,7 @@
return buffer.toString();
}
+ @Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
@@ -123,6 +129,7 @@
return getBoost() == that.getBoost();
}
+ @Override
public int hashCode() {
int h = clauses.hashCode();
h ^= (h << 10) | (h >>> 23);
@@ -136,6 +143,7 @@
initialize(size);
}
+ @Override
protected final boolean lessThan(Spans spans1, Spans spans2) {
if (spans1.doc() == spans2.doc()) {
if (spans1.start() == spans2.start()) {
@@ -149,6 +157,7 @@
}
}
+ @Override
public Spans getSpans(final IndexReader reader) throws IOException {
if (clauses.size() == 1) // optimize 1-clause case
return (clauses.get(0)).getSpans(reader);
@@ -169,6 +178,7 @@
return queue.size() != 0;
}
+ @Override
public boolean next() throws IOException {
if (queue == null) {
return initSpanQueue(-1);
@@ -189,6 +199,7 @@
private Spans top() { return queue.top(); }
+ @Override
public boolean skipTo(int target) throws IOException {
if (queue == null) {
return initSpanQueue(target);
@@ -210,10 +221,14 @@
return next();
}
+ @Override
public int doc() { return top().doc(); }
+ @Override
public int start() { return top().start(); }
+ @Override
public int end() { return top().end(); }
+ @Override
public Collection getPayload() throws IOException {
ArrayList result = null;
Spans theTop = top();
@@ -223,11 +238,13 @@
return result;
}
- public boolean isPayloadAvailable() {
+ @Override
+ public boolean isPayloadAvailable() {
Spans top = top();
return top != null && top.isPayloadAvailable();
}
+ @Override
public String toString() {
return "spans("+SpanOrQuery.this+")@"+
((queue == null)?"START"
Index: src/java/org/apache/lucene/search/spans/SpanQuery.java
===================================================================
--- src/java/org/apache/lucene/search/spans/SpanQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/SpanQuery.java (working copy)
@@ -33,6 +33,7 @@
/** Returns the name of the field matched by this query.*/
public abstract String getField();
+ @Override
public Weight createWeight(Searcher searcher) throws IOException {
return new SpanWeight(this, searcher);
}
Index: src/java/org/apache/lucene/search/spans/SpanTermQuery.java
===================================================================
--- src/java/org/apache/lucene/search/spans/SpanTermQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/SpanTermQuery.java (working copy)
@@ -34,12 +34,15 @@
/** Return the term whose spans are matched. */
public Term getTerm() { return term; }
+ @Override
public String getField() { return term.field(); }
+ @Override
public void extractTerms(Set terms) {
terms.add(term);
}
+ @Override
public String toString(String field) {
StringBuilder buffer = new StringBuilder();
if (term.field().equals(field))
@@ -50,6 +53,7 @@
return buffer.toString();
}
+ @Override
public int hashCode() {
final int prime = 31;
int result = super.hashCode();
@@ -57,6 +61,7 @@
return result;
}
+ @Override
public boolean equals(Object obj) {
if (this == obj)
return true;
@@ -73,6 +78,7 @@
return true;
}
+ @Override
public Spans getSpans(final IndexReader reader) throws IOException {
return new TermSpans(reader.termPositions(term), term);
}
Index: src/java/org/apache/lucene/search/spans/TermSpans.java
===================================================================
--- src/java/org/apache/lucene/search/spans/TermSpans.java (revision 830378)
+++ src/java/org/apache/lucene/search/spans/TermSpans.java (working copy)
@@ -43,6 +43,7 @@
doc = -1;
}
+ @Override
public boolean next() throws IOException {
if (count == freq) {
if (!positions.next()) {
@@ -58,6 +59,7 @@
return true;
}
+ @Override
public boolean skipTo(int target) throws IOException {
if (!positions.skipTo(target)) {
doc = Integer.MAX_VALUE;
@@ -74,19 +76,23 @@
return true;
}
+ @Override
public int doc() {
return doc;
}
+ @Override
public int start() {
return position;
}
+ @Override
public int end() {
return position + 1;
}
// TODO: Remove warning after API has been finalized
+ @Override
public Collection getPayload() throws IOException {
byte [] bytes = new byte[positions.getPayloadLength()];
bytes = positions.getPayload(bytes, 0);
@@ -94,10 +100,12 @@
}
// TODO: Remove warning after API has been finalized
- public boolean isPayloadAvailable() {
+ @Override
+ public boolean isPayloadAvailable() {
return positions.isPayloadAvailable();
}
+ @Override
public String toString() {
return "spans(" + term.toString() + ")@" +
(doc == -1 ? "START" : (doc == Integer.MAX_VALUE) ? "END" : doc + "-" + position);
Index: src/java/org/apache/lucene/search/TermRangeTermEnum.java
===================================================================
--- src/java/org/apache/lucene/search/TermRangeTermEnum.java (revision 830378)
+++ src/java/org/apache/lucene/search/TermRangeTermEnum.java (working copy)
@@ -93,14 +93,17 @@
setEnum(reader.terms(new Term(this.field, startTermText)));
}
+ @Override
public float difference() {
return 1.0f;
}
+ @Override
protected boolean endEnum() {
return endEnum;
}
+ @Override
protected boolean termCompare(Term term) {
if (collator == null) {
// Use Unicode code point ordering
Index: src/java/org/apache/lucene/search/TimeLimitingCollector.java
===================================================================
--- src/java/org/apache/lucene/search/TimeLimitingCollector.java (revision 830378)
+++ src/java/org/apache/lucene/search/TimeLimitingCollector.java (working copy)
@@ -70,6 +70,7 @@
this.setDaemon( true );
}
+ @Override
public void run() {
while (true) {
// TODO: Use System.nanoTime() when Lucene moves to Java SE 5.
@@ -194,6 +195,7 @@
* @throws TimeExceededException
* if the time allowed has exceeded.
*/
+ @Override
public void collect(final int doc) throws IOException {
long time = TIMER_THREAD.getMilliseconds();
if (timeout < time) {
@@ -208,14 +210,17 @@
collector.collect(doc);
}
+ @Override
public void setNextReader(IndexReader reader, int base) throws IOException {
collector.setNextReader(reader, base);
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
collector.setScorer(scorer);
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return collector.acceptsDocsOutOfOrder();
}
Index: src/java/org/apache/lucene/search/TopFieldCollector.java
===================================================================
--- src/java/org/apache/lucene/search/TopFieldCollector.java (revision 830378)
+++ src/java/org/apache/lucene/search/TopFieldCollector.java (working copy)
@@ -63,6 +63,7 @@
bottom = pq.updateTop();
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -89,11 +90,13 @@
}
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
this.docBase = docBase;
comparator.setNextReader(reader, docBase);
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
comparator.setScorer(scorer);
}
@@ -113,6 +116,7 @@
super(queue, numHits, fillFields);
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -138,6 +142,7 @@
}
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return true;
}
@@ -164,6 +169,7 @@
bottom = pq.updateTop();
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -196,6 +202,7 @@
}
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
this.scorer = scorer;
comparator.setScorer(scorer);
@@ -217,6 +224,7 @@
super(queue, numHits, fillFields);
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -248,6 +256,7 @@
}
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return true;
}
@@ -276,6 +285,7 @@
bottom = pq.updateTop();
}
+ @Override
public void collect(int doc) throws IOException {
final float score = scorer.score();
if (score > maxScore) {
@@ -307,6 +317,7 @@
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
this.scorer = scorer;
super.setScorer(scorer);
@@ -326,6 +337,7 @@
super(queue, numHits, fillFields);
}
+ @Override
public void collect(int doc) throws IOException {
final float score = scorer.score();
if (score > maxScore) {
@@ -355,6 +367,7 @@
}
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return true;
}
@@ -383,6 +396,7 @@
bottom = pq.updateTop();
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -429,6 +443,7 @@
}
}
+ @Override
public void setNextReader(IndexReader reader, int docBase) throws IOException {
this.docBase = docBase;
for (int i = 0; i < comparators.length; i++) {
@@ -436,6 +451,7 @@
}
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
// set the scorer on all comparators
for (int i = 0; i < comparators.length; i++) {
@@ -457,6 +473,7 @@
super(queue, numHits, fillFields);
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -505,6 +522,7 @@
}
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return true;
}
@@ -532,6 +550,7 @@
bottom = pq.updateTop();
}
+ @Override
public void collect(int doc) throws IOException {
final float score = scorer.score();
if (score > maxScore) {
@@ -582,6 +601,7 @@
}
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
this.scorer = scorer;
super.setScorer(scorer);
@@ -601,6 +621,7 @@
super(queue, numHits, fillFields);
}
+ @Override
public void collect(int doc) throws IOException {
final float score = scorer.score();
if (score > maxScore) {
@@ -653,6 +674,7 @@
}
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return true;
}
@@ -678,6 +700,7 @@
bottom = pq.updateTop();
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -729,6 +752,7 @@
}
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
this.scorer = scorer;
super.setScorer(scorer);
@@ -749,6 +773,7 @@
super(queue, numHits, fillFields);
}
+ @Override
public void collect(int doc) throws IOException {
++totalHits;
if (queueFull) {
@@ -802,11 +827,13 @@
}
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
this.scorer = scorer;
super.setScorer(scorer);
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return true;
}
@@ -934,6 +961,7 @@
* topDocs(int, int) calls them to return the results.
*/
+ @Override
protected void populateResults(ScoreDoc[] results, int howMany) {
if (fillFields) {
// avoid casting if unnecessary.
@@ -949,6 +977,7 @@
}
}
+ @Override
protected TopDocs newTopDocs(ScoreDoc[] results, int start) {
if (results == null) {
results = EMPTY_SCOREDOCS;
@@ -960,6 +989,7 @@
return new TopFieldDocs(totalHits, results, ((FieldValueHitQueue) pq).getFields(), maxScore);
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return false;
}
Index: src/java/org/apache/lucene/search/TopScoreDocCollector.java
===================================================================
--- src/java/org/apache/lucene/search/TopScoreDocCollector.java (revision 830378)
+++ src/java/org/apache/lucene/search/TopScoreDocCollector.java (working copy)
@@ -42,6 +42,7 @@
super(numHits);
}
+ @Override
public void collect(int doc) throws IOException {
float score = scorer.score();
totalHits++;
@@ -56,6 +57,7 @@
pqTop = pq.updateTop();
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return false;
}
@@ -67,6 +69,7 @@
super(numHits);
}
+ @Override
public void collect(int doc) throws IOException {
float score = scorer.score();
totalHits++;
@@ -79,6 +82,7 @@
pqTop = pq.updateTop();
}
+ @Override
public boolean acceptsDocsOutOfOrder() {
return true;
}
@@ -116,6 +120,7 @@
pqTop = pq.top();
}
+ @Override
protected TopDocs newTopDocs(ScoreDoc[] results, int start) {
if (results == null) {
return EMPTY_TOPDOCS;
@@ -136,10 +141,12 @@
return new TopDocs(totalHits, results, maxScore);
}
+ @Override
public void setNextReader(IndexReader reader, int base) {
docBase = base;
}
+ @Override
public void setScorer(Scorer scorer) throws IOException {
this.scorer = scorer;
}
Index: src/java/org/apache/lucene/search/WildcardQuery.java
===================================================================
--- src/java/org/apache/lucene/search/WildcardQuery.java (revision 830378)
+++ src/java/org/apache/lucene/search/WildcardQuery.java (working copy)
@@ -50,6 +50,7 @@
&& (text.indexOf('*') == text.length() - 1);
}
+ @Override
protected FilteredTermEnum getEnum(IndexReader reader) throws IOException {
if (termContainsWildcard)
return new WildcardTermEnum(reader, getTerm());
Index: src/java/org/apache/lucene/search/WildcardTermEnum.java
===================================================================
--- src/java/org/apache/lucene/search/WildcardTermEnum.java (revision 830378)
+++ src/java/org/apache/lucene/search/WildcardTermEnum.java (working copy)
@@ -65,6 +65,7 @@
setEnum(reader.terms(new Term(searchTerm.field(), pre)));
}
+ @Override
protected final boolean termCompare(Term term) {
if (field == term.field()) {
String searchText = term.text();
@@ -76,10 +77,12 @@
return false;
}
+ @Override
public float difference() {
return 1.0f;
}
+ @Override
public final boolean endEnum() {
return endEnum;
}
Index: src/java/org/apache/lucene/store/BufferedIndexInput.java
===================================================================
--- src/java/org/apache/lucene/store/BufferedIndexInput.java (revision 830378)
+++ src/java/org/apache/lucene/store/BufferedIndexInput.java (working copy)
@@ -33,6 +33,7 @@
private int bufferLength = 0; // end of valid bytes
private int bufferPosition = 0; // next byte to read
+ @Override
public byte readByte() throws IOException {
if (bufferPosition >= bufferLength)
refill();
@@ -88,10 +89,12 @@
throw new IllegalArgumentException("bufferSize must be greater than 0 (got " + bufferSize + ")");
}
+ @Override
public void readBytes(byte[] b, int offset, int len) throws IOException {
readBytes(b, offset, len, true);
}
+ @Override
public void readBytes(byte[] b, int offset, int len, boolean useBuffer) throws IOException {
if(len <= (bufferLength-bufferPosition)){
@@ -169,8 +172,10 @@
protected abstract void readInternal(byte[] b, int offset, int length)
throws IOException;
+ @Override
public long getFilePointer() { return bufferStart + bufferPosition; }
+ @Override
public void seek(long pos) throws IOException {
if (pos >= bufferStart && pos < (bufferStart + bufferLength))
bufferPosition = (int)(pos - bufferStart); // seek within buffer
@@ -188,6 +193,7 @@
*/
protected abstract void seekInternal(long pos) throws IOException;
+ @Override
public Object clone() {
BufferedIndexInput clone = (BufferedIndexInput)super.clone();
Index: src/java/org/apache/lucene/store/BufferedIndexOutput.java
===================================================================
--- src/java/org/apache/lucene/store/BufferedIndexOutput.java (revision 830378)
+++ src/java/org/apache/lucene/store/BufferedIndexOutput.java (working copy)
@@ -30,6 +30,7 @@
/** Writes a single byte.
* @see IndexInput#readByte()
*/
+ @Override
public void writeByte(byte b) throws IOException {
if (bufferPosition >= BUFFER_SIZE)
flush();
@@ -41,6 +42,7 @@
* @param length the number of bytes to write
* @see IndexInput#readBytes(byte[],int,int)
*/
+ @Override
public void writeBytes(byte[] b, int offset, int length) throws IOException {
int bytesLeft = BUFFER_SIZE - bufferPosition;
// is there enough space in the buffer?
@@ -81,6 +83,7 @@
}
/** Forces any buffered output to be written. */
+ @Override
public void flush() throws IOException {
flushBuffer(buffer, bufferPosition);
bufferStart += bufferPosition;
@@ -105,6 +108,7 @@
protected abstract void flushBuffer(byte[] b, int offset, int len) throws IOException;
/** Closes this stream to further operations. */
+ @Override
public void close() throws IOException {
flush();
}
@@ -113,6 +117,7 @@
* occur.
* @see #seek(long)
*/
+ @Override
public long getFilePointer() {
return bufferStart + bufferPosition;
}
@@ -120,12 +125,14 @@
/** Sets current position in this file, where the next write will occur.
* @see #getFilePointer()
*/
+ @Override
public void seek(long pos) throws IOException {
flush();
bufferStart = pos;
}
/** The number of bytes in the file. */
+ @Override
public abstract long length() throws IOException;
Index: src/java/org/apache/lucene/store/ChecksumIndexInput.java
===================================================================
--- src/java/org/apache/lucene/store/ChecksumIndexInput.java (revision 830378)
+++ src/java/org/apache/lucene/store/ChecksumIndexInput.java (working copy)
@@ -32,12 +32,14 @@
digest = new CRC32();
}
+ @Override
public byte readByte() throws IOException {
final byte b = main.readByte();
digest.update(b);
return b;
}
+ @Override
public void readBytes(byte[] b, int offset, int len)
throws IOException {
main.readBytes(b, offset, len);
@@ -49,18 +51,22 @@
return digest.getValue();
}
+ @Override
public void close() throws IOException {
main.close();
}
+ @Override
public long getFilePointer() {
return main.getFilePointer();
}
+ @Override
public void seek(long pos) {
throw new RuntimeException("not allowed");
}
+ @Override
public long length() {
return main.length();
}
Index: src/java/org/apache/lucene/store/ChecksumIndexOutput.java
===================================================================
--- src/java/org/apache/lucene/store/ChecksumIndexOutput.java (revision 830378)
+++ src/java/org/apache/lucene/store/ChecksumIndexOutput.java (working copy)
@@ -32,11 +32,13 @@
digest = new CRC32();
}
+ @Override
public void writeByte(byte b) throws IOException {
digest.update(b);
main.writeByte(b);
}
+ @Override
public void writeBytes(byte[] b, int offset, int length) throws IOException {
digest.update(b, offset, length);
main.writeBytes(b, offset, length);
@@ -46,18 +48,22 @@
return digest.getValue();
}
+ @Override
public void flush() throws IOException {
main.flush();
}
+ @Override
public void close() throws IOException {
main.close();
}
+ @Override
public long getFilePointer() {
return main.getFilePointer();
}
+ @Override
public void seek(long pos) {
throw new RuntimeException("not allowed");
}
@@ -86,6 +92,7 @@
main.writeLong(getChecksum());
}
+ @Override
public long length() throws IOException {
return main.length();
}
Index: src/java/org/apache/lucene/store/FileSwitchDirectory.java
===================================================================
--- src/java/org/apache/lucene/store/FileSwitchDirectory.java (revision 830378)
+++ src/java/org/apache/lucene/store/FileSwitchDirectory.java (working copy)
@@ -59,6 +59,7 @@
return secondaryDir;
}
+ @Override
public void close() throws IOException {
if (doClose) {
try {
@@ -70,6 +71,7 @@
}
}
+ @Override
public String[] listAll() throws IOException {
String[] primaryFiles = primaryDir.listAll();
String[] secondaryFiles = secondaryDir.listAll();
@@ -97,34 +99,42 @@
}
}
+ @Override
public boolean fileExists(String name) throws IOException {
return getDirectory(name).fileExists(name);
}
+ @Override
public long fileModified(String name) throws IOException {
return getDirectory(name).fileModified(name);
}
+ @Override
public void touchFile(String name) throws IOException {
getDirectory(name).touchFile(name);
}
+ @Override
public void deleteFile(String name) throws IOException {
getDirectory(name).deleteFile(name);
}
+ @Override
public long fileLength(String name) throws IOException {
return getDirectory(name).fileLength(name);
}
+ @Override
public IndexOutput createOutput(String name) throws IOException {
return getDirectory(name).createOutput(name);
}
+ @Override
public void sync(String name) throws IOException {
getDirectory(name).sync(name);
}
+ @Override
public IndexInput openInput(String name) throws IOException {
return getDirectory(name).openInput(name);
}
Index: src/java/org/apache/lucene/store/FSDirectory.java
===================================================================
--- src/java/org/apache/lucene/store/FSDirectory.java (revision 830378)
+++ src/java/org/apache/lucene/store/FSDirectory.java (working copy)
@@ -238,12 +238,14 @@
/** Lists all files (not subdirectories) in the
* directory.
* @see #listAll(File) */
+ @Override
public String[] listAll() throws IOException {
ensureOpen();
return listAll(directory);
}
/** Returns true iff a file with the given name exists. */
+ @Override
public boolean fileExists(String name) {
ensureOpen();
File file = new File(directory, name);
@@ -251,6 +253,7 @@
}
/** Returns the time the named file was last modified. */
+ @Override
public long fileModified(String name) {
ensureOpen();
File file = new File(directory, name);
@@ -264,6 +267,7 @@
}
/** Set the modified time of an existing file to now. */
+ @Override
public void touchFile(String name) {
ensureOpen();
File file = new File(directory, name);
@@ -271,6 +275,7 @@
}
/** Returns the length in bytes of a file in the directory. */
+ @Override
public long fileLength(String name) {
ensureOpen();
File file = new File(directory, name);
@@ -278,6 +283,7 @@
}
/** Removes an existing file in the directory. */
+ @Override
public void deleteFile(String name) throws IOException {
ensureOpen();
File file = new File(directory, name);
@@ -285,6 +291,7 @@
throw new IOException("Cannot delete " + file);
}
+ @Override
public void sync(String name) throws IOException {
ensureOpen();
File fullFile = new File(directory, name);
@@ -323,6 +330,7 @@
}
// Inherit javadoc
+ @Override
public IndexInput openInput(String name) throws IOException {
ensureOpen();
return openInput(name, BufferedIndexInput.BUFFER_SIZE);
@@ -335,6 +343,7 @@
{'0','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'};
+ @Override
public String getLockID() {
ensureOpen();
String dirName; // name to be hashed
@@ -360,6 +369,7 @@
}
/** Closes the store to future operations. */
+ @Override
public synchronized void close() {
isOpen = false;
}
@@ -370,6 +380,7 @@
}
/** For debug output. */
+ @Override
public String toString() {
return this.getClass().getName() + "@" + directory;
}
Index: src/java/org/apache/lucene/store/IndexInput.java
===================================================================
--- src/java/org/apache/lucene/store/IndexInput.java (revision 830378)
+++ src/java/org/apache/lucene/store/IndexInput.java (working copy)
@@ -217,6 +217,7 @@
* different points in the input from each other and from the stream they
* were cloned from.
*/
+ @Override
public Object clone() {
IndexInput clone = null;
try {
Index: src/java/org/apache/lucene/store/MMapDirectory.java
===================================================================
--- src/java/org/apache/lucene/store/MMapDirectory.java (revision 830378)
+++ src/java/org/apache/lucene/store/MMapDirectory.java (working copy)
@@ -202,6 +202,7 @@
this.buffer = raf.getChannel().map(MapMode.READ_ONLY, 0, length);
}
+ @Override
public byte readByte() throws IOException {
try {
return buffer.get();
@@ -210,6 +211,7 @@
}
}
+ @Override
public void readBytes(byte[] b, int offset, int len) throws IOException {
try {
buffer.get(b, offset, len);
@@ -218,18 +220,22 @@
}
}
+ @Override
public long getFilePointer() {
return buffer.position();
}
+ @Override
public void seek(long pos) throws IOException {
buffer.position((int)pos);
}
+ @Override
public long length() {
return length;
}
+ @Override
public Object clone() {
MMapIndexInput clone = (MMapIndexInput)super.clone();
clone.isClone = true;
@@ -237,6 +243,7 @@
return clone;
}
+ @Override
public void close() throws IOException {
if (isClone || buffer == null) return;
// unmap the buffer (if enabled) and at least unset it for GC
@@ -299,6 +306,7 @@
seek(0L);
}
+ @Override
public byte readByte() throws IOException {
// Performance might be improved by reading ahead into an array of
// e.g. 128 bytes and readByte() from there.
@@ -314,6 +322,7 @@
return curBuf.get();
}
+ @Override
public void readBytes(byte[] b, int offset, int len) throws IOException {
while (len > curAvail) {
curBuf.get(b, offset, curAvail);
@@ -330,10 +339,12 @@
curAvail -= len;
}
+ @Override
public long getFilePointer() {
return ((long) curBufIndex * maxBufSize) + curBuf.position();
}
+ @Override
public void seek(long pos) throws IOException {
curBufIndex = (int) (pos / maxBufSize);
curBuf = buffers[curBufIndex];
@@ -342,10 +353,12 @@
curAvail = bufSizes[curBufIndex] - bufOffset;
}
+ @Override
public long length() {
return length;
}
+ @Override
public Object clone() {
MultiMMapIndexInput clone = (MultiMMapIndexInput)super.clone();
clone.isClone = true;
@@ -366,6 +379,7 @@
return clone;
}
+ @Override
public void close() throws IOException {
if (isClone || buffers == null) return;
try {
@@ -384,6 +398,7 @@
}
/** Creates an IndexInput for the file with the given name. */
+ @Override
public IndexInput openInput(String name, int bufferSize) throws IOException {
ensureOpen();
File f = new File(getFile(), name);
@@ -398,6 +413,7 @@
}
/** Creates an IndexOutput for the file with the given name. */
+ @Override
public IndexOutput createOutput(String name) throws IOException {
initOutput(name);
return new SimpleFSDirectory.SimpleFSIndexOutput(new File(directory, name));
Index: src/java/org/apache/lucene/store/NativeFSLockFactory.java
===================================================================
--- src/java/org/apache/lucene/store/NativeFSLockFactory.java (revision 830378)
+++ src/java/org/apache/lucene/store/NativeFSLockFactory.java (working copy)
@@ -122,6 +122,7 @@
setLockDir(lockDir);
}
+ @Override
public synchronized Lock makeLock(String lockName) {
acquireTestLock();
if (lockPrefix != null)
@@ -129,6 +130,7 @@
return new NativeFSLock(lockDir, lockName);
}
+ @Override
public void clearLock(String lockName) throws IOException {
// Note that this isn't strictly required anymore
// because the existence of these files does not mean
@@ -175,6 +177,7 @@
return lock != null;
}
+ @Override
public synchronized boolean obtain() throws IOException {
if (lockExists()) {
@@ -274,6 +277,7 @@
return lockExists();
}
+ @Override
public synchronized void release() throws IOException {
if (lockExists()) {
try {
@@ -299,6 +303,7 @@
}
}
+ @Override
public synchronized boolean isLocked() {
// The test for is isLocked is not directly possible with native file locks:
@@ -318,6 +323,7 @@
}
}
+ @Override
public String toString() {
return "NativeFSLock@" + path;
}
Index: src/java/org/apache/lucene/store/NIOFSDirectory.java
===================================================================
--- src/java/org/apache/lucene/store/NIOFSDirectory.java (revision 830378)
+++ src/java/org/apache/lucene/store/NIOFSDirectory.java (working copy)
@@ -61,12 +61,14 @@
}
/** Creates an IndexInput for the file with the given name. */
+ @Override
public IndexInput openInput(String name, int bufferSize) throws IOException {
ensureOpen();
return new NIOFSIndexInput(new File(getFile(), name), bufferSize, getReadChunkSize());
}
/** Creates an IndexOutput for the file with the given name. */
+ @Override
public IndexOutput createOutput(String name) throws IOException {
initOutput(name);
return new SimpleFSDirectory.SimpleFSIndexOutput(new File(directory, name));
@@ -86,11 +88,13 @@
channel = file.getChannel();
}
+ @Override
protected void newBuffer(byte[] newBuffer) {
super.newBuffer(newBuffer);
byteBuf = ByteBuffer.wrap(newBuffer);
}
+ @Override
public void close() throws IOException {
if (!isClone && file.isOpen) {
// Close the channel & file
@@ -102,6 +106,7 @@
}
}
+ @Override
protected void readInternal(byte[] b, int offset, int len) throws IOException {
final ByteBuffer bb;
Index: src/java/org/apache/lucene/store/NoLockFactory.java
===================================================================
--- src/java/org/apache/lucene/store/NoLockFactory.java (revision 830378)
+++ src/java/org/apache/lucene/store/NoLockFactory.java (working copy)
@@ -38,25 +38,31 @@
return singleton;
}
+ @Override
public Lock makeLock(String lockName) {
return singletonLock;
}
+ @Override
public void clearLock(String lockName) {};
};
class NoLock extends Lock {
+ @Override
public boolean obtain() throws IOException {
return true;
}
+ @Override
public void release() {
}
+ @Override
public boolean isLocked() {
return false;
}
+ @Override
public String toString() {
return "NoLock";
}
Index: src/java/org/apache/lucene/store/RAMDirectory.java
===================================================================
--- src/java/org/apache/lucene/store/RAMDirectory.java (revision 830378)
+++ src/java/org/apache/lucene/store/RAMDirectory.java (working copy)
@@ -69,6 +69,7 @@
Directory.copy(dir, this, closeDir);
}
+ @Override
public synchronized final String[] listAll() {
ensureOpen();
Set fileNames = fileMap.keySet();
@@ -80,6 +81,7 @@
}
/** Returns true iff the named file exists in this directory. */
+ @Override
public final boolean fileExists(String name) {
ensureOpen();
RAMFile file;
@@ -92,6 +94,7 @@
/** Returns the time the named file was last modified.
* @throws IOException if the file does not exist
*/
+ @Override
public final long fileModified(String name) throws IOException {
ensureOpen();
RAMFile file;
@@ -106,6 +109,7 @@
/** Set the modified time of an existing file to now.
* @throws IOException if the file does not exist
*/
+ @Override
public void touchFile(String name) throws IOException {
ensureOpen();
RAMFile file;
@@ -134,6 +138,7 @@
/** Returns the length in bytes of a file in the directory.
* @throws IOException if the file does not exist
*/
+ @Override
public final long fileLength(String name) throws IOException {
ensureOpen();
RAMFile file;
@@ -156,6 +161,7 @@
/** Removes an existing file in the directory.
* @throws IOException if the file does not exist
*/
+ @Override
public synchronized void deleteFile(String name) throws IOException {
ensureOpen();
RAMFile file = fileMap.get(name);
@@ -168,6 +174,7 @@
}
/** Creates a new, empty file in the directory with the given name. Returns a stream writing this file. */
+ @Override
public IndexOutput createOutput(String name) throws IOException {
ensureOpen();
RAMFile file = new RAMFile(this);
@@ -183,6 +190,7 @@
}
/** Returns a stream reading an existing file. */
+ @Override
public IndexInput openInput(String name) throws IOException {
ensureOpen();
RAMFile file;
@@ -195,6 +203,7 @@
}
/** Closes the store to future operations, releasing associated memory. */
+ @Override
public void close() {
isOpen = false;
fileMap = null;
Index: src/java/org/apache/lucene/store/RAMInputStream.java
===================================================================
--- src/java/org/apache/lucene/store/RAMInputStream.java (revision 830378)
+++ src/java/org/apache/lucene/store/RAMInputStream.java (working copy)
@@ -49,14 +49,17 @@
currentBuffer = null;
}
+ @Override
public void close() {
// nothing to do here
}
+ @Override
public long length() {
return length;
}
+ @Override
public byte readByte() throws IOException {
if (bufferPosition >= bufferLength) {
currentBufferIndex++;
@@ -65,6 +68,7 @@
return currentBuffer[bufferPosition++];
}
+ @Override
public void readBytes(byte[] b, int offset, int len) throws IOException {
while (len > 0) {
if (bufferPosition >= bufferLength) {
@@ -100,10 +104,12 @@
}
}
+ @Override
public long getFilePointer() {
return currentBufferIndex < 0 ? 0 : bufferStart + bufferPosition;
}
+ @Override
public void seek(long pos) throws IOException {
if (currentBuffer==null || pos < bufferStart || pos >= bufferStart + BUFFER_SIZE) {
currentBufferIndex = (int) (pos / BUFFER_SIZE);
Index: src/java/org/apache/lucene/store/RAMOutputStream.java
===================================================================
--- src/java/org/apache/lucene/store/RAMOutputStream.java (revision 830378)
+++ src/java/org/apache/lucene/store/RAMOutputStream.java (working copy)
@@ -77,10 +77,12 @@
file.setLength(0);
}
+ @Override
public void close() throws IOException {
flush();
}
+ @Override
public void seek(long pos) throws IOException {
// set the file length in case we seek back
// and flush() has not been called yet
@@ -93,10 +95,12 @@
bufferPosition = (int) (pos % BUFFER_SIZE);
}
+ @Override
public long length() {
return file.length;
}
+ @Override
public void writeByte(byte b) throws IOException {
if (bufferPosition == bufferLength) {
currentBufferIndex++;
@@ -105,6 +109,7 @@
currentBuffer[bufferPosition++] = b;
}
+ @Override
public void writeBytes(byte[] b, int offset, int len) throws IOException {
assert b != null;
while (len > 0) {
@@ -140,11 +145,13 @@
}
}
+ @Override
public void flush() throws IOException {
file.setLastModified(System.currentTimeMillis());
setFileLength();
}
+ @Override
public long getFilePointer() {
return currentBufferIndex < 0 ? 0 : bufferStart + bufferPosition;
}
Index: src/java/org/apache/lucene/store/SimpleFSDirectory.java
===================================================================
--- src/java/org/apache/lucene/store/SimpleFSDirectory.java (revision 830378)
+++ src/java/org/apache/lucene/store/SimpleFSDirectory.java (working copy)
@@ -50,12 +50,14 @@
}
/** Creates an IndexOutput for the file with the given name. */
+ @Override
public IndexOutput createOutput(String name) throws IOException {
initOutput(name);
return new SimpleFSIndexOutput(new File(directory, name));
}
/** Creates an IndexInput for the file with the given name. */
+ @Override
public IndexInput openInput(String name, int bufferSize) throws IOException {
ensureOpen();
return new SimpleFSIndexInput(new File(directory, name), bufferSize, getReadChunkSize());
@@ -76,6 +78,7 @@
length=length();
}
+ @Override
public void close() throws IOException {
if (isOpen) {
isOpen=false;
@@ -96,6 +99,7 @@
}
/** IndexInput methods */
+ @Override
protected void readInternal(byte[] b, int offset, int len)
throws IOException {
synchronized (file) {
@@ -135,18 +139,22 @@
}
}
+ @Override
public void close() throws IOException {
// only close the file if this is not a clone
if (!isClone) file.close();
}
+ @Override
protected void seekInternal(long position) {
}
+ @Override
public long length() {
return file.length;
}
+ @Override
public Object clone() {
SimpleFSIndexInput clone = (SimpleFSIndexInput)super.clone();
clone.isClone = true;
@@ -174,9 +182,11 @@
}
/** output methods: */
+ @Override
public void flushBuffer(byte[] b, int offset, int size) throws IOException {
file.write(b, offset, size);
}
+ @Override
public void close() throws IOException {
// only close the file if it has not been closed yet
if (isOpen) {
@@ -199,13 +209,16 @@
}
/** Random-access methods */
+ @Override
public void seek(long pos) throws IOException {
super.seek(pos);
file.seek(pos);
}
+ @Override
public long length() throws IOException {
return file.length();
}
+ @Override
public void setLength(long length) throws IOException {
file.setLength(length);
}
Index: src/java/org/apache/lucene/store/SimpleFSLockFactory.java
===================================================================
--- src/java/org/apache/lucene/store/SimpleFSLockFactory.java (revision 830378)
+++ src/java/org/apache/lucene/store/SimpleFSLockFactory.java (working copy)
@@ -80,6 +80,7 @@
setLockDir(new File(lockDirName));
}
+ @Override
public Lock makeLock(String lockName) {
if (lockPrefix != null) {
lockName = lockPrefix + "-" + lockName;
@@ -87,6 +88,7 @@
return new SimpleFSLock(lockDir, lockName);
}
+ @Override
public void clearLock(String lockName) throws IOException {
if (lockDir.exists()) {
if (lockPrefix != null) {
@@ -110,6 +112,7 @@
lockFile = new File(lockDir, lockFileName);
}
+ @Override
public boolean obtain() throws IOException {
// Ensure that lockDir exists and is a directory:
@@ -124,15 +127,18 @@
return lockFile.createNewFile();
}
+ @Override
public void release() throws LockReleaseFailedException {
if (lockFile.exists() && !lockFile.delete())
throw new LockReleaseFailedException("failed to delete " + lockFile);
}
+ @Override
public boolean isLocked() {
return lockFile.exists();
}
+ @Override
public String toString() {
return "SimpleFSLock@" + lockFile;
}
Index: src/java/org/apache/lucene/store/SingleInstanceLockFactory.java
===================================================================
--- src/java/org/apache/lucene/store/SingleInstanceLockFactory.java (revision 830378)
+++ src/java/org/apache/lucene/store/SingleInstanceLockFactory.java (working copy)
@@ -35,6 +35,7 @@
private HashSet locks = new HashSet();
+ @Override
public Lock makeLock(String lockName) {
// We do not use the LockPrefix at all, because the private
// HashSet instance effectively scopes the locking to this
@@ -42,6 +43,7 @@
return new SingleInstanceLock(locks, lockName);
}
+ @Override
public void clearLock(String lockName) throws IOException {
synchronized(locks) {
if (locks.contains(lockName)) {
@@ -61,24 +63,28 @@
this.lockName = lockName;
}
+ @Override
public boolean obtain() throws IOException {
synchronized(locks) {
return locks.add(lockName);
}
}
+ @Override
public void release() {
synchronized(locks) {
locks.remove(lockName);
}
}
+ @Override
public boolean isLocked() {
synchronized(locks) {
return locks.contains(lockName);
}
}
+ @Override
public String toString() {
return super.toString() + ": " + lockName;
}
Index: src/java/org/apache/lucene/store/VerifyingLockFactory.java
===================================================================
--- src/java/org/apache/lucene/store/VerifyingLockFactory.java (revision 830378)
+++ src/java/org/apache/lucene/store/VerifyingLockFactory.java (working copy)
@@ -68,6 +68,7 @@
}
}
+ @Override
public synchronized boolean obtain(long lockWaitTimeout)
throws LockObtainFailedException, IOException {
boolean obtained = lock.obtain(lockWaitTimeout);
@@ -76,15 +77,18 @@
return obtained;
}
+ @Override
public synchronized boolean obtain()
throws LockObtainFailedException, IOException {
return lock.obtain();
}
+ @Override
public synchronized boolean isLocked() {
return lock.isLocked();
}
+ @Override
public synchronized void release() throws IOException {
if (isLocked()) {
verify((byte) 0);
@@ -108,10 +112,12 @@
this.port = port;
}
+ @Override
public synchronized Lock makeLock(String lockName) {
return new CheckedLock(lf.makeLock(lockName));
}
+ @Override
public synchronized void clearLock(String lockName)
throws IOException {
lf.clearLock(lockName);
Index: src/java/org/apache/lucene/util/AttributeImpl.java
===================================================================
--- src/java/org/apache/lucene/util/AttributeImpl.java (revision 830378)
+++ src/java/org/apache/lucene/util/AttributeImpl.java (working copy)
@@ -48,6 +48,7 @@
*
* This method may be overridden by subclasses.
*/
+ @Override
public String toString() {
StringBuilder buffer = new StringBuilder();
Class clazz = this.getClass();
@@ -89,6 +90,7 @@
*
* see also {@link #equals(Object)}
*/
+ @Override
public abstract int hashCode();
/**
@@ -97,6 +99,7 @@
*
* see also {@link Object#equals(Object)}
*/
+ @Override
public abstract boolean equals(Object other);
/**
@@ -110,6 +113,7 @@
* Shallow clone. Subclasses must override this if they
* need to clone any members deeply,
*/
+ @Override
public Object clone() {
Object clone = null;
try {
Index: src/java/org/apache/lucene/util/AttributeSource.java
===================================================================
--- src/java/org/apache/lucene/util/AttributeSource.java (revision 830378)
+++ src/java/org/apache/lucene/util/AttributeSource.java (working copy)
@@ -59,6 +59,7 @@
private DefaultAttributeFactory() {}
+ @Override
public AttributeImpl createAttributeInstance(Class extends Attribute> attClass) {
try {
return getClassForInterface(attClass).newInstance();
@@ -269,6 +270,7 @@
private AttributeImpl attribute;
private State next;
+ @Override
public Object clone() {
State clone = new State();
clone.attribute = (AttributeImpl) attribute.clone();
@@ -352,6 +354,7 @@
} while (state != null);
}
+ @Override
public int hashCode() {
int code = 0;
if (hasAttributes()) {
@@ -366,6 +369,7 @@
return code;
}
+ @Override
public boolean equals(Object obj) {
if (obj == this) {
return true;
@@ -407,6 +411,7 @@
return false;
}
+ @Override
public String toString() {
StringBuilder sb = new StringBuilder().append('(');
if (hasAttributes()) {
Index: src/java/org/apache/lucene/util/AverageGuessMemoryModel.java
===================================================================
--- src/java/org/apache/lucene/util/AverageGuessMemoryModel.java (revision 830378)
+++ src/java/org/apache/lucene/util/AverageGuessMemoryModel.java (working copy)
@@ -44,6 +44,7 @@
*
* @see org.apache.lucene.util.MemoryModel#getArraySize()
*/
+ @Override
public int getArraySize() {
return 16;
}
@@ -53,6 +54,7 @@
*
* @see org.apache.lucene.util.MemoryModel#getClassSize()
*/
+ @Override
public int getClassSize() {
return 8;
}
@@ -60,6 +62,7 @@
/* (non-Javadoc)
* @see org.apache.lucene.util.MemoryModel#getPrimitiveSize(java.lang.Class)
*/
+ @Override
public int getPrimitiveSize(Class clazz) {
return sizes.get(clazz).intValue();
}
@@ -67,6 +70,7 @@
/* (non-Javadoc)
* @see org.apache.lucene.util.MemoryModel#getReferenceSize()
*/
+ @Override
public int getReferenceSize() {
return 4;
}
Index: src/java/org/apache/lucene/util/BitVector.java
===================================================================
--- src/java/org/apache/lucene/util/BitVector.java (revision 830378)
+++ src/java/org/apache/lucene/util/BitVector.java (working copy)
@@ -49,6 +49,7 @@
this.size = size;
}
+ @Override
public Object clone() {
byte[] copyBits = new byte[bits.length];
System.arraycopy(bits, 0, copyBits, 0, bits.length);
Index: src/java/org/apache/lucene/util/DocIdBitSet.java
===================================================================
--- src/java/org/apache/lucene/util/DocIdBitSet.java (revision 830378)
+++ src/java/org/apache/lucene/util/DocIdBitSet.java (working copy)
@@ -31,11 +31,13 @@
this.bitSet = bitSet;
}
+ @Override
public DocIdSetIterator iterator() {
return new DocIdBitSetIterator(bitSet);
}
/** This DocIdSet implementation is cacheable. */
+ @Override
public boolean isCacheable() {
return true;
}
@@ -56,10 +58,12 @@
this.docId = -1;
}
+ @Override
public int docID() {
return docId;
}
+ @Override
public int nextDoc() {
// (docId + 1) on next line requires -1 initial value for docNr:
int d = bitSet.nextSetBit(docId + 1);
@@ -68,6 +72,7 @@
return docId;
}
+ @Override
public int advance(int target) {
int d = bitSet.nextSetBit(target);
// -1 returned by BitSet.nextSetBit() when exhausted
Index: src/java/org/apache/lucene/util/FieldCacheSanityChecker.java
===================================================================
--- src/java/org/apache/lucene/util/FieldCacheSanityChecker.java (revision 830378)
+++ src/java/org/apache/lucene/util/FieldCacheSanityChecker.java (working copy)
@@ -297,9 +297,11 @@
this.readerKey = readerKey;
this.fieldName = fieldName;
}
+ @Override
public int hashCode() {
return System.identityHashCode(readerKey) * fieldName.hashCode();
}
+ @Override
public boolean equals(Object that) {
if (! (that instanceof ReaderField)) return false;
@@ -307,6 +309,7 @@
return (this.readerKey == other.readerKey &&
this.fieldName.equals(other.fieldName));
}
+ @Override
public String toString() {
return readerKey.toString() + "+" + fieldName;
}
@@ -352,6 +355,7 @@
* the Type and Msg, followed by each CacheEntry.toString() on it's
* own line prefaced by a tab character
*/
+ @Override
public String toString() {
StringBuilder buf = new StringBuilder();
buf.append(getType()).append(": ");
@@ -383,6 +387,7 @@
private InsanityType(final String label) {
this.label = label;
}
+ @Override
public String toString() { return label; }
/**
Index: src/java/org/apache/lucene/util/OpenBitSet.java
===================================================================
--- src/java/org/apache/lucene/util/OpenBitSet.java (revision 830378)
+++ src/java/org/apache/lucene/util/OpenBitSet.java (working copy)
@@ -640,6 +640,7 @@
+ @Override
public Object clone() {
try {
OpenBitSet obs = (OpenBitSet)super.clone();
@@ -775,6 +776,7 @@
/** returns true if both sets have the same bits set */
+ @Override
public boolean equals(Object o) {
if (this == o) return true;
if (!(o instanceof OpenBitSet)) return false;
@@ -800,6 +802,7 @@
}
+ @Override
public int hashCode() {
long h = 0x98761234; // something non-zero for length==0
for (int i = bits.length; --i>=0;) {
Index: src/java/org/apache/lucene/util/OpenBitSetIterator.java
===================================================================
--- src/java/org/apache/lucene/util/OpenBitSetIterator.java (revision 830378)
+++ src/java/org/apache/lucene/util/OpenBitSetIterator.java (working copy)
@@ -128,6 +128,7 @@
}
******/
+ @Override
public int nextDoc() {
if (indexArray == 0) {
if (word != 0) {
@@ -155,6 +156,7 @@
return curDocId = (i<<6) + bitIndex;
}
+ @Override
public int advance(int target) {
indexArray = 0;
i = target >> 6;
@@ -185,6 +187,7 @@
return curDocId = (i<<6) + bitIndex;
}
+ @Override
public int docID() {
return curDocId;
}
Index: src/java/org/apache/lucene/util/Parameter.java
===================================================================
--- src/java/org/apache/lucene/util/Parameter.java (revision 830378)
+++ src/java/org/apache/lucene/util/Parameter.java (working copy)
@@ -53,6 +53,7 @@
return getClass() + " " + name;
}
+ @Override
public String toString() {
return name;
}
Index: src/java/org/apache/lucene/util/SortedVIntList.java
===================================================================
--- src/java/org/apache/lucene/util/SortedVIntList.java (revision 830378)
+++ src/java/org/apache/lucene/util/SortedVIntList.java (working copy)
@@ -206,10 +206,12 @@
}
}
+ @Override
public int docID() {
return doc;
}
+ @Override
public int nextDoc() {
if (bytePos >= lastBytePos) {
doc = NO_MORE_DOCS;
@@ -220,6 +222,7 @@
return doc;
}
+ @Override
public int advance(int target) {
while (bytePos < lastBytePos) {
advance();