beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From boyu...@apache.org
Subject [beam] branch master updated: fix PerPartitionSubscriptionSdf methods with incorrect visibility
Date Wed, 16 Dec 2020 18:38:00 GMT
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-google@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);
   }
 


Mime
View raw message