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",