fix stupidness with spatial indexing

This commit is contained in:
fjy 2014-08-05 15:07:56 -07:00
parent c58a316437
commit 66225d698f
2 changed files with 2 additions and 6 deletions

View File

@ -566,10 +566,6 @@ public class IncrementalIndexStorageAdapter implements StorageAdapter
@Override
public ValueMatcher makeValueMatcher(final String dimension, final Bound bound)
{
if (!dimension.endsWith(".geo")) {
return new BooleanValueMatcher(false);
}
Integer dimIndexObject = index.getDimensionIndex(dimension.toLowerCase());
if (dimIndexObject == null) {
return new BooleanValueMatcher(false);
@ -601,4 +597,4 @@ public class IncrementalIndexStorageAdapter implements StorageAdapter
};
}
}
}
}

View File

@ -786,7 +786,7 @@ public class RealtimePlumber implements Plumber
public boolean apply(final DataSegment segment)
{
return
schema.getDataSource().equals(segment.getDataSource())
schema.getDataSource().equalsIgnoreCase(segment.getDataSource())
&& config.getShardSpec().getPartitionNum() == segment.getShardSpec().getPartitionNum()
&& Iterables.any(
sinks.keySet(), new Predicate<Long>()