You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by sc...@apache.org on 2019/01/24 19:08:35 UTC
[beam] branch master updated: Add missing javadocs for new public
methods
This is an automated email from the ASF dual-hosted git repository.
scott pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 4fedc75 Add missing javadocs for new public methods
new 98952d2 Merge pull request #7618: [BEAM-6500] Add missing javadocs for new public methods
4fedc75 is described below
commit 4fedc75194e24d9b89b8d6326143136a25126b91
Author: Scott Wegner <sc...@apache.org>
AuthorDate: Thu Jan 24 10:30:53 2019 -0800
Add missing javadocs for new public methods
---
.../java/org/apache/beam/runners/direct/portable/ReferenceRunner.java | 1 +
.../beam/runners/direct/portable/job/ReferenceRunnerJobServer.java | 1 +
2 files changed, 2 insertions(+)
diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/ReferenceRunner.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/ReferenceRunner.java
index 5458a21..07212a3 100644
--- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/ReferenceRunner.java
+++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/ReferenceRunner.java
@@ -161,6 +161,7 @@ public class ReferenceRunner {
return res;
}
+ /** Configures and starts the {@link ExecutorServiceParallelExecutor}. */
public void execute() throws Exception {
ExecutableGraph<PTransformNode, PCollectionNode> graph = PortableGraph.forPipeline(pipeline);
BundleFactory bundleFactory = ImmutableListBundleFactory.create();
diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/job/ReferenceRunnerJobServer.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/job/ReferenceRunnerJobServer.java
index 31d84e8..e2eac87 100644
--- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/job/ReferenceRunnerJobServer.java
+++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/portable/job/ReferenceRunnerJobServer.java
@@ -144,6 +144,7 @@ public class ReferenceRunnerJobServer {
return jobServiceConfig;
}
+ /** Command-line options to configure the JobServer. */
public static class ServerConfiguration {
@Option(
name = "-p",