minor, make cube provision extensible
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/e47a6481 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/e47a6481 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/e47a6481 Branch: refs/heads/1.5.x-HBase1.x Commit: e47a64816d95e410bfacef9097737008bc19ebc7 Parents: 79d1c6d Author: lidongsjtu <lid...@apache.org> Authored: Sun May 1 14:06:24 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Sun May 1 14:06:24 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/provision/BuildCubeWithEngine.java | 7 +++++-- .../java/org/apache/kylin/provision/BuildCubeWithStream.java | 7 ++++++- .../java/org/apache/kylin/provision/BuildIIWithStream.java | 6 +++++- 3 files changed, 16 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/e47a6481/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java index 2ca6c5f..d7538e0 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithEngine.java @@ -126,11 +126,14 @@ public class BuildCubeWithEngine { } } - public void before() throws Exception { - + protected void deployEnv() throws IOException { DeployUtil.initCliWorkDir(); DeployUtil.deployMetadata(); DeployUtil.overrideJobJarLocations(); + } + + public void before() throws Exception { + deployEnv(); final KylinConfig kylinConfig = KylinConfig.getInstanceFromEnv(); jobService = ExecutableManager.getInstance(kylinConfig); http://git-wip-us.apache.org/repos/asf/kylin/blob/e47a6481/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java index d8a9c21..c426ea4 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildCubeWithStream.java @@ -19,6 +19,7 @@ package org.apache.kylin.provision; import java.io.File; +import java.io.IOException; import java.util.UUID; import org.apache.commons.lang3.StringUtils; @@ -80,8 +81,12 @@ public class BuildCubeWithStream { HBaseMetadataTestCase.staticCreateTestMetadata(HBaseMetadataTestCase.SANDBOX_TEST_DATA); } - public void before() throws Exception { + protected void deployEnv() throws IOException { DeployUtil.overrideJobJarLocations(); + } + + public void before() throws Exception { + deployEnv(); kylinConfig = KylinConfig.getInstanceFromEnv(); final CubeInstance cubeInstance = CubeManager.getInstance(kylinConfig).getCube(cubeName); http://git-wip-us.apache.org/repos/asf/kylin/blob/e47a6481/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java ---------------------------------------------------------------------- diff --git a/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java b/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java index 6d077e7..c0f6f63 100644 --- a/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java +++ b/kylin-it/src/test/java/org/apache/kylin/provision/BuildIIWithStream.java @@ -116,8 +116,12 @@ public class BuildIIWithStream { HBaseMetadataTestCase.staticCreateTestMetadata(HBaseMetadataTestCase.SANDBOX_TEST_DATA); } - public void before() throws Exception { + protected void deployEnv() throws Exception { DeployUtil.overrideJobJarLocations(); + } + + public void before() throws Exception { + deployEnv(); kylinConfig = KylinConfig.getInstanceFromEnv(); iiManager = IIManager.getInstance(kylinConfig);
