From 65a297182e3eeb33426ea3e9d9d48030509e3a5c Mon Sep 17 00:00:00 2001 From: Andrew Martin Date: Thu, 18 May 2017 15:52:09 -0400 Subject: [PATCH] Remove incorrect `Message` bound on writeAvros --- .../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 e293b95ede1e..117bd6d93785 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 static Write writeProtos(Class messageClass) { * Returns A {@link PTransform} that writes binary encoded Avro messages of a given type * to a Google Cloud Pub/Sub stream. */ - public static Write writeAvros(Class clazz) { + public static Write writeAvros(Class clazz) { // TODO: Like in readAvros(), stop using AvroCoder and instead format the payload directly. return PubsubIO.write().withFormatFn(new FormatPayloadUsingCoder<>(AvroCoder.of(clazz))); }