You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2016/11/13 10:34:42 UTC
[2/2] kylin git commit: minor,
remove unnecessary check in BaseCuboidMapperBase
minor, remove unnecessary check in BaseCuboidMapperBase
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/9cdf8e7f
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9cdf8e7f
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9cdf8e7f
Branch: refs/heads/v1.6.0-rc2
Commit: 9cdf8e7feb04c4d79a46e8682d161d902b3a9bfe
Parents: d91d847
Author: Yang Li <li...@apache.org>
Authored: Sun Nov 13 13:12:11 2016 +0800
Committer: shaofengshi <sh...@apache.org>
Committed: Sun Nov 13 18:34:32 2016 +0800
----------------------------------------------------------------------
.../kylin/cube/model/CubeJoinedFlatTableEnrich.java | 11 -----------
.../kylin/engine/mr/steps/BaseCuboidMapperBase.java | 2 --
2 files changed, 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/9cdf8e7f/core-cube/src/main/java/org/apache/kylin/cube/model/CubeJoinedFlatTableEnrich.java
----------------------------------------------------------------------
diff --git a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeJoinedFlatTableEnrich.java b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeJoinedFlatTableEnrich.java
index 8af2297..979af76 100644
--- a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeJoinedFlatTableEnrich.java
+++ b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeJoinedFlatTableEnrich.java
@@ -20,7 +20,6 @@ package org.apache.kylin.cube.model;
import java.util.List;
-import org.apache.kylin.common.util.BytesSplitter;
import org.apache.kylin.cube.cuboid.Cuboid;
import org.apache.kylin.metadata.model.DataModelDesc;
import org.apache.kylin.metadata.model.FunctionDesc;
@@ -81,16 +80,6 @@ public class CubeJoinedFlatTableEnrich implements IJoinedFlatTableDesc {
}
}
- // sanity check the input record (in bytes) matches what's expected
- public void sanityCheck(BytesSplitter bytesSplitter) {
- int columnCount = flatDesc.getAllColumns().size();
- if (columnCount != bytesSplitter.getBufferSize()) {
- throw new IllegalArgumentException("Expect " + columnCount + " columns, but see " + bytesSplitter.getBufferSize() + " -- " + bytesSplitter);
- }
-
- // TODO: check data types here
- }
-
public CubeDesc getCubeDesc() {
return cubeDesc;
}
http://git-wip-us.apache.org/repos/asf/kylin/blob/9cdf8e7f/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/BaseCuboidMapperBase.java
----------------------------------------------------------------------
diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/BaseCuboidMapperBase.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/BaseCuboidMapperBase.java
index 4f0d3fd..38595a0 100644
--- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/BaseCuboidMapperBase.java
+++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/BaseCuboidMapperBase.java
@@ -195,8 +195,6 @@ public class BaseCuboidMapperBase<KEYIN, VALUEIN> extends KylinMapper<KEYIN, VAL
}
protected void outputKV(Context context) throws IOException, InterruptedException {
- intermediateTableDesc.sanityCheck(bytesSplitter);
-
byte[] rowKey = buildKey(bytesSplitter.getSplitBuffers());
outputKey.set(rowKey, 0, rowKey.length);