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 84f2cbd9b30a72ecc827e9c03de533b8e65190b2 Author: Etienne Chauchot <[email protected]> AuthorDate: Tue Aug 27 17:26:30 2019 +0200 Fix EncoderHelpers.fromBeamCoder() visibility --- .../structuredstreaming/translation/helpers/EncoderHelpers.java | 5 +++-- 1 file changed, 3 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 3159de9b..ab24e37 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 @@ -96,7 +96,7 @@ public class EncoderHelpers { */ /** A way to construct encoders using generic serializers. */ - private <T> Encoder<T> fromBeamCoder(Coder<T> coder, Class<T> claz){ + public static <T> Encoder<T> fromBeamCoder(Coder<T> coder, Class<T> claz){ List<Expression> serialiserList = new ArrayList<>(); serialiserList.add(new EncodeUsingBeamCoder<>(claz, coder)); @@ -105,7 +105,8 @@ public class EncoderHelpers { SchemaHelpers.binarySchema(), false, JavaConversions.collectionAsScalaIterable(serialiserList).toSeq(), - new DecodeUsingBeamCoder<>(claz, coder), classTag); + new DecodeUsingBeamCoder<>(claz, coder), + classTag); /* ExpressionEncoder[T](
