mirror of https://github.com/apache/lucene.git
LUCENE-7059: remove MultiPointValues
This commit is contained in:
Mike McCandless
parent
e80ab3926c
commit
9f5bbc2d91
|
|
@ -1,172 +0,0 @@
|
|||
/*
|
||||
* Licensed to the Apache Software Foundation (ASF) under one or more
|
||||
* contributor license agreements. See the NOTICE file distributed with
|
||||
* this work for additional information regarding copyright ownership.
|
||||
* The ASF licenses this file to You under the Apache License, Version 2.0
|
||||
* (the "License"); you may not use this file except in compliance with
|
||||
* the License. You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.apache.lucene.index;
|
||||
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
import org.apache.lucene.util.StringHelper;
|
||||
|
||||
/** Merges multiple {@link PointValues} into a single one. */
|
||||
public class MultiPointValues extends PointValues {
|
||||
|
||||
private final List<PointValues> subs;
|
||||
private final List<Integer> docBases;
|
||||
|
||||
private MultiPointValues(List<PointValues> subs, List<Integer> docBases) {
|
||||
this.subs = subs;
|
||||
this.docBases = docBases;
|
||||
}
|
||||
|
||||
/** Returns a {@link PointValues} merging all point values from the provided reader. */
|
||||
public static PointValues get(IndexReader r) {
|
||||
final List<LeafReaderContext> leaves = r.leaves();
|
||||
final int size = leaves.size();
|
||||
if (size == 0) {
|
||||
return null;
|
||||
} else if (size == 1) {
|
||||
return leaves.get(0).reader().getPointValues();
|
||||
}
|
||||
|
||||
List<PointValues> values = new ArrayList<>();
|
||||
List<Integer> docBases = new ArrayList<>();
|
||||
for (int i = 0; i < size; i++) {
|
||||
LeafReaderContext context = leaves.get(i);
|
||||
PointValues v = context.reader().getPointValues();
|
||||
if (v != null) {
|
||||
values.add(v);
|
||||
docBases.add(context.docBase);
|
||||
}
|
||||
}
|
||||
|
||||
if (values.isEmpty()) {
|
||||
return null;
|
||||
}
|
||||
|
||||
return new MultiPointValues(values, docBases);
|
||||
}
|
||||
|
||||
/** Finds all documents and points matching the provided visitor */
|
||||
public void intersect(String fieldName, IntersectVisitor visitor) throws IOException {
|
||||
for(int i=0;i<subs.size();i++) {
|
||||
int docBase = docBases.get(i);
|
||||
subs.get(i).intersect(fieldName,
|
||||
new IntersectVisitor() {
|
||||
@Override
|
||||
public void visit(int docID) throws IOException {
|
||||
visitor.visit(docBase+docID);
|
||||
}
|
||||
@Override
|
||||
public void visit(int docID, byte[] packedValue) throws IOException {
|
||||
visitor.visit(docBase+docID, packedValue);
|
||||
}
|
||||
@Override
|
||||
public Relation compare(byte[] minPackedValue, byte[] maxPackedValue) {
|
||||
return visitor.compare(minPackedValue, maxPackedValue);
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
StringBuilder b = new StringBuilder();
|
||||
b.append("MultiPointValues(");
|
||||
for(int i=0;i<subs.size();i++) {
|
||||
if (i > 0) {
|
||||
b.append(", ");
|
||||
}
|
||||
b.append("docBase=");
|
||||
b.append(docBases.get(i));
|
||||
b.append(" sub=" + subs.get(i));
|
||||
}
|
||||
b.append(')');
|
||||
return b.toString();
|
||||
}
|
||||
|
||||
@Override
|
||||
public byte[] getMinPackedValue(String fieldName) throws IOException {
|
||||
byte[] result = null;
|
||||
for(int i=0;i<subs.size();i++) {
|
||||
byte[] minPackedValue = subs.get(i).getMinPackedValue(fieldName);
|
||||
if (result == null) {
|
||||
if (minPackedValue != null) {
|
||||
result = minPackedValue.clone();
|
||||
}
|
||||
} else {
|
||||
int numDims = subs.get(0).getNumDimensions(fieldName);
|
||||
int bytesPerDim = subs.get(0).getBytesPerDimension(fieldName);
|
||||
for(int dim=0;dim<numDims;dim++) {
|
||||
int offset = dim*bytesPerDim;
|
||||
if (StringHelper.compare(bytesPerDim, minPackedValue, offset, result, offset) < 0) {
|
||||
System.arraycopy(minPackedValue, offset, result, offset, bytesPerDim);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
@Override
|
||||
public byte[] getMaxPackedValue(String fieldName) throws IOException {
|
||||
byte[] result = null;
|
||||
for(int i=0;i<subs.size();i++) {
|
||||
byte[] maxPackedValue = subs.get(i).getMaxPackedValue(fieldName);
|
||||
if (result == null) {
|
||||
if (maxPackedValue != null) {
|
||||
result = maxPackedValue.clone();
|
||||
}
|
||||
} else {
|
||||
int numDims = subs.get(0).getNumDimensions(fieldName);
|
||||
int bytesPerDim = subs.get(0).getBytesPerDimension(fieldName);
|
||||
for(int dim=0;dim<numDims;dim++) {
|
||||
int offset = dim*bytesPerDim;
|
||||
if (StringHelper.compare(bytesPerDim, maxPackedValue, offset, result, offset) > 0) {
|
||||
System.arraycopy(maxPackedValue, offset, result, offset, bytesPerDim);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getNumDimensions(String fieldName) throws IOException {
|
||||
for(int i=0;i<subs.size();i++) {
|
||||
int result = subs.get(i).getNumDimensions(fieldName);
|
||||
if (result != 0) {
|
||||
return result;
|
||||
}
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getBytesPerDimension(String fieldName) throws IOException {
|
||||
for(int i=0;i<subs.size();i++) {
|
||||
int result = subs.get(i).getBytesPerDimension(fieldName);
|
||||
if (result != 0) {
|
||||
return result;
|
||||
}
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue