set 0 for all HTable cellâs timestamp Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/fe79ed9b Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/fe79ed9b Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/fe79ed9b
Branch: refs/heads/1.x-HBase1.1.3 Commit: fe79ed9bdd3b695c6338594edb6474793caefbee Parents: 7fef205 Author: shaofengshi <shaofeng...@apache.org> Authored: Wed Dec 30 10:20:34 2015 +0800 Committer: shaofengshi <shaofeng...@apache.org> Committed: Wed Dec 30 10:20:34 2015 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/job/hadoop/cube/CubeHFileMapper.java | 2 +- .../java/org/apache/kylin/job/hadoop/hbase/CreateHTableJob.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/fe79ed9b/job/src/main/java/org/apache/kylin/job/hadoop/cube/CubeHFileMapper.java ---------------------------------------------------------------------- diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/cube/CubeHFileMapper.java b/job/src/main/java/org/apache/kylin/job/hadoop/cube/CubeHFileMapper.java index c19e54b..f12d229 100644 --- a/job/src/main/java/org/apache/kylin/job/hadoop/cube/CubeHFileMapper.java +++ b/job/src/main/java/org/apache/kylin/job/hadoop/cube/CubeHFileMapper.java @@ -120,7 +120,7 @@ public class CubeHFileMapper extends KylinMapper<Text, Text, ImmutableBytesWrita cfBytes = Bytes.toBytes(colDesc.getColumnFamilyName()); qBytes = Bytes.toBytes(colDesc.getQualifier()); - timestamp = System.currentTimeMillis(); + timestamp = 0; // use 0 for timestamp List<MeasureDesc> measures = cubeDesc.getMeasures(); String[] measureNames = getMeasureNames(cubeDesc); http://git-wip-us.apache.org/repos/asf/kylin/blob/fe79ed9b/job/src/main/java/org/apache/kylin/job/hadoop/hbase/CreateHTableJob.java ---------------------------------------------------------------------- diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/hbase/CreateHTableJob.java b/job/src/main/java/org/apache/kylin/job/hadoop/hbase/CreateHTableJob.java index af2850c..027c0ca 100644 --- a/job/src/main/java/org/apache/kylin/job/hadoop/hbase/CreateHTableJob.java +++ b/job/src/main/java/org/apache/kylin/job/hadoop/hbase/CreateHTableJob.java @@ -79,7 +79,6 @@ public class CreateHTableJob extends AbstractHadoopJob { // https://hbase.apache.org/apidocs/org/apache/hadoop/hbase/regionserver/ConstantSizeRegionSplitPolicy.html tableDesc.setValue(HTableDescriptor.SPLIT_POLICY, ConstantSizeRegionSplitPolicy.class.getName()); tableDesc.setValue(IRealizationConstants.HTableTag, config.getMetadataUrlPrefix()); - tableDesc.setReadOnly(true); Configuration conf = HadoopUtil.getCurrentHBaseConfiguration(); HBaseAdmin admin = new HBaseAdmin(conf);
