You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/05/11 15:13:37 UTC
[1/2] beam git commit: Add support for local execution to PubsubIO
using the google cloud emulator
Repository: beam
Updated Branches:
refs/heads/master 15bd3a394 -> ea8116c32
Add support for local execution to PubsubIO using the google cloud emulator
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/86486e27
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/86486e27
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/86486e27
Branch: refs/heads/master
Commit: 86486e279e952011865769c6e53cf348e52914c0
Parents: 15bd3a3
Author: Borisa Zivkovic <bo...@huawei.com>
Authored: Thu May 11 10:27:41 2017 +0100
Committer: Borisa Zivkovic <bo...@huawei.com>
Committed: Thu May 11 10:27:41 2017 +0100
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/86486e27/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 048fded..bdc2752e 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
@@ -65,6 +65,12 @@ import org.slf4j.LoggerFactory;
* Read and Write {@link PTransform}s for Cloud Pub/Sub streams. These transforms create
* and consume unbounded {@link PCollection PCollections}.
*
+ * <h3>Using local emulator</h3>
+ *
+ * <p>In order to use local emulator for Pubsub you should use
+ * {@code PubsubOptions#setPubsubRootUrl(String)} method to set host and port of your
+ * local emulator.
+ *
* <h3>Permissions</h3>
*
* <p>Permission requirements depend on the {@link PipelineRunner} that is used to execute the
[2/2] beam git commit: This closes #3079
Posted by dh...@apache.org.
This closes #3079
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ea8116c3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ea8116c3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ea8116c3
Branch: refs/heads/master
Commit: ea8116c32c5c7d85b20d39fc03657d2090b72ed7
Parents: 15bd3a3 86486e2
Author: Dan Halperin <dh...@google.com>
Authored: Thu May 11 08:13:30 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu May 11 08:13:30 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------