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 <[email protected]> Authored: Thu May 11 10:27:41 2017 +0100 Committer: Borisa Zivkovic <[email protected]> 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
