You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bo...@apache.org on 2020/12/16 18:38:00 UTC
[beam] branch master updated: fix PerPartitionSubscriptionSdf
methods with incorrect visibility
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 <40...@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);
}