You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/10/18 03:38:35 UTC
[04/18] incubator-beam git commit: Make
AfterSynchronizedProcessingTime public
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 <kl...@google.com>
Authored: Thu Oct 13 20:43:33 2016 -0700
Committer: Kenneth Knowles <kl...@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