This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git
commit c8bfcf367c6a4ac855fa2b9d549fa26c39b8be81 Author: Etienne Chauchot <[email protected]> AuthorDate: Fri Sep 6 10:31:36 2019 +0200 Put Encoders expressions serializable --- .../structuredstreaming/translation/helpers/EncoderHelpers.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java index f4ea6fa..e7c5bb7 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java @@ -20,6 +20,7 @@ package org.apache.beam.runners.spark.structuredstreaming.translation.helpers; import static org.apache.spark.sql.types.DataTypes.BinaryType; import java.io.ByteArrayInputStream; +import java.io.Serializable; import java.util.ArrayList; import java.util.List; import java.util.Objects; @@ -114,7 +115,8 @@ public class EncoderHelpers { * * @param <T>: Type of elements ot be serialized. */ - public static class EncodeUsingBeamCoder<T> extends UnaryExpression implements NonSQLExpression { + public static class EncodeUsingBeamCoder<T> extends UnaryExpression + implements NonSQLExpression, Serializable { private Expression child; private Coder<T> beamCoder; @@ -229,7 +231,8 @@ public class EncoderHelpers { * * @param <T>: Type of elements ot be serialized. */ - public static class DecodeUsingBeamCoder<T> extends UnaryExpression implements NonSQLExpression { + public static class DecodeUsingBeamCoder<T> extends UnaryExpression + implements NonSQLExpression, Serializable { private Expression child; private ClassTag<T> classTag;
