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 <k...@google.com> Authored: Thu Oct 13 22:14:32 2016 -0700 Committer: Kenneth Knowles <k...@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) {