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 2017/04/26 07:49:43 UTC
[07/14] kylin git commit: minor,
add some log in FactDistinctColumnsMapper
minor, add some log in FactDistinctColumnsMapper
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/a1ad1eb2
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/a1ad1eb2
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/a1ad1eb2
Branch: refs/heads/master-hadoop3.0
Commit: a1ad1eb2d8f1e0fe4f4a5cdc2fd93f35ea82b2d4
Parents: bb1517b
Author: xiefan46 <95...@qq.com>
Authored: Tue Apr 18 15:30:59 2017 +0800
Committer: xiefan46 <95...@qq.com>
Committed: Tue Apr 18 15:30:59 2017 +0800
----------------------------------------------------------------------
.../apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/a1ad1eb2/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java
index 993dafa..d36ae18 100644
--- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java
+++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/FactDistinctColumnsMapper.java
@@ -103,7 +103,6 @@ public class FactDistinctColumnsMapper<KEYIN> extends FactDistinctColumnsMapperB
}
-
TblColRef partitionColRef = cubeDesc.getModel().getPartitionDesc().getPartitionDateColumnRef();
if (partitionColRef != null) {
partitionColumnIndex = intermediateTableDesc.getColumnIndex(partitionColRef);
@@ -124,10 +123,12 @@ public class FactDistinctColumnsMapper<KEYIN> extends FactDistinctColumnsMapperB
row_hashcodes[i] = new ByteArray();
}
hf = Hashing.murmur3_32();
+ logger.info("Found KylinVersion : {}. Use old algorithm for cuboid sampling.", cubeDesc.getVersion());
} else {
isUsePutRowKeyToHllNewAlgorithm = true;
rowHashCodesLong = new long[nRowKey];
hf = Hashing.murmur3_128();
+ logger.info("Found KylinVersion : {}. Use new algorithm for cuboid sampling. About the details of the new algorithm, please refer to KYLIN-2518", cubeDesc.getVersion());
}
}