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 <[email protected]> Authored: Mon Feb 13 22:02:07 2017 +0800 Committer: Billy Liu <[email protected]> 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);
