Add isStateful() to DoFnSignature
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bdd3e086 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bdd3e086 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/bdd3e086 Branch: refs/heads/master Commit: bdd3e0862b91ac682336eb8ff489fff104ea927d Parents: 3a8b9b5 Author: Kenneth Knowles <[email protected]> Authored: Mon Nov 28 16:15:55 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Tue Nov 29 09:24:55 2016 -0800 ---------------------------------------------------------------------- .../org/apache/beam/sdk/transforms/reflect/DoFnSignature.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/bdd3e086/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java index cd93583..0750949 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java @@ -105,6 +105,13 @@ public abstract class DoFnSignature { @Nullable public abstract Map<String, OnTimerMethod> onTimerMethods(); + /** + * Whether the {@link DoFn} described by this signature uses state. + */ + public boolean isStateful() { + return stateDeclarations().size() > 0; + } + static Builder builder() { return new AutoValue_DoFnSignature.Builder(); }
