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/04/11 00:47:47 UTC

[10/34] incubator-kylin git commit: KYLIN-607 More efficient cube building

KYLIN-607 More efficient cube building

Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/240fb53e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/240fb53e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/240fb53e

Branch: refs/heads/streaming-localdict
Commit: 240fb53e3683707bec38bdd3c6e9db2340a249c9
Parents: b23e7e0
Author: Shao Feng, Shi <sh...@ebay.com>
Authored: Tue Apr 7 18:17:52 2015 +0800
Committer: Shao Feng, Shi <sh...@ebay.com>
Committed: Tue Apr 7 18:17:52 2015 +0800

----------------------------------------------------------------------
 .../java/org/apache/kylin/job/hadoop/cube/KeyValueCreator.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/240fb53e/job/src/main/java/org/apache/kylin/job/hadoop/cube/KeyValueCreator.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/cube/KeyValueCreator.java b/job/src/main/java/org/apache/kylin/job/hadoop/cube/KeyValueCreator.java
index 29474ac..a8d06de 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/cube/KeyValueCreator.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/cube/KeyValueCreator.java
@@ -58,7 +58,7 @@ public class KeyValueCreator {
     }
 
     public KeyValue create(Text key, Object[] measureValues) {
-        return create(key.getBytes(), 0, key.getLength(), valueBuf.array(), 0, valueBuf.position());
+        return create(key.getBytes(), 0, key.getLength(), measureValues);
     }
 
     public KeyValue create(byte[] keyBytes, int keyOffset, int keyLength, Object[] measureValues) {