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/11/29 17:34:57 UTC
[3/3] incubator-beam git commit: Add isStateful() to DoFnSignature
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 <kl...@google.com>
Authored: Mon Nov 28 16:15:55 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
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();
}