Remove use of OldDoFn in ValueWithRecordId
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/40513578 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/40513578 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/40513578 Branch: refs/heads/apex-runner Commit: 4051357870b88ed18d09ef502ee8b1cf5142979f Parents: 7abdcbf Author: Kenneth Knowles <k...@google.com> Authored: Mon Oct 24 15:57:18 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Oct 25 13:12:17 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/util/ValueWithRecordId.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/40513578/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ValueWithRecordId.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ValueWithRecordId.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ValueWithRecordId.java index d6b5fe3..abca598 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ValueWithRecordId.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/ValueWithRecordId.java @@ -31,7 +31,7 @@ import java.util.Objects; import org.apache.beam.sdk.coders.ByteArrayCoder; import org.apache.beam.sdk.coders.Coder; import org.apache.beam.sdk.coders.StandardCoder; -import org.apache.beam.sdk.transforms.OldDoFn; +import org.apache.beam.sdk.transforms.DoFn; /** * Immutable struct containing a value as well as a unique id identifying the value. @@ -136,9 +136,9 @@ public class ValueWithRecordId<ValueT> { ByteArrayCoder idCoder; } - /** {@link OldDoFn} to turn a {@code ValueWithRecordId<T>} back to the value {@code T}. */ - public static class StripIdsDoFn<T> extends OldDoFn<ValueWithRecordId<T>, T> { - @Override + /** {@link DoFn} to turn a {@code ValueWithRecordId<T>} back to the value {@code T}. */ + public static class StripIdsDoFn<T> extends DoFn<ValueWithRecordId<T>, T> { + @ProcessElement public void processElement(ProcessContext c) { c.output(c.element().getValue()); }