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/09/09 10:59:03 UTC
incubator-kylin git commit: KYLIN-998 allow configurable hive
database in IIFlattenHiveJob
Repository: incubator-kylin
Updated Branches:
refs/heads/1.x-staging b338dc3ea -> 44309fed9
KYLIN-998 allow configurable hive database in IIFlattenHiveJob
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/44309fed
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/44309fed
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/44309fed
Branch: refs/heads/1.x-staging
Commit: 44309fed91c130a486ef329b31b9522095ae8dd8
Parents: b338dc3
Author: shaofengshi <sh...@apache.org>
Authored: Wed Sep 9 16:52:53 2015 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Wed Sep 9 16:52:53 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/job/hadoop/invertedindex/IIFlattenHiveJob.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/44309fed/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IIFlattenHiveJob.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IIFlattenHiveJob.java b/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IIFlattenHiveJob.java
index 9e60823..e9d8a4a 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IIFlattenHiveJob.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/invertedindex/IIFlattenHiveJob.java
@@ -59,6 +59,7 @@ public class IIFlattenHiveJob extends AbstractHadoopJob {
String jobUUID = "00bf87b5-c7b5-4420-a12a-07f6b37b3187";
JobEngineConfig engineConfig = new JobEngineConfig(config);
IJoinedFlatTableDesc intermediateTableDesc = new IIJoinedFlatTableDesc(iidesc);
+ final String useDatabaseHql = "USE " + engineConfig.getConfig().getHiveDatabaseForIntermediateTable() + ";";
String dropTableHql = JoinedFlatTable.generateDropTableStatement(intermediateTableDesc, jobUUID);
String createTableHql = JoinedFlatTable.generateCreateTableStatement(intermediateTableDesc, //
JobInstance.getJobWorkingDir(jobUUID, engineConfig.getHdfsWorkingDirectory()), jobUUID);
@@ -66,6 +67,7 @@ public class IIFlattenHiveJob extends AbstractHadoopJob {
StringBuffer buf = new StringBuffer();
buf.append("hive -e \"");
+ buf.append(useDatabaseHql + "\n");
buf.append(dropTableHql + "\n");
buf.append(createTableHql + "\n");
buf.append(insertDataHqls + "\n");