You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ec...@apache.org on 2019/09/06 08:53:06 UTC
[beam] 01/02: Put Encoders expressions serializable
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 3a333fb2fbdbe32df9e6eaaa6484f53692c805c1
Author: Etienne Chauchot <ec...@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;