Repository: kylin Updated Branches: refs/heads/sparkcubing-rebase [created] 55ba39afb
http://git-wip-us.apache.org/repos/asf/kylin/blob/78e6cd5b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java ---------------------------------------------------------------------- diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java index fc2b982..763b537 100644 --- a/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java +++ b/source-hive/src/main/java/org/apache/kylin/source/hive/HiveMRInput.java @@ -22,6 +22,7 @@ import java.io.IOException; import java.util.Map; import java.util.Set; +import com.google.common.collect.Sets; import org.apache.commons.lang.StringUtils; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @@ -56,8 +57,6 @@ import org.apache.kylin.metadata.model.TableDesc; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.google.common.collect.Sets; - public class HiveMRInput implements IMRInput { public static String getTableNameForHCat(TableDesc table) { @@ -74,7 +73,7 @@ public class HiveMRInput implements IMRInput { public IMRTableInputFormat getTableInputFormat(TableDesc table) { return new HiveTableInputFormat(getTableNameForHCat(table)); } - + @Override public IMRBatchMergeInputSide getBatchMergeInputSide(ISegment seg) { return new IMRBatchMergeInputSide() { http://git-wip-us.apache.org/repos/asf/kylin/blob/78e6cd5b/tool/pom.xml ---------------------------------------------------------------------- diff --git a/tool/pom.xml b/tool/pom.xml index 8eddec4..b577ae9 100644 --- a/tool/pom.xml +++ b/tool/pom.xml @@ -40,6 +40,10 @@ </dependency> <dependency> <groupId>org.apache.kylin</groupId> + <artifactId>kylin-engine-spark</artifactId> + </dependency> + <dependency> + <groupId>org.apache.kylin</groupId> <artifactId>kylin-source-kafka</artifactId> </dependency> <dependency>
