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:38 UTC
[07/18] incubator-beam git commit: Make OrFinallyTrigger public so it
can be examined
Make OrFinallyTrigger public so it can be examined
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2e565172
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2e565172
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2e565172
Branch: refs/heads/master
Commit: 2e565172d74bc906bdbdb1c4ee986c9e3d65089f
Parents: 303a42a
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Oct 13 20:58:12 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Oct 17 19:56:35 2016 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/2e565172/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java
index 1a03450..9bef45a 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java
@@ -26,7 +26,7 @@ import org.joda.time.Instant;
/**
* Executes the {@code actual} trigger until it finishes or until the {@code until} trigger fires.
*/
-class OrFinallyTrigger extends Trigger {
+public class OrFinallyTrigger extends Trigger {
private static final int ACTUAL = 0;
private static final int UNTIL = 1;