minor improvements
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/e80b13ff Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/e80b13ff Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/e80b13ff Branch: refs/heads/1.5.x-HBase1.x Commit: e80b13ff1b3235b13b872675b8c2165a8b024d19 Parents: f6be483 Author: Hongbin Ma <mahong...@apache.org> Authored: Mon May 16 15:27:49 2016 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Mon May 16 15:27:56 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/kylin/common/KylinConfigBase.java | 4 ++++ .../java/org/apache/kylin/common/util/CompressionUtils.java | 6 ++++-- 2 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/e80b13ff/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java ---------------------------------------------------------------------- diff --git a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java index 2e17c94..1062749 100644 --- a/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java +++ b/core-common/src/main/java/org/apache/kylin/common/KylinConfigBase.java @@ -499,6 +499,10 @@ abstract public class KylinConfigBase implements Serializable { return Integer.valueOf(this.getOptional("kylin.query.storage.visit.scanrange.max", "1000000")); } + public long getSequenceExpireTime() { + return Long.valueOf(this.getOptional("kylin.query.sequence.expire.time", "86400000"));//default a day + } + public int getHBaseKeyValueSize() { return Integer.parseInt(this.getOptional("kylin.hbase.client.keyvalue.maxsize", "10485760")); } http://git-wip-us.apache.org/repos/asf/kylin/blob/e80b13ff/core-common/src/main/java/org/apache/kylin/common/util/CompressionUtils.java ---------------------------------------------------------------------- diff --git a/core-common/src/main/java/org/apache/kylin/common/util/CompressionUtils.java b/core-common/src/main/java/org/apache/kylin/common/util/CompressionUtils.java index 2781cac..7bd520c 100644 --- a/core-common/src/main/java/org/apache/kylin/common/util/CompressionUtils.java +++ b/core-common/src/main/java/org/apache/kylin/common/util/CompressionUtils.java @@ -31,6 +31,7 @@ public class CompressionUtils { private static final org.slf4j.Logger logger = LoggerFactory.getLogger(CompressionUtils.class); public static byte[] compress(byte[] data) throws IOException { + long startTime = System.currentTimeMillis(); Deflater deflater = new Deflater(1); deflater.setInput(data); @@ -45,11 +46,12 @@ public class CompressionUtils { outputStream.close(); byte[] output = outputStream.toByteArray(); - logger.debug("Original: " + data.length + " bytes. " + "Compressed: " + output.length + " bytes "); + logger.debug("Original: " + data.length + " bytes. " + "Compressed: " + output.length + " byte. Time: " + (System.currentTimeMillis() - startTime)); return output; } public static byte[] decompress(byte[] data) throws IOException, DataFormatException { + long startTime = System.currentTimeMillis(); Inflater inflater = new Inflater(); inflater.setInput(data); @@ -62,7 +64,7 @@ public class CompressionUtils { outputStream.close(); byte[] output = outputStream.toByteArray(); - logger.debug("Original: " + data.length + " bytes. " + "Decompressed: " + output.length + " bytes"); + logger.debug("Original: " + data.length + " bytes. " + "Decompressed: " + output.length + " bytes. Time: " + (System.currentTimeMillis() - startTime)); return output; } }
