You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by li...@apache.org on 2017/03/17 15:38:34 UTC
[2/4] kylin git commit: minor fix unused import
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-hbase0.98
Commit: 12009b2daa66c1105c5d82883b035c9e840de435
Parents: b01f2ec
Author: Hongbin Ma <ma...@apache.org>
Authored: Fri Mar 17 23:33:42 2017 +0800
Committer: Hongbin Ma <ma...@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;