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 <echauc...@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);