Repository: kylin Updated Branches: refs/heads/yang23 b01f2ecd6 -> 12009b2da
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/12009b2d Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/12009b2d Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/12009b2d Branch: refs/heads/yang23 Commit: 12009b2daa66c1105c5d82883b035c9e840de435 Parents: b01f2ec 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:33:42 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/12009b2d/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;
