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 2015/10/26 01:42:14 UTC
incubator-kylin git commit: KYLIN-1068 increase reuseDelta size
automatically
Repository: incubator-kylin
Updated Branches:
refs/heads/KYLIN-1068 ae9c4c086 -> 35c7e4d06
KYLIN-1068 increase reuseDelta size automatically
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/35c7e4d0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/35c7e4d0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/35c7e4d0
Branch: refs/heads/KYLIN-1068
Commit: 35c7e4d06315de963dc97bc47d453a52f15dfa0a
Parents: ae9c4c0
Author: shaofengshi <sh...@apache.org>
Authored: Mon Oct 26 08:21:02 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Mon Oct 26 08:21:02 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/common/topn/DoubleDeltaSerializer.java | 2 +-
.../measure/serializer/TopNCounterSerializer.java | 10 +++++-----
2 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/35c7e4d0/core-common/src/main/java/org/apache/kylin/common/topn/DoubleDeltaSerializer.java
----------------------------------------------------------------------
diff --git a/core-common/src/main/java/org/apache/kylin/common/topn/DoubleDeltaSerializer.java b/core-common/src/main/java/org/apache/kylin/common/topn/DoubleDeltaSerializer.java
index 4ce2e0c..52dee77 100644
--- a/core-common/src/main/java/org/apache/kylin/common/topn/DoubleDeltaSerializer.java
+++ b/core-common/src/main/java/org/apache/kylin/common/topn/DoubleDeltaSerializer.java
@@ -114,7 +114,7 @@ public class DoubleDeltaSerializer {
len = Math.max(0, len);
long[] deltas = deltasThreadLocal.get();
- if (deltas == null) {
+ if (deltas == null || deltas.length < len) {
deltas = new long[len];
deltasThreadLocal.set(deltas);
}
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/35c7e4d0/core-metadata/src/main/java/org/apache/kylin/metadata/measure/serializer/TopNCounterSerializer.java
----------------------------------------------------------------------
diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/measure/serializer/TopNCounterSerializer.java b/core-metadata/src/main/java/org/apache/kylin/metadata/measure/serializer/TopNCounterSerializer.java
index f6cacde..9062825 100644
--- a/core-metadata/src/main/java/org/apache/kylin/metadata/measure/serializer/TopNCounterSerializer.java
+++ b/core-metadata/src/main/java/org/apache/kylin/metadata/measure/serializer/TopNCounterSerializer.java
@@ -37,7 +37,7 @@ public class TopNCounterSerializer extends DataTypeSerializer<TopNCounter<ByteAr
private DoubleDeltaSerializer dds = new DoubleDeltaSerializer(3);
private int precision;
-
+
public TopNCounterSerializer(DataType dataType) {
this.precision = dataType.getPrecision();
}
@@ -68,7 +68,7 @@ public class TopNCounterSerializer extends DataTypeSerializer<TopNCounter<ByteAr
ByteArray key = new ByteArray(sizeOfId);
BytesUtil.writeUnsigned(keyEncodedValue, key.array(), 0, sizeOfId);
-
+
TopNCounter<ByteArray> topNCounter = new TopNCounter<ByteArray>(precision * TopNCounter.EXTRA_SPACE_RATE);
topNCounter.offer(key, counter);
return topNCounter;
@@ -83,8 +83,8 @@ public class TopNCounterSerializer extends DataTypeSerializer<TopNCounter<ByteAr
out.putInt(value.size());
out.putInt(keyLength);
dds.serialize(counters, out);
- Iterator<Counter<ByteArray>> iterator = value.iterator();
- while(iterator.hasNext()) {
+ Iterator<Counter<ByteArray>> iterator = value.iterator();
+ while (iterator.hasNext()) {
out.put(iterator.next().getItem().array());
}
}
@@ -103,7 +103,7 @@ public class TopNCounterSerializer extends DataTypeSerializer<TopNCounter<ByteAr
in.get(byteArray.array());
counter.offerToHead(byteArray, counters[i]);
}
-
+
return counter;
}
}