You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/02/13 17:50:24 UTC
[2/2] beam git commit: Make PrepareForProcessing Final, Deprecated
Make PrepareForProcessing Final, Deprecated
This is only used by aggregators; Users should use @Setup or
@StartBundle instead.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/82690271
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/82690271
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/82690271
Branch: refs/heads/master
Commit: 826902717376257d4c22718ba4981b95b9db7db2
Parents: 982ea7a
Author: Thomas Groh <tg...@google.com>
Authored: Mon Feb 13 09:03:32 2017 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Mon Feb 13 09:50:12 2017 -0800
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/82690271/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java
index a161919..126e967 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java
@@ -808,7 +808,8 @@ public abstract class DoFn<InputT, OutputT> implements Serializable, HasDisplayD
* Finalize the {@link DoFn} construction to prepare for processing.
* This method should be called by runners before any processing methods.
*/
- public void prepareForProcessing() {
+ @Deprecated
+ public final void prepareForProcessing() {
aggregatorsAreFinal = true;
}