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 e96af88096a6798ff0de2f24a95273334b3d9c7d Author: Etienne Chauchot <[email protected]> AuthorDate: Thu Aug 29 15:18:44 2019 +0200 Fix visibility of serializer and deserializer --- .../structuredstreaming/translation/helpers/EncoderHelpers.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 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 002545e..0765c78 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 @@ -126,12 +126,12 @@ public class EncoderHelpers { */ } - private static class EncodeUsingBeamCoder<T> extends UnaryExpression implements NonSQLExpression { + public static class EncodeUsingBeamCoder<T> extends UnaryExpression implements NonSQLExpression { private Expression child; private Coder<T> beamCoder; - private EncodeUsingBeamCoder(Expression child, Coder<T> beamCoder) { + public EncodeUsingBeamCoder(Expression child, Coder<T> beamCoder) { this.child = child; this.beamCoder = beamCoder; } @@ -231,13 +231,13 @@ public class EncoderHelpers { override def dataType: DataType = BinaryType }*/ - private static class DecodeUsingBeamCoder<T> extends UnaryExpression implements NonSQLExpression{ + public static class DecodeUsingBeamCoder<T> extends UnaryExpression implements NonSQLExpression{ private Expression child; private ClassTag<T> classTag; private Coder<T> beamCoder; - private DecodeUsingBeamCoder(Expression child, ClassTag<T> classTag, Coder<T> beamCoder) { + public DecodeUsingBeamCoder(Expression child, ClassTag<T> classTag, Coder<T> beamCoder) { this.child = child; this.classTag = classTag; this.beamCoder = beamCoder;
