You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/05/24 19:05:36 UTC
[1/2] incubator-beam git commit: Updated all existing instances of
PCollection's #setCoder to use Create.of use it's #withCoder
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 <il...@capitalone.com>
Authored: Mon May 23 16:34:38 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
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)
[2/2] incubator-beam git commit: This closes #378
Posted by ke...@apache.org.
This closes #378
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8ff800b9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8ff800b9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8ff800b9
Branch: refs/heads/master
Commit: 8ff800b974c451267344095cd08a65086e01fca8
Parents: e2307f2 6ce3640
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue May 24 12:05:25 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue May 24 12:05:25 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(-)
----------------------------------------------------------------------