You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2015/03/21 01:27:53 UTC
[48/50] [abbrv] incubator-kylin git commit: fix bug
fix bug
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/21909b9a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/21909b9a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/21909b9a
Branch: refs/heads/streaming-localdict
Commit: 21909b9aacccc35e1bd013242d60dccfc3efcfdd
Parents: a7b771d
Author: qianhao.zhou <qi...@ebay.com>
Authored: Fri Mar 20 18:47:48 2015 +0800
Committer: qianhao.zhou <qi...@ebay.com>
Committed: Fri Mar 20 18:47:48 2015 +0800
----------------------------------------------------------------------
.../kylin/storage/hbase/coprocessor/endpoint/IIEndpoint.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/21909b9a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/IIEndpoint.java
----------------------------------------------------------------------
diff --git a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/IIEndpoint.java b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/IIEndpoint.java
index cb85718..c166e73 100644
--- a/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/IIEndpoint.java
+++ b/storage/src/main/java/org/apache/kylin/storage/hbase/coprocessor/endpoint/IIEndpoint.java
@@ -189,9 +189,10 @@ public class IIEndpoint extends IIProtos.RowsService implements Coprocessor, Cop
ClearTextDictionary clearTextDictionary = new ClearTextDictionary(recordInfo, type);
RowKeyColumnIO rowKeyColumnIO = new RowKeyColumnIO(clearTextDictionary);
for (Slice slice : slices) {
+ CoprocessorFilter newFilter = CoprocessorFilter.fromFilter(new LocalDictionary(slice.getLocalDictionaries(), type, slice.getInfo()), filter.getFilter(), FilterDecorator.FilterConstantsTreatment.REPLACE_WITH_LOCAL_DICT);
ConciseSet result = null;
if (filter != null) {
- result = new BitMapFilterEvaluator(new SliceBitMapProvider(slice, type)).evaluate(filter.getFilter());
+ result = new BitMapFilterEvaluator(new SliceBitMapProvider(slice, type)).evaluate(newFilter.getFilter());
}
Iterator<RawTableRecord> iterator = slice.iterateWithBitmap(result);