Make AfterSynchronizedProcessingTime public We need to be able to access this class to reason about it when converting a trigger to a state machine.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b19918df Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b19918df Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b19918df Branch: refs/heads/master Commit: b19918df1992d445ad8c13a63722c690ddca3899 Parents: 77332f1 Author: Kenneth Knowles <k...@google.com> Authored: Thu Oct 13 20:43:33 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Oct 17 19:56:35 2016 -0700 ---------------------------------------------------------------------- .../transforms/windowing/AfterSynchronizedProcessingTime.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b19918df/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java index 59ece10..b96b293 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java @@ -25,7 +25,11 @@ import org.apache.beam.sdk.transforms.SerializableFunction; import org.apache.beam.sdk.util.TimeDomain; import org.joda.time.Instant; -class AfterSynchronizedProcessingTime extends AfterDelayFromFirstElement { +/** + * A trigger that fires after synchronized processing time has reached a shared + * threshold between upstream workers. + */ +public class AfterSynchronizedProcessingTime extends AfterDelayFromFirstElement { @Override @Nullable