Repository: kylin Updated Branches: refs/heads/xiefan22 74658e925 -> fde2e0a5c
add more log Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/fde2e0a5 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/fde2e0a5 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/fde2e0a5 Branch: refs/heads/xiefan22 Commit: fde2e0a5c2c2fa8100fe96e3e3c4f3315dfab58b Parents: 74658e9 Author: Hongbin Ma <mahong...@apache.org> Authored: Fri Dec 23 13:56:01 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Fri Dec 23 13:56:01 2016 +0800 ---------------------------------------------------------------------- .../apache/kylin/storage/gtrecord/StorageResponseGTScatter.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/fde2e0a5/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/StorageResponseGTScatter.java ---------------------------------------------------------------------- diff --git a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/StorageResponseGTScatter.java b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/StorageResponseGTScatter.java index fe1afd3..0e7809a 100644 --- a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/StorageResponseGTScatter.java +++ b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/StorageResponseGTScatter.java @@ -74,8 +74,10 @@ public class StorageResponseGTScatter implements IGTScanner { public Iterator<GTRecord> iterator() { Iterator<Iterator<GTRecord>> shardSubsets = Iterators.transform(blocks, new EndpointResponseGTScatterFunc()); if (storagePushDownLimit != Integer.MAX_VALUE) { + logger.info("Using SortedIteratorMergerWithLimit to merge partitions"); return new SortedIteratorMergerWithLimit<GTRecord>(shardSubsets, storagePushDownLimit, GTRecord.getPrimaryKeyComparator()).getIterator(); } else { + logger.info("Using Iterators.concat to merge partitions"); return Iterators.concat(shardSubsets); } }
