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 <[email protected]> Authored: Thu May 18 15:52:09 2017 -0400 Committer: Eugene Kirpichov <[email protected]> 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) {
