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/08 20:48:39 UTC
[1/2] beam git commit: Shortens PubsubIO names for reading/writing
messages.
Repository: beam
Updated Branches:
refs/heads/master c481396ed -> d1914ed0c
Shortens PubsubIO names for reading/writing messages.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1fd15bd7
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1fd15bd7
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1fd15bd7
Branch: refs/heads/master
Commit: 1fd15bd7441e1be72feb3f9535ffe536d730a531
Parents: c481396
Author: Reuven Lax <re...@google.com>
Authored: Sun May 7 11:50:08 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Mon May 8 13:44:51 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/1fd15bd7/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());
}
[2/2] beam git commit: This closes #2950
Posted by jk...@apache.org.
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/d1914ed0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d1914ed0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d1914ed0
Branch: refs/heads/master
Commit: d1914ed0c3195e1de2f707e2bb7bc57597b834fe
Parents: c481396 1fd15bd
Author: Eugene Kirpichov <ki...@google.com>
Authored: Mon May 8 13:45:25 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Mon May 8 13:45:25 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------