[beam] 08/08: Put all transform translators Serializable

[ec...@apache.org]

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 a7d2328d697319be6d5ebea196cfe9389b5cda0f
Author: Etienne Chauchot <ec...@apache.org>
AuthorDate: Fri Jan 11 11:24:39 2019 +0100

    Put all transform translators Serializable
---
 .../spark/structuredstreaming/translation/TransformTranslator.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TransformTranslator.java b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TransformTranslator.java
index f9558c9..097013b 100644
--- a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TransformTranslator.java
+++ b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TransformTranslator.java
@@ -17,10 +17,11 @@
  */
 package org.apache.beam.runners.spark.structuredstreaming.translation;
 
+import java.io.Serializable;
 import org.apache.beam.sdk.transforms.PTransform;
 
 /** Supports translation between a Beam transform, and Spark's operations on Datasets. */
-public interface TransformTranslator<TransformT extends PTransform> {
+public interface TransformTranslator<TransformT extends PTransform> extends Serializable {
 
   /** Base class for translators of {@link PTransform}. */
   void translateTransform(TransformT transform, TranslationContext context);