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/05 14:47:56 UTC
[beam] 03/24: Fix EncoderHelpers.fromBeamCoder() visibility
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 <ec...@apache.org>
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](