Repository: kylin Updated Branches: refs/heads/KYLIN-2428 a5a0904a7 -> 9da563352
KYLIN-2428 add more Serializable mapping Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/9da56335 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9da56335 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9da56335 Branch: refs/heads/KYLIN-2428 Commit: 9da56335253095ff48e5ac87f5c815022d3f0d4f Parents: a5a0904 Author: Billy Liu <billy...@apache.org> Authored: Tue Feb 14 13:08:44 2017 +0800 Committer: Billy Liu <billy...@apache.org> Committed: Tue Feb 14 13:08:44 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/cube/model/CubeDesc.java | 2 +- .../org/apache/kylin/dimension/BooleanDimEnc.java | 3 ++- .../org/apache/kylin/dimension/DateDimEnc.java | 4 +++- .../apache/kylin/dimension/DictionaryDimEnc.java | 3 ++- .../org/apache/kylin/dimension/FixedLenDimEnc.java | 3 ++- .../apache/kylin/dimension/FixedLenHexDimEnc.java | 3 ++- .../java/org/apache/kylin/dimension/IntDimEnc.java | 3 ++- .../org/apache/kylin/dimension/IntegerDimEnc.java | 3 ++- .../kylin/dimension/OneMoreByteVLongDimEnc.java | 3 ++- .../org/apache/kylin/dimension/TimeDimEnc.java | 4 +++- .../org/apache/kylin/measure/topn/Counter.java | 3 ++- .../apache/kylin/metadata/model/DataModelDesc.java | 5 +++-- .../apache/kylin/metadata/model/PartitionDesc.java | 2 +- .../kylin/metadata/model/SegmentStatusEnum.java | 4 +++- .../org/apache/kylin/metadata/model/Segments.java | 3 ++- .../realization/RealizationStatusEnum.java | 4 +++- .../kylin/engine/spark/KylinKryoRegistrator.java | 17 +++++++++++++++++ 17 files changed, 52 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java ---------------------------------------------------------------------- diff --git a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java index 9acb90c..0c1419d 100644 --- a/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java +++ b/core-cube/src/main/java/org/apache/kylin/cube/model/CubeDesc.java @@ -97,7 +97,7 @@ public class CubeDesc extends RootPersistentEntity implements IEngineAware { } } - public enum DeriveType { + public enum DeriveType implements java.io.Serializable{ LOOKUP, PK_FK, EXTENDED_COLUMN } http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/BooleanDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/BooleanDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/BooleanDimEnc.java index bb759da..fbdb0bb 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/BooleanDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/BooleanDimEnc.java @@ -21,6 +21,7 @@ package org.apache.kylin.dimension; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.Arrays; import java.util.Map; @@ -33,7 +34,7 @@ import com.google.common.collect.Maps; /** * Encoding Boolean values to bytes */ -public class BooleanDimEnc extends DimensionEncoding { +public class BooleanDimEnc extends DimensionEncoding implements Serializable{ private static final long serialVersionUID = 1L; public static final String ENCODING_NAME = "boolean"; http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/DateDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/DateDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/DateDimEnc.java index 79e00ce..3b390d9 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/DateDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/DateDimEnc.java @@ -18,10 +18,12 @@ package org.apache.kylin.dimension; +import java.io.Serializable; + /** * This encoding is meant to be IDENTICAL to DateStrDictionary for 100% backward compatibility. */ -public class DateDimEnc extends AbstractDateDimEnc { +public class DateDimEnc extends AbstractDateDimEnc implements Serializable{ private static final long serialVersionUID = 1L; public static final int ID_9999_12_31 = 3652426; http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/DictionaryDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/DictionaryDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/DictionaryDimEnc.java index 48238dc..cfa10b9 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/DictionaryDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/DictionaryDimEnc.java @@ -21,6 +21,7 @@ package org.apache.kylin.dimension; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; import java.nio.ByteBuffer; import org.apache.kylin.common.util.BytesUtil; @@ -29,7 +30,7 @@ import org.apache.kylin.metadata.datatype.DataTypeSerializer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class DictionaryDimEnc extends DimensionEncoding { +public class DictionaryDimEnc extends DimensionEncoding implements Serializable{ private static final long serialVersionUID = 1L; private static final Logger logger = LoggerFactory.getLogger(DictionaryDimEnc.class); http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenDimEnc.java index f7f02a0..9ce1577 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenDimEnc.java @@ -21,6 +21,7 @@ package org.apache.kylin.dimension; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.Arrays; @@ -29,7 +30,7 @@ import org.apache.kylin.metadata.datatype.DataTypeSerializer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class FixedLenDimEnc extends DimensionEncoding { +public class FixedLenDimEnc extends DimensionEncoding implements Serializable{ private static final long serialVersionUID = 1L; private static Logger logger = LoggerFactory.getLogger(FixedLenDimEnc.class); http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenHexDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenHexDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenHexDimEnc.java index f90a40e..a931450 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenHexDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/FixedLenHexDimEnc.java @@ -21,6 +21,7 @@ package org.apache.kylin.dimension; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.Arrays; @@ -43,7 +44,7 @@ import com.google.common.base.Preconditions; * <p> * Due to these limitations hex representation of hash values(with no padding, better with even characters) is more suitable */ -public class FixedLenHexDimEnc extends DimensionEncoding { +public class FixedLenHexDimEnc extends DimensionEncoding implements Serializable{ private static final long serialVersionUID = 1L; private static Logger logger = LoggerFactory.getLogger(FixedLenHexDimEnc.class); http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/IntDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/IntDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/IntDimEnc.java index aa954da..3650200 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/IntDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/IntDimEnc.java @@ -21,6 +21,7 @@ package org.apache.kylin.dimension; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.Arrays; @@ -33,7 +34,7 @@ import org.slf4j.LoggerFactory; * deprecated use IntegerDimEnc instead * @deprecated */ -public class IntDimEnc extends DimensionEncoding { +public class IntDimEnc extends DimensionEncoding implements Serializable{ private static final long serialVersionUID = 1L; private static Logger logger = LoggerFactory.getLogger(IntDimEnc.class); http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/IntegerDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/IntegerDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/IntegerDimEnc.java index 0875a7f..e024696 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/IntegerDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/IntegerDimEnc.java @@ -21,6 +21,7 @@ package org.apache.kylin.dimension; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.Arrays; @@ -36,7 +37,7 @@ import org.slf4j.LoggerFactory; * -2^(8*N-1) is not supported because the slot is reserved for null values. * -2^(8*N-1) will be encoded with warn, and its output will be null */ -public class IntegerDimEnc extends DimensionEncoding { +public class IntegerDimEnc extends DimensionEncoding implements Serializable{ private static final long serialVersionUID = 1L; private static Logger logger = LoggerFactory.getLogger(IntegerDimEnc.class); http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/OneMoreByteVLongDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/OneMoreByteVLongDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/OneMoreByteVLongDimEnc.java index c0c52d1..d998f44 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/OneMoreByteVLongDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/OneMoreByteVLongDimEnc.java @@ -26,13 +26,14 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; import java.nio.ByteBuffer; import java.util.Arrays; /** * not being used yet, prepared for future */ -public class OneMoreByteVLongDimEnc extends DimensionEncoding { +public class OneMoreByteVLongDimEnc extends DimensionEncoding implements Serializable{ private static final long serialVersionUID = 1L; private static Logger logger = LoggerFactory.getLogger(OneMoreByteVLongDimEnc.class); http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/dimension/TimeDimEnc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/dimension/TimeDimEnc.java b/core-metadata/src/main/java/org/apache/kylin/dimension/TimeDimEnc.java index 8c66d5d..4bef2b8 100644 --- a/core-metadata/src/main/java/org/apache/kylin/dimension/TimeDimEnc.java +++ b/core-metadata/src/main/java/org/apache/kylin/dimension/TimeDimEnc.java @@ -18,10 +18,12 @@ package org.apache.kylin.dimension; +import java.io.Serializable; + /** * This encoding is meant to be IDENTICAL to TimeStrDictionary for 100% backward compatibility. */ -public class TimeDimEnc extends AbstractDateDimEnc { +public class TimeDimEnc extends AbstractDateDimEnc implements Serializable{ private static final long serialVersionUID = 1L; public static final String ENCODING_NAME = "time"; http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/measure/topn/Counter.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/measure/topn/Counter.java b/core-metadata/src/main/java/org/apache/kylin/measure/topn/Counter.java index 2f625af..d8fdc6e 100644 --- a/core-metadata/src/main/java/org/apache/kylin/measure/topn/Counter.java +++ b/core-metadata/src/main/java/org/apache/kylin/measure/topn/Counter.java @@ -22,13 +22,14 @@ import java.io.Externalizable; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; +import java.io.Serializable; /** * Modified from Counter.java in https://github.com/addthis/stream-lib * * @param <T> */ -public class Counter<T> implements Externalizable { +public class Counter<T> implements Externalizable, Serializable{ protected T item; protected double count; http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java index 86eea55..c04de0d 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/DataModelDesc.java @@ -18,6 +18,7 @@ package org.apache.kylin.metadata.model; +import java.io.Serializable; import java.util.ArrayList; import java.util.Arrays; import java.util.HashSet; @@ -48,11 +49,11 @@ import com.google.common.collect.Sets; public class DataModelDesc extends RootPersistentEntity { private static final Logger logger = LoggerFactory.getLogger(DataModelDesc.class); - public static enum TableKind { + public static enum TableKind implements Serializable{ FACT, LOOKUP } - public static enum RealizationCapacity { + public static enum RealizationCapacity implements Serializable{ SMALL, MEDIUM, LARGE } http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/metadata/model/PartitionDesc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/PartitionDesc.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/PartitionDesc.java index c6e6425..38c2de5 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/PartitionDesc.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/PartitionDesc.java @@ -34,7 +34,7 @@ import java.io.Serializable; @JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE) public class PartitionDesc implements Serializable { - public static enum PartitionType { + public static enum PartitionType implements Serializable{ APPEND, // UPDATE_INSERT // not used since 0.7.1 } http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/metadata/model/SegmentStatusEnum.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/SegmentStatusEnum.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/SegmentStatusEnum.java index 65c44df..689a314 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/SegmentStatusEnum.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/SegmentStatusEnum.java @@ -18,10 +18,12 @@ package org.apache.kylin.metadata.model; +import java.io.Serializable; + /** * @author xduo * */ -public enum SegmentStatusEnum { +public enum SegmentStatusEnum implements Serializable{ NEW, READY, READY_PENDING } http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java index 9371f76..9d22dc6 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/Segments.java @@ -19,6 +19,7 @@ package org.apache.kylin.metadata.model; import java.io.IOException; +import java.io.Serializable; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; @@ -27,7 +28,7 @@ import org.apache.kylin.common.util.Pair; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class Segments<T extends ISegment> extends ArrayList<T> { +public class Segments<T extends ISegment> extends ArrayList<T> implements Serializable{ private static final long serialVersionUID = 1L; http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/core-metadata/src/main/java/org/apache/kylin/metadata/realization/RealizationStatusEnum.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/realization/RealizationStatusEnum.java b/core-metadata/src/main/java/org/apache/kylin/metadata/realization/RealizationStatusEnum.java index 27e2d57..872d2e4 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/realization/RealizationStatusEnum.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/realization/RealizationStatusEnum.java @@ -18,7 +18,9 @@ package org.apache.kylin.metadata.realization; -public enum RealizationStatusEnum { +import java.io.Serializable; + +public enum RealizationStatusEnum implements Serializable{ DISABLED, READY, DESCBROKEN http://git-wip-us.apache.org/repos/asf/kylin/blob/9da56335/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 8ccae47..b49327f 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 @@ -141,6 +141,7 @@ public class KylinKryoRegistrator implements KryoRegistrator { 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); @@ -168,13 +169,22 @@ public class KylinKryoRegistrator implements KryoRegistrator { kyroClasses.add(org.apache.kylin.dict.TrieDictionary.class); kyroClasses.add(org.apache.kylin.dict.TrieDictionaryForest.class); kyroClasses.add(org.apache.kylin.dict.lookup.SnapshotTable.class); + kyroClasses.add(org.apache.kylin.dimension.BooleanDimEnc.class); kyroClasses.add(org.apache.kylin.dimension.BooleanDimEnc.BooleanSerializer.class); + kyroClasses.add(org.apache.kylin.dimension.DateDimEnc.class); + kyroClasses.add(org.apache.kylin.dimension.DictionaryDimEnc.class); kyroClasses.add(org.apache.kylin.dimension.DictionaryDimEnc.DictionarySerializer.class); + kyroClasses.add(org.apache.kylin.dimension.FixedLenDimEnc.class); kyroClasses.add(org.apache.kylin.dimension.FixedLenDimEnc.FixedLenSerializer.class); + kyroClasses.add(org.apache.kylin.dimension.FixedLenHexDimEnc.class); kyroClasses.add(org.apache.kylin.dimension.FixedLenHexDimEnc.FixedLenSerializer.class); + kyroClasses.add(org.apache.kylin.dimension.IntDimEnc.class); kyroClasses.add(org.apache.kylin.dimension.IntDimEnc.IntegerSerializer.class); + kyroClasses.add(org.apache.kylin.dimension.IntegerDimEnc.class); kyroClasses.add(org.apache.kylin.dimension.IntegerDimEnc.IntegerSerializer.class); + kyroClasses.add(org.apache.kylin.dimension.OneMoreByteVLongDimEnc.class); kyroClasses.add(org.apache.kylin.dimension.OneMoreByteVLongDimEnc.VLongSerializer.class); + kyroClasses.add(org.apache.kylin.dimension.TimeDimEnc.class); kyroClasses.add(org.apache.kylin.engine.mr.common.BaseCuboidBuilder.class); kyroClasses.add(org.apache.kylin.engine.mr.common.NDCuboidBuilder.class); kyroClasses.add(org.apache.kylin.engine.spark.SparkCubingByLayer.class); @@ -233,6 +243,7 @@ public class KylinKryoRegistrator implements KryoRegistrator { kyroClasses.add(org.apache.kylin.measure.raw.RawAggregator.class); kyroClasses.add(org.apache.kylin.measure.raw.RawMeasureType.class); kyroClasses.add(org.apache.kylin.measure.raw.RawSerializer.class); + kyroClasses.add(org.apache.kylin.measure.topn.Counter.class); kyroClasses.add(org.apache.kylin.measure.topn.DoubleDeltaSerializer.class); kyroClasses.add(org.apache.kylin.measure.topn.TopNAggregator.class); kyroClasses.add(org.apache.kylin.measure.topn.TopNCounter.class); @@ -255,6 +266,8 @@ public class KylinKryoRegistrator implements KryoRegistrator { kyroClasses.add(org.apache.kylin.metadata.datatype.StringSerializer.class); kyroClasses.add(org.apache.kylin.metadata.model.ColumnDesc.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.DatabaseDesc.class); kyroClasses.add(org.apache.kylin.metadata.model.ExternalFilterDesc.class); kyroClasses.add(org.apache.kylin.metadata.model.FunctionDesc.class); @@ -266,7 +279,10 @@ public class KylinKryoRegistrator implements KryoRegistrator { 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.PartitionType.class); kyroClasses.add(org.apache.kylin.metadata.model.PartitionDesc.DefaultPartitionConditionBuilder.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.TableExtDesc.ColumnStats.class); @@ -274,6 +290,7 @@ public class KylinKryoRegistrator implements KryoRegistrator { kyroClasses.add(org.apache.kylin.metadata.model.TblColRef.class); kyroClasses.add(org.apache.kylin.metadata.project.ProjectInstance.class); kyroClasses.add(org.apache.kylin.metadata.project.RealizationEntry.class); + kyroClasses.add(org.apache.kylin.metadata.realization.RealizationStatusEnum.class); kyroClasses.add(org.apache.kylin.metadata.streaming.StreamingConfig.class); kyroClasses.add(org.apache.kylin.source.ReadableTable.TableSignature.class); kyroClasses.add(org.apache.kylin.storage.hybrid.HybridInstance.class);
