Repository: beam Updated Branches: refs/heads/release-2.0.0 8f1834432 -> 5493c6c8f
This closes #2950 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8f14c18d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8f14c18d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8f14c18d Branch: refs/heads/release-2.0.0 Commit: 8f14c18d21439754071711c93c32ba757b0a0776 Parents: 8f18344 Author: Eugene Kirpichov <[email protected]> Authored: Mon May 8 13:45:25 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Mon May 8 16:19:28 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/8f14c18d/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 ac6cb44..048fded 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 @@ -435,7 +435,7 @@ public class PubsubIO { * messages will only contain a {@link PubsubMessage#getPayload() payload}, but no {@link * PubsubMessage#getAttributeMap() attributes}. */ - public static Read<PubsubMessage> readPubsubMessagesWithoutAttributes() { + public static Read<PubsubMessage> readMessages() { return new AutoValue_PubsubIO_Read.Builder<PubsubMessage>() .setCoder(PubsubMessagePayloadOnlyCoder.of()) .setParseFn(new IdentityMessageFn()) @@ -448,7 +448,7 @@ public class PubsubIO { * messages will contain both a {@link PubsubMessage#getPayload() payload} and {@link * PubsubMessage#getAttributeMap() attributes}. */ - public static Read<PubsubMessage> readPubsubMessagesWithAttributes() { + public static Read<PubsubMessage> readMessagesWithAttributes() { return new AutoValue_PubsubIO_Read.Builder<PubsubMessage>() .setCoder(PubsubMessageWithAttributesCoder.of()) .setParseFn(new IdentityMessageFn()) @@ -495,7 +495,7 @@ public class PubsubIO { } /** Returns A {@link PTransform} that writes to a Google Cloud Pub/Sub stream. */ - public static Write<PubsubMessage> writePubsubMessages() { + public static Write<PubsubMessage> writeMessages() { return PubsubIO.<PubsubMessage>write().withFormatFn(new IdentityMessageFn()); }
