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/02/07 18:32:55 UTC
[beam] branch master updated: OutputReceiver is not an annotation
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 e99a096 OutputReceiver is not an annotation
new 9b27a6c Merge pull request #7755: [BEAM-6615] OutputReceiver is not an annotation
e99a096 is described below
commit e99a09649481dbf8a5114ecef3b3b9bb9aef56d5
Author: Brian Hulette <bh...@google.com>
AuthorDate: Wed Feb 6 10:52:12 2019 -0800
OutputReceiver is not an annotation
---
.../java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java
index 3e86c79..e7ef933 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java
@@ -125,7 +125,7 @@ import org.apache.beam.vendor.guava.v20_0.com.google.common.collect.ImmutableLis
* lines.apply(ParDo.of(new DoFn<String, String>() {
* {@literal @}ProcessElement
* public void processElement({@literal @}Element String line,
- * {@literal @}OutputReceiver<String> r) {
+ * OutputReceiver<String> r) {
* for (String word : line.split("[^a-zA-Z']+")) {
* r.output(word);
* }
@@ -134,7 +134,7 @@ import org.apache.beam.vendor.guava.v20_0.com.google.common.collect.ImmutableLis
* words.apply(ParDo.of(new DoFn<String, Integer>() {
* {@literal @}ProcessElement
* public void processElement({@literal @}Element String word,
- * {@literal @}OutputReceiver<Integer> r) {
+ * OutputReceiver<Integer> r) {
* Integer length = word.length();
* r.output(length);
* }}));