This is an automated email from the ASF dual-hosted git repository. wonook pushed a commit to branch release-0.4-prep in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git
commit af334de3f20df2fca8ebe93ac585a5f87332187b Author: Won Wook SONG <wsong0...@gmail.com> AuthorDate: Thu Sep 1 12:42:46 2022 +0900 javadoc --- .../nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java | 1 + .../org/apache/nemo/common/ir/vertex/transform/StreamTransform.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java b/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java index eaa60b2ba..5ae96958e 100644 --- a/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java +++ b/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java @@ -41,6 +41,7 @@ public abstract class LatencymarkEmitTransform<I, O> implements Transform<I, O> /** * get OutputCollector. + * @return the output collector. */ public OutputCollector<O> getOutputCollector() { return outputCollector; diff --git a/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java b/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java index e812a9dcf..97e7c095a 100644 --- a/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java +++ b/common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java @@ -24,7 +24,7 @@ import org.slf4j.LoggerFactory; /** * A {@link Transform} relays input data from upstream vertex to downstream vertex promptly. - * This transform can be used for merging input data into the {@link OutputCollector}. + * This transform can be used for merging input data into the {@link org.apache.nemo.common.ir.OutputCollector}. * * @param <T> input/output type. */