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 <[email protected]> Authored: Mon Feb 13 09:03:32 2017 -0800 Committer: Thomas Groh <[email protected]> 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; }
