You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by bi...@apache.org on 2017/02/13 14:02:20 UTC
kylin git commit: KYLIN-2428 add more kyro mapping2
Repository: kylin
Updated Branches:
refs/heads/KYLIN-2428 aa629dde4 -> 900436e36
KYLIN-2428 add more kyro mapping2
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/900436e3
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/900436e3
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/900436e3
Branch: refs/heads/KYLIN-2428
Commit: 900436e36505bc3973446204958f9f179a4b1b8c
Parents: aa629dd
Author: Billy Liu <bi...@apache.org>
Authored: Mon Feb 13 22:02:07 2017 +0800
Committer: Billy Liu <bi...@apache.org>
Committed: Mon Feb 13 22:02:07 2017 +0800
----------------------------------------------------------------------
.../org/apache/kylin/engine/spark/KylinKryoRegistrator.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/900436e3/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java
----------------------------------------------------------------------
diff --git a/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java b/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java
index d5a4479..c99ee6e 100644
--- a/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java
+++ b/engine-spark/src/main/java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java
@@ -74,6 +74,7 @@ public class KylinKryoRegistrator implements KryoRegistrator {
kyroClasses.add(org.apache.kylin.common.util.Array.class);
kyroClasses.add(org.apache.kylin.common.util.SplittedBytes[].class);
kyroClasses.add(org.apache.kylin.common.util.SplittedBytes.class);
+ kyroClasses.add(org.apache.kylin.metadata.model.ColumnDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.ColumnDesc[].class);
kyroClasses.add(org.apache.kylin.metadata.model.DatabaseDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.DataModelDesc.class);
@@ -81,8 +82,11 @@ public class KylinKryoRegistrator implements KryoRegistrator {
kyroClasses.add(org.apache.kylin.metadata.model.DataModelDesc.TableKind.class);
kyroClasses.add(org.apache.kylin.metadata.model.FunctionDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.JoinDesc.class);
+ kyroClasses.add(org.apache.kylin.metadata.model.JoinTableDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.JoinTableDesc[].class);
+ kyroClasses.add(org.apache.kylin.metadata.model.TblColRef.class);
kyroClasses.add(org.apache.kylin.metadata.model.TblColRef[].class);
+ kyroClasses.add(org.apache.kylin.metadata.model.MeasureDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.MeasureDesc[].class);
kyroClasses.add(org.apache.kylin.metadata.model.ModelDimensionDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.ParameterDesc.class);
@@ -96,9 +100,11 @@ public class KylinKryoRegistrator implements KryoRegistrator {
kyroClasses.add(org.apache.kylin.metadata.model.TableRef.class);
kyroClasses.add(org.apache.kylin.metadata.model.TblColRef.class);
kyroClasses.add(org.apache.kylin.metadata.realization.RealizationStatusEnum.class);
+ kyroClasses.add(org.apache.kylin.metadata.datatype.DataTypeSerializer.class);
kyroClasses.add(org.apache.kylin.metadata.datatype.DataTypeSerializer[].class);
kyroClasses.add(org.apache.kylin.measure.BufferedMeasureCodec.class);
kyroClasses.add(org.apache.kylin.measure.MeasureCodec.class);
+ kyroClasses.add(org.apache.kylin.measure.MeasureAggregator.class);
kyroClasses.add(org.apache.kylin.measure.MeasureAggregator[].class);
kyroClasses.add(org.apache.kylin.measure.basic.BasicMeasureType.class);
kyroClasses.add(org.apache.kylin.measure.basic.BigDecimalIngester.class);
@@ -117,10 +123,13 @@ public class KylinKryoRegistrator implements KryoRegistrator {
kyroClasses.add(org.apache.kylin.cube.model.CubeJoinedFlatTableEnrich.class);
kyroClasses.add(org.apache.kylin.cube.model.DictionaryDesc.class);
kyroClasses.add(org.apache.kylin.cube.model.DimensionDesc.class);
+ kyroClasses.add(org.apache.kylin.cube.model.HBaseColumnFamilyDesc.class);
kyroClasses.add(org.apache.kylin.cube.model.HBaseColumnFamilyDesc[].class);
+ kyroClasses.add(org.apache.kylin.cube.model.HBaseColumnDesc.class);
kyroClasses.add(org.apache.kylin.cube.model.HBaseColumnDesc[].class);
kyroClasses.add(org.apache.kylin.cube.model.HBaseMappingDesc.class);
kyroClasses.add(org.apache.kylin.cube.model.HierarchyDesc.class);
+ kyroClasses.add(org.apache.kylin.cube.model.RowKeyColDesc.class);
kyroClasses.add(org.apache.kylin.cube.model.RowKeyColDesc[].class);
kyroClasses.add(org.apache.kylin.cube.model.RowKeyDesc.class);
kyroClasses.add(org.apache.kylin.cube.model.SelectRule.class);