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 <billy...@apache.org> Authored: Mon Feb 13 21:36:26 2017 +0800 Committer: Billy Liu <billy...@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);
