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 2015/06/25 01:47:04 UTC
incubator-kylin git commit: KYLIN-803 Enable DoggedCubeBuilder in
batch build
Repository: incubator-kylin
Updated Branches:
refs/heads/0.8 e124e8f33 -> bcea2a742
KYLIN-803 Enable DoggedCubeBuilder in batch build
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/bcea2a74
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/bcea2a74
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/bcea2a74
Branch: refs/heads/0.8
Commit: bcea2a7426b3777e5d437304082904f5deb85db4
Parents: e124e8f
Author: Yang Li <li...@apache.org>
Authored: Thu Jun 25 07:46:54 2015 +0800
Committer: Yang Li <li...@apache.org>
Committed: Thu Jun 25 07:46:54 2015 +0800
----------------------------------------------------------------------
.../org/apache/kylin/job/hadoop/cubev2/InMemCuboidMapper.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/bcea2a74/job/src/main/java/org/apache/kylin/job/hadoop/cubev2/InMemCuboidMapper.java
----------------------------------------------------------------------
diff --git a/job/src/main/java/org/apache/kylin/job/hadoop/cubev2/InMemCuboidMapper.java b/job/src/main/java/org/apache/kylin/job/hadoop/cubev2/InMemCuboidMapper.java
index 4f6f295..e600b1d 100644
--- a/job/src/main/java/org/apache/kylin/job/hadoop/cubev2/InMemCuboidMapper.java
+++ b/job/src/main/java/org/apache/kylin/job/hadoop/cubev2/InMemCuboidMapper.java
@@ -27,7 +27,7 @@ import org.apache.kylin.dict.Dictionary;
import org.apache.kylin.dict.lookup.HiveTableReader;
import org.apache.kylin.job.constant.BatchConstants;
import org.apache.kylin.job.hadoop.AbstractHadoopJob;
-import org.apache.kylin.job.inmemcubing.InMemCubeBuilder;
+import org.apache.kylin.job.inmemcubing.DoggedCubeBuilder;
import org.apache.kylin.metadata.model.SegmentStatusEnum;
import org.apache.kylin.metadata.model.TblColRef;
@@ -75,7 +75,7 @@ public class InMemCuboidMapper<KEYIN> extends KylinMapper<KEYIN, HCatRecord, Imm
}
}
- InMemCubeBuilder cubeBuilder = new InMemCubeBuilder(cube.getDescriptor(), dictionaryMap);
+ DoggedCubeBuilder cubeBuilder = new DoggedCubeBuilder(cube.getDescriptor(), dictionaryMap);
ExecutorService executorService = Executors.newSingleThreadExecutor();
future = executorService.submit(cubeBuilder.buildAsRunnable(queue, new MapContextGTRecordWriter(context, cubeDesc, cubeSegment)));