beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From echauc...@apache.org
Subject [beam] 22/37: Put Encoders expressions serializable
Date Thu, 24 Oct 2019 10:15:31 GMT
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 <echauchot@apache.org>
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;


Mime
View raw message