KryoRegistrator add ComputedColumnDesc
Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/3326b089 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/3326b089 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/3326b089 Branch: refs/heads/KYLIN-2653 Commit: 3326b0897b3f839cc34c9c8030571d02627d2629 Parents: 6413c28 Author: kangkaisen <kangkai...@meituan.com> Authored: Thu Jul 13 20:18:17 2017 +0800 Committer: kangkaisen <kangkai...@meituan.com> Committed: Sat Jul 22 14:59:54 2017 +0800 ---------------------------------------------------------------------- .../java/org/apache/kylin/metadata/model/ComputedColumnDesc.java | 4 +++- .../java/org/apache/kylin/engine/spark/KylinKryoRegistrator.java | 1 + 2 files changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/3326b089/core-metadata/src/main/java/org/apache/kylin/metadata/model/ComputedColumnDesc.java ---------------------------------------------------------------------- diff --git a/core-metadata/src/main/java/org/apache/kylin/metadata/model/ComputedColumnDesc.java b/core-metadata/src/main/java/org/apache/kylin/metadata/model/ComputedColumnDesc.java index 540b5fc..e8cc351 100644 --- a/core-metadata/src/main/java/org/apache/kylin/metadata/model/ComputedColumnDesc.java +++ b/core-metadata/src/main/java/org/apache/kylin/metadata/model/ComputedColumnDesc.java @@ -22,8 +22,10 @@ import com.fasterxml.jackson.annotation.JsonProperty; import com.google.common.base.Preconditions; import org.apache.kylin.metadata.model.tool.CalciteParser; +import java.io.Serializable; + @JsonAutoDetect(fieldVisibility = JsonAutoDetect.Visibility.NONE, getterVisibility = JsonAutoDetect.Visibility.NONE, isGetterVisibility = JsonAutoDetect.Visibility.NONE, setterVisibility = JsonAutoDetect.Visibility.NONE) -public class ComputedColumnDesc { +public class ComputedColumnDesc implements Serializable { @JsonProperty private String tableIdentity; @JsonProperty http://git-wip-us.apache.org/repos/asf/kylin/blob/3326b089/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 106653f..048f62b 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 @@ -269,6 +269,7 @@ public class KylinKryoRegistrator implements KryoRegistrator { 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.ComputedColumnDesc.class); kyroClasses.add(org.apache.kylin.metadata.model.ExternalFilterDesc.class); kyroClasses.add(org.apache.kylin.metadata.model.FunctionDesc.class); kyroClasses.add(org.apache.kylin.metadata.model.JoinDesc.class);