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:48:00 UTC
[beam] 07/24: Fix visibility of serializer and deserializer
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 <ec...@apache.org>
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;