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/05/15 05:06:33 UTC
[21/50] [abbrv] incubator-kylin git commit: KYLIN-754 - Enable lzo on
II's table
KYLIN-754 - Enable lzo on II's table
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/e349cda6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/e349cda6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/e349cda6
Branch: refs/heads/streaming-localdict
Commit: e349cda6693eb3e897df4abb930e82babd479c63
Parents: 9854f7d
Author: honma <ho...@ebay.com>
Authored: Thu May 7 15:51:45 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Thu May 7 15:51:45 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/job/hadoop/invertedindex/IICreateHTableJob.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/e349cda6/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IICreateHTableJob.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IICreateHTableJob.java b/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IICreateHTableJob.java
index 77d0d55..cf8d005 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IICreateHTableJob.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IICreateHTableJob.java
@@ -25,6 +25,7 @@ import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.HBaseAdmin;
+import org.apache.hadoop.hbase.io.compress.Compression;
import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;
import org.apache.hadoop.hbase.regionserver.DisabledRegionSplitPolicy;
import org.apache.hadoop.hbase.security.User;
@@ -65,7 +66,7 @@ public class IICreateHTableJob extends AbstractHadoopJob {
HTableDescriptor tableDesc = new HTableDescriptor(TableName.valueOf(tableName));
HColumnDescriptor cf = new HColumnDescriptor(IIDesc.HBASE_FAMILY);
cf.setMaxVersions(1);
- //cf.setCompressionType(Algorithm.LZO);
+ cf.setCompressionType(Compression.Algorithm.LZO);
cf.setDataBlockEncoding(DataBlockEncoding.FAST_DIFF);
tableDesc.addFamily(cf);
tableDesc.setValue(IRealizationConstants.HTableTag, config.getMetadataUrlPrefix());