You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/05/18 21:09:27 UTC
[1/2] beam git commit: Remove incorrect `Message` bound on writeAvros
Repository: beam
Updated Branches:
refs/heads/master 8c572ef0b -> 6a7eeeb93
Remove incorrect `Message` bound on writeAvros
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/26a615e8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/26a615e8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/26a615e8
Branch: refs/heads/master
Commit: 26a615e885b39f92dc81d383c8115906c280187a
Parents: 8c572ef
Author: Andrew Martin <an...@gmail.com>
Authored: Thu May 18 15:52:09 2017 -0400
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Thu May 18 13:52:22 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/26a615e8/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
----------------------------------------------------------------------
diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
index e293b95..4f33d61 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
@@ -527,7 +527,7 @@ public class PubsubIO {
* Returns A {@link PTransform} that writes binary encoded Avro messages of a given type
* to a Google Cloud Pub/Sub stream.
*/
- public static <T extends Message> Write<T> writeAvros(Class<T> clazz) {
+ public static <T> Write<T> writeAvros(Class<T> clazz) {
// TODO: Like in readAvros(), stop using AvroCoder and instead format the payload directly.
return PubsubIO.<T>write().withFormatFn(new FormatPayloadUsingCoder<>(AvroCoder.of(clazz)));
}
@@ -970,8 +970,7 @@ public class PubsubIO {
}
}
- private static class FormatPayloadUsingCoder<T extends Message>
- extends SimpleFunction<T, PubsubMessage> {
+ private static class FormatPayloadUsingCoder<T> extends SimpleFunction<T, PubsubMessage> {
private Coder<T> coder;
public FormatPayloadUsingCoder(Coder<T> coder) {
[2/2] beam git commit: This closes #3176: Remove incorrect `Message`
bound on writeAvros
Posted by jk...@apache.org.
This closes #3176: Remove incorrect `Message` bound on writeAvros
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6a7eeeb9
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6a7eeeb9
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6a7eeeb9
Branch: refs/heads/master
Commit: 6a7eeeb932ffb33c876c0d11d7f325c47606d8de
Parents: 8c572ef 26a615e
Author: Eugene Kirpichov <ki...@google.com>
Authored: Thu May 18 13:52:33 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Thu May 18 13:52:33 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------