[beam] branch master updated: fix PerPartitionSubscriptionSdf methods with incorrect visibility

[boyuanz]

This is an automated email from the ASF dual-hosted git repository.

boyuanz 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 97ad770  fix PerPartitionSubscriptionSdf methods with incorrect 
visibility
     new 92209d1  Merge pull request #13566 from fix 
PerPartitionSubscriptionSdf methods with incorrect visibility
97ad770 is described below

commit 97ad7702ea1d3d01a1b6e52d87dec3fc75a6a886
Author: dpcollins-google <40498610+dpcollins-goo...@users.noreply.github.com>
AuthorDate: Wed Dec 16 13:00:50 2020 -0500

    fix PerPartitionSubscriptionSdf methods with incorrect visibility
---
 .../beam/sdk/io/gcp/pubsublite/PerSubscriptionPartitionSdf.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PerSubscriptionPartitionSdf.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PerSubscriptionPartitionSdf.java
index 6c47908..c9e1e69 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PerSubscriptionPartitionSdf.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PerSubscriptionPartitionSdf.java
@@ -57,12 +57,12 @@ class PerSubscriptionPartitionSdf extends 
DoFn<SubscriptionPartition, SequencedM
   }
 
   @GetInitialWatermarkEstimatorState
-  Instant getInitialWatermarkState() {
+  public Instant getInitialWatermarkState() {
     return Instant.EPOCH;
   }
 
   @NewWatermarkEstimator
-  MonotonicallyIncreasing newWatermarkEstimator(@WatermarkEstimatorState 
Instant state) {
+  public MonotonicallyIncreasing 
newWatermarkEstimator(@WatermarkEstimatorState Instant state) {
     return new MonotonicallyIncreasing(state);
   }