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 13:36:36 UTC
kylin git commit: KYLIN-2428 add more kyro mapping
Repository: kylin
Updated Branches:
refs/heads/KYLIN-2428 401c38a23 -> aa629dde4
KYLIN-2428 add more kyro mapping
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/aa629dde
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/aa629dde
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/aa629dde
Branch: refs/heads/KYLIN-2428
Commit: aa629dde40f00a095b17da8e86e020e1a65f9115
Parents: 401c38a
Author: Billy Liu <bi...@apache.org>
Authored: Mon Feb 13 21:36:26 2017 +0800
Committer: Billy Liu <bi...@apache.org>
Committed: Mon Feb 13 21:36:26 2017 +0800
----------------------------------------------------------------------
.../engine/spark/KylinKryoRegistrator.java | 27 ++++++++++++++++----
1 file changed, 22 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kylin/blob/aa629dde/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 9168c37..d5a4479 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
@@ -75,17 +75,26 @@ public class KylinKryoRegistrator implements KryoRegistrator {
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.JoinTableDesc[].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.DatabaseDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.DataModelDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.DataModelDesc.RealizationCapacity.class);
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.TblColRef[].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);
kyroClasses.add(org.apache.kylin.metadata.model.PartitionDesc.class);
kyroClasses.add(org.apache.kylin.metadata.model.PartitionDesc.DefaultPartitionConditionBuilder.class);
kyroClasses.add(org.apache.kylin.metadata.model.PartitionDesc.PartitionType.class);
kyroClasses.add(org.apache.kylin.metadata.model.Segments.class);
kyroClasses.add(org.apache.kylin.metadata.model.SegmentStatusEnum.class);
+ kyroClasses.add(org.apache.kylin.metadata.model.TableDesc.class);
+ kyroClasses.add(org.apache.kylin.metadata.model.TableExtDesc.class);
+ 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.measure.BufferedMeasureCodec.class);
@@ -99,14 +108,22 @@ public class KylinKryoRegistrator implements KryoRegistrator {
kyroClasses.add(org.apache.kylin.measure.topn.TopNCounter.class);
kyroClasses.add(org.apache.kylin.measure.topn.DoubleDeltaSerializer.class);
kyroClasses.add(org.apache.kylin.measure.percentile.PercentileSerializer.class);
+ kyroClasses.add(org.apache.kylin.cube.model.AggregationGroup.class);
+ kyroClasses.add(org.apache.kylin.cube.model.AggregationGroup.HierarchyMask.class);
kyroClasses.add(org.apache.kylin.cube.model.CubeDesc.class);
kyroClasses.add(org.apache.kylin.cube.model.CubeDesc.DeriveInfo.class);
kyroClasses.add(org.apache.kylin.cube.model.CubeDesc.DeriveType.class);
+ kyroClasses.add(org.apache.kylin.cube.model.CubeJoinedFlatTableDesc.class);
+ 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.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.AggregationGroup.class);
- kyroClasses.add(org.apache.kylin.cube.model.AggregationGroup.HierarchyMask.class);
+ kyroClasses.add(org.apache.kylin.cube.model.RowKeyDesc.class);
+ kyroClasses.add(org.apache.kylin.cube.model.SelectRule.class);
kyroClasses.add(org.apache.kylin.cube.kv.RowKeyColumnIO.class);
kyroClasses.add(org.apache.kylin.cube.kv.CubeDimEncMap.class);
kyroClasses.add(org.apache.kylin.cube.kv.RowKeyEncoderProvider.class);