Repository: incubator-beam Updated Branches: refs/heads/master e2307f263 -> 8ff800b97
Updated all existing instances of PCollection's #setCoder to use Create.of use it's #withCoder Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6ce36409 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6ce36409 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6ce36409 Branch: refs/heads/master Commit: 6ce364095019933e54282c30964afd2b13c73445 Parents: e2307f2 Author: Ilya Ganelin <[email protected]> Authored: Mon May 23 16:34:38 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue May 24 12:05:05 2016 -0700 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/beam/sdk/io/PubsubIO.java | 2 +- .../src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6ce36409/sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubIO.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubIO.java index 77c0b35..7e24253 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubIO.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/PubsubIO.java @@ -645,7 +645,7 @@ public class PubsubIO { if (boundedOutput) { return input.getPipeline().begin() - .apply(Create.of((Void) null)).setCoder(VoidCoder.of()) + .apply(Create.of((Void) null).withCoder(VoidCoder.of())) .apply(ParDo.of(new PubsubBoundedReader())) .setCoder(coder); } else { http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6ce36409/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java index 2d1b550..7c360b9 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java @@ -514,8 +514,8 @@ public class BigQueryIOTest implements Serializable { p.apply(Create.of( new TableRow().set("name", "a").set("number", 1), new TableRow().set("name", "b").set("number", 2), - new TableRow().set("name", "c").set("number", 3))) - .setCoder(TableRowJsonCoder.of()) + new TableRow().set("name", "c").set("number", 3)) + .withCoder(TableRowJsonCoder.of())) .apply(BigQueryIO.Write.to("dataset-id.table-id") .withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED) .withSchema(new TableSchema().setFields( @@ -547,8 +547,8 @@ public class BigQueryIOTest implements Serializable { p.apply(Create.of( new TableRow().set("name", "a").set("number", 1), new TableRow().set("name", "b").set("number", 2), - new TableRow().set("name", "c").set("number", 3))) - .setCoder(TableRowJsonCoder.of()) + new TableRow().set("name", "c").set("number", 3)) + .withCoder(TableRowJsonCoder.of())) .apply(BigQueryIO.Write.to("project-id:dataset-id.table-id") .withCreateDisposition(CreateDisposition.CREATE_NEVER) .withTestServices(fakeBqServices)
