You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2018/11/21 04:16:40 UTC
[kylin] branch master updated: KYLIN-3669,
add log to indicate the case when using GTStreamAggregateScanner.
This is an automated email from the ASF dual-hosted git repository.
shaofengshi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/master by this push:
new 78a5f34 KYLIN-3669, add log to indicate the case when using GTStreamAggregateScanner.
78a5f34 is described below
commit 78a5f349e8f744edeed8072b0dc82ce7d21e052f
Author: Jiatao Tao <24...@qq.com>
AuthorDate: Tue Nov 20 17:11:21 2018 +0800
KYLIN-3669, add log to indicate the case when using GTStreamAggregateScanner.
---
.../java/org/apache/kylin/storage/gtrecord/SegmentCubeTupleIterator.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/SegmentCubeTupleIterator.java b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/SegmentCubeTupleIterator.java
index 629c025..028d105 100644
--- a/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/SegmentCubeTupleIterator.java
+++ b/core-storage/src/main/java/org/apache/kylin/storage/gtrecord/SegmentCubeTupleIterator.java
@@ -92,6 +92,7 @@ public class SegmentCubeTupleIterator implements ITupleIterator {
boolean hasMultiplePartitions = records instanceof SortMergedPartitionResultIterator;
if (hasMultiplePartitions && context.isStreamAggregateEnabled()) {
+ logger.info("Using GTStreamAggregateScanner to pre-aggregate storage partition.");
// input records are ordered, leverage stream aggregator to produce possibly fewer records
IGTScanner inputScanner = new IGTScanner() {
public GTInfo getInfo() {