You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2019/06/20 17:20:23 UTC
[beam] branch master updated: Make PubsubIO#withCoderAndParseFn
public (#8879)
This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new c775eda Make PubsubIO#withCoderAndParseFn public (#8879)
c775eda is described below
commit c775eda2df6457a784a1945d16cf781abb453d5f
Author: Claire McGinty <cl...@gmail.com>
AuthorDate: Thu Jun 20 13:20:08 2019 -0400
Make PubsubIO#withCoderAndParseFn public (#8879)
---
.../src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
index 61cd8ce..d3883d2 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
@@ -788,7 +788,7 @@ public class PubsubIO {
* output type T must be registered or set on the output via {@link
* PCollection#setCoder(Coder)}.
*/
- private Read<T> withCoderAndParseFn(Coder<T> coder, SimpleFunction<PubsubMessage, T> parseFn) {
+ public Read<T> withCoderAndParseFn(Coder<T> coder, SimpleFunction<PubsubMessage, T> parseFn) {
return toBuilder().setCoder(coder).setParseFn(parseFn).build();
}