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/14 05:08:54 UTC
kylin git commit: KYLIN-2428 add more Serializable mapping
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 <bi...@apache.org>
Authored: Tue Feb 14 13:08:44 2017 +0800
Committer: Billy Liu <bi...@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);