beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/3] beam git commit: Add support for local execution to PubsubIO using the google cloud emulator
Date Thu, 11 May 2017 19:50:57 GMT
Repository: beam
Updated Branches:
  refs/heads/release-2.0.0 c839c1321 -> e8e8a6e87


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/51272750
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/51272750
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/51272750

Branch: refs/heads/release-2.0.0
Commit: 5127275037cfb864f25fa86de640e66904ee63f9
Parents: 2237697
Author: Borisa Zivkovic <borisa.zivkovic@huawei.com>
Authored: Thu May 11 10:27:41 2017 +0100
Committer: Dan Halperin <dhalperi@google.com>
Committed: Thu May 11 12:50:47 2017 -0700

----------------------------------------------------------------------
 .../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/51272750/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


Mime
View raw message