You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2016/12/07 16:51:21 UTC
[2/2] incubator-beam git commit: Port most of DoFnRunner Javadoc to
new DoFn
Port most of DoFnRunner Javadoc to new DoFn
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b2d72237
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b2d72237
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b2d72237
Branch: refs/heads/master
Commit: b2d72237b592e1dcb5cca30f5cbc9a11d2890c0f
Parents: 02bb8c3
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Dec 6 15:20:28 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Wed Dec 7 08:51:02 2016 -0800
----------------------------------------------------------------------
.../java/org/apache/beam/runners/core/DoFnRunner.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b2d72237/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java
----------------------------------------------------------------------
diff --git a/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java b/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java
index aac8e8f..501667e 100644
--- a/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java
+++ b/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java
@@ -18,29 +18,29 @@
package org.apache.beam.runners.core;
import org.apache.beam.sdk.transforms.Aggregator;
+import org.apache.beam.sdk.transforms.DoFn;
import org.apache.beam.sdk.transforms.OldDoFn;
-import org.apache.beam.sdk.transforms.OldDoFn.ProcessContext;
import org.apache.beam.sdk.util.WindowedValue;
import org.apache.beam.sdk.values.KV;
/**
- * An wrapper interface that represents the execution of a {@link OldDoFn}.
+ * An wrapper interface that represents the execution of a {@link DoFn}.
*/
public interface DoFnRunner<InputT, OutputT> {
/**
- * Prepares and calls {@link OldDoFn#startBundle}.
+ * Prepares and calls a {@link DoFn DoFn's} {@link DoFn.StartBundle @StartBundle} method.
*/
void startBundle();
/**
- * Calls {@link OldDoFn#processElement} with a {@link ProcessContext} containing the current
- * element.
+ * Calls a {@link DoFn DoFn's} {@link DoFn.ProcessElement @ProcessElement} method with a
+ * {@link DoFn.ProcessContext} containing the provided element.
*/
void processElement(WindowedValue<InputT> elem);
/**
- * Calls {@link OldDoFn#finishBundle} and performs additional tasks, such as
- * flushing in-memory states.
+ * Calls a {@link DoFn DoFn's} {@link DoFn.FinishBundle @FinishBundle} method and performs
+ * additional tasks, such as flushing in-memory states.
*/
void finishBundle();