Port Java 8 tests to new DoFn
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/879f18fd Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/879f18fd Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/879f18fd Branch: refs/heads/gearpump-runner Commit: 879f18fd1694b0540e3e695416566f24220ecb1e Parents: 331f523 Author: Kenneth Knowles <[email protected]> Authored: Fri Aug 5 12:12:12 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Mon Aug 8 11:35:17 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/transforms/WithTimestampsJava8Test.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/879f18fd/sdks/java/java8tests/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsJava8Test.java ---------------------------------------------------------------------- diff --git a/sdks/java/java8tests/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsJava8Test.java b/sdks/java/java8tests/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsJava8Test.java index 1141e88..03aa647 100644 --- a/sdks/java/java8tests/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsJava8Test.java +++ b/sdks/java/java8tests/src/test/java/org/apache/beam/sdk/transforms/WithTimestampsJava8Test.java @@ -47,9 +47,9 @@ public class WithTimestampsJava8Test implements Serializable { .apply(WithTimestamps.of((String input) -> new Instant(Long.valueOf(yearTwoThousand)))); PCollection<KV<String, Instant>> timestampedVals = - timestamped.apply(ParDo.of(new OldDoFn<String, KV<String, Instant>>() { - @Override - public void processElement(OldDoFn<String, KV<String, Instant>>.ProcessContext c) + timestamped.apply(ParDo.of(new DoFn<String, KV<String, Instant>>() { + @ProcessElement + public void processElement(ProcessContext c) throws Exception { c.output(KV.of(c.element(), c.timestamp())); }
