KYLIN-1636 HBase benchmark, add param for create table
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/08bc6c4f Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/08bc6c4f Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/08bc6c4f Branch: refs/heads/1.5.x-HBase1.x Commit: 08bc6c4fba9828a82dd85b137a9a5773cdb543fd Parents: 0909989 Author: lidongsjtu <lid...@apache.org> Authored: Thu May 5 11:41:49 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Thu May 5 11:41:49 2016 +0800 ---------------------------------------------------------------------- .../storage/hbase/cube/HBaseScannerBenchmark.java | 17 ++++++++++++++--- 1 file changed, 14 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/08bc6c4f/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/HBaseScannerBenchmark.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/HBaseScannerBenchmark.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/HBaseScannerBenchmark.java index 3f20025..5744ea3 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/HBaseScannerBenchmark.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/HBaseScannerBenchmark.java @@ -56,7 +56,7 @@ public class HBaseScannerBenchmark { final TableName htableName = TableName.valueOf("HBaseScannerBenchmark"); final SimpleHBaseStore simpleStore; - public HBaseScannerBenchmark() throws IOException { + public HBaseScannerBenchmark(boolean createTable) throws IOException { Builder builder = GTInfo.builder(); builder.setCodeSystem(new GTSampleCodeSystem()); DataType tint = DataType.getType("int4"); @@ -75,7 +75,10 @@ public class HBaseScannerBenchmark { gen.addMeasure(8); simpleStore = new SimpleHBaseStore(info, htableName); - buildTable(); + + if (createTable) { + buildTable(); + } } private void buildTable() throws IOException { @@ -150,9 +153,17 @@ public class HBaseScannerBenchmark { } public static void main(String[] args) throws IOException { + boolean createTable = true; + if (args != null && args.length > 0) { + try { + createTable = Boolean.parseBoolean(args[0]); + } catch (Exception e) { + createTable = true; + } + } KylinConfig.setSandboxEnvIfPossible(); - HBaseScannerBenchmark benchmark = new HBaseScannerBenchmark(); + HBaseScannerBenchmark benchmark = new HBaseScannerBenchmark(createTable); benchmark.testScan(); benchmark.cleanup(); }
