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 2016/07/26 03:33:35 UTC
[16/55] [abbrv] kylin git commit: minor, use upper in hql
minor, use upper in hql
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/a08b77dd
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/a08b77dd
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/a08b77dd
Branch: refs/heads/1.5.x-CDH5.7
Commit: a08b77dd342e4b6b755b55f40383c7b180e429a8
Parents: 2224eec
Author: shaofengshi <sh...@apache.org>
Authored: Mon Jul 11 09:58:08 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Mon Jul 11 09:59:20 2016 +0800
----------------------------------------------------------------------
.../main/java/org/apache/kylin/job/JoinedFlatTable.java | 12 +++---------
1 file changed, 3 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/a08b77dd/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java
----------------------------------------------------------------------
diff --git a/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java b/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java
index 41c301a..31c92b6 100644
--- a/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java
+++ b/core-job/src/main/java/org/apache/kylin/job/JoinedFlatTable.java
@@ -42,8 +42,7 @@ import org.w3c.dom.Document;
import org.w3c.dom.NodeList;
/**
- * @author George Song (ysong1)
- *
+ *
*/
public class JoinedFlatTable {
@@ -115,11 +114,6 @@ public class JoinedFlatTable {
return sql.toString();
}
- public static String generateRedistributeDataStatement(IJoinedFlatTableDesc intermediateTableDesc) {
- final String tableName = intermediateTableDesc.getTableName();
- return "INSERT OVERWRITE TABLE " + tableName + " SELECT * FROM " + tableName + " distribute by rand();\n";
- }
-
public static String generateSelectDataStatement(IJoinedFlatTableDesc intermediateTableDesc) {
StringBuilder sql = new StringBuilder();
sql.append("SELECT" + "\n");
@@ -222,9 +216,9 @@ public class JoinedFlatTable {
if (distDcol != null) {
String tblAlias = tableAliasMap.get(distDcol.getTable());
- sql.append(" distribute by ").append(tblAlias).append(".").append(distDcol.getName());
+ sql.append(" DISTRIBUTE BY ").append(tblAlias).append(".").append(distDcol.getName());
} else {
- sql.append(" distribute by rand()");
+ sql.append(" DISTRIBUTE BY RAND()");
}
}