Repository: kylin Updated Branches: refs/heads/master 8b70fa521 -> 19c87e7a8
minor fix unused import Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/19c87e7a Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/19c87e7a Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/19c87e7a Branch: refs/heads/master Commit: 19c87e7a80b95a16a930feb6d0281555cd1232b5 Parents: 8b70fa5 Author: Hongbin Ma <mahong...@apache.org> Authored: Fri Mar 17 23:33:42 2017 +0800 Committer: Hongbin Ma <mahong...@apache.org> Committed: Fri Mar 17 23:39:22 2017 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/metadata/model/JoinsTree.java | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/19c87e7a/core-metadata/src/main/java/org/apache/kylin/metadata/model/JoinsTree.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/JoinsTree.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/JoinsTree.java index 224788c..c6df52e 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/JoinsTree.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/JoinsTree.java @@ -30,11 +30,10 @@ import java.util.Queue; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import com.google.common.collect.Queues; -public class JoinsTree implements Serializable { +public class JoinsTree implements Serializable { private static final long serialVersionUID = 1L; - + final Map<String, Chain> tableChains = new LinkedHashMap<>(); public JoinsTree(TableRef rootTable, List<JoinDesc> joins) { @@ -48,7 +47,7 @@ public class JoinsTree implements Serializable { // Walk through joins to build FK table to joins mapping HashMap<String, List<JoinDesc>> fkJoinMap = Maps.newHashMap(); int joinCount = 0; - for (JoinDesc join: joins) { + for (JoinDesc join : joins) { joinCount++; String fkSideAlias = join.getFKSide().getAlias(); if (fkJoinMap.containsKey(fkSideAlias)) { @@ -64,14 +63,14 @@ public class JoinsTree implements Serializable { chainBuff.add(new Chain(rootTable, null, null)); int chainCount = 0; while (!chainBuff.isEmpty()) { - Chain chain= chainBuff.poll(); + Chain chain = chainBuff.poll(); String pkSideAlias = chain.table.getAlias(); chainCount++; tableChains.put(pkSideAlias, chain); // this round pk side is next round's fk side if (fkJoinMap.containsKey(pkSideAlias)) { - for (JoinDesc join: fkJoinMap.get(pkSideAlias)) { + for (JoinDesc join : fkJoinMap.get(pkSideAlias)) { chainBuff.add(new Chain(join.getPKSide(), join, chain)); } } @@ -149,7 +148,7 @@ public class JoinsTree implements Serializable { public static class Chain implements Serializable { private static final long serialVersionUID = 1L; - + TableRef table; // pk side JoinDesc join; Chain fkSide;
