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:42 UTC
[11/18] incubator-beam git commit: Add accessors for
AfterPane(StateMachine) parameters
Add accessors for AfterPane(StateMachine) parameters
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e0c57664
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e0c57664
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e0c57664
Branch: refs/heads/master
Commit: e0c576649382ea4d1d70ee9e54ff25018210dcfb
Parents: b4445ac
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Oct 13 22:14:32 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Oct 17 19:56:36 2016 -0700
----------------------------------------------------------------------
.../beam/runners/core/triggers/AfterPaneStateMachine.java | 7 +++++++
.../org/apache/beam/sdk/transforms/windowing/AfterPane.java | 7 +++++++
2 files changed, 14 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e0c57664/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java
----------------------------------------------------------------------
diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java
index 723aba6..288643d 100644
--- a/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java
+++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java
@@ -49,6 +49,13 @@ private static final StateTag<Object, AccumulatorCombiningState<Long, long[], Lo
}
/**
+ * The number of elements after which this trigger may fire.
+ */
+ public int getElementCount() {
+ return countElems;
+ }
+
+ /**
* Creates a trigger that fires when the pane contains at least {@code countElems} elements.
*/
public static AfterPaneStateMachine elementCountAtLeast(int countElems) {
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e0c57664/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java
index 8c128dd..4d59d58 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java
@@ -51,6 +51,13 @@ private static final StateTag<Object, AccumulatorCombiningState<Long, long[], Lo
}
/**
+ * The number of elements after which this trigger may fire.
+ */
+ public int getElementCount() {
+ return countElems;
+ }
+
+ /**
* Creates a trigger that fires when the pane contains at least {@code countElems} elements.
*/
public static AfterPane elementCountAtLeast(int countElems) {