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 <shaofeng...@apache.org> Authored: Mon Jul 11 09:58:08 2016 +0800 Committer: shaofengshi <shaofeng...@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()"); } }
