You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2022/03/10 17:46:42 UTC
[beam] branch master updated: [BEAM-13923] Fix the answers placeholders locations in the Java katas
This is an automated email from the ASF dual-hosted git repository.
altay 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 eb25730 [BEAM-13923] Fix the answers placeholders locations in the Java katas
new 3a7a213 Merge pull request #16827 from iht/groom_java_katas
eb25730 is described below
commit eb2573076c4afbcb8ed7c5330c318898ca023de1
Author: Israel Herraiz <ih...@google.com>
AuthorDate: Fri Feb 11 17:46:49 2022 +0100
[BEAM-13923] Fix the answers placeholders locations in the Java katas
---
.../Common Transforms/Aggregation/Count/task-info.yaml | 4 ++--
.../java/Common Transforms/Aggregation/Max/task-info.yaml | 4 ++--
.../java/Common Transforms/Aggregation/Mean/task-info.yaml | 4 ++--
.../java/Common Transforms/Aggregation/Min/task-info.yaml | 4 ++--
.../java/Common Transforms/Aggregation/Sum/task-info.yaml | 4 ++--
.../java/Common Transforms/Filter/Filter/task-info.yaml | 4 ++--
.../java/Common Transforms/Filter/ParDo/task-info.yaml | 4 ++--
.../Common Transforms/WithKeys/WithKeys/task-info.yaml | 4 ++--
.../Core Transforms/Branching/Branching/task-info.yaml | 8 ++++----
.../learning/katas/coretransforms/cogroupbykey/Task.java | 9 +++++++++
.../CoGroupByKey/CoGroupByKey/task-info.yaml | 2 +-
.../Combine/BinaryCombineFn Lambda/task-info.yaml | 4 ++--
.../Core Transforms/Combine/BinaryCombineFn/task-info.yaml | 2 +-
.../Core Transforms/Combine/Combine PerKey/task-info.yaml | 6 +++---
.../java/Core Transforms/Combine/CombineFn/task-info.yaml | 2 +-
.../Core Transforms/Combine/Simple Function/task-info.yaml | 2 +-
.../Composite Transform/Composite Transform/task-info.yaml | 4 ++--
.../DoFn Additional Parameters/task-info.yaml | 2 +-
.../DoFn Additional Parameters/task.md | 2 ++
.../java/Core Transforms/Flatten/Flatten/task-info.yaml | 4 ++--
.../Core Transforms/GroupByKey/GroupByKey/task-info.yaml | 4 ++--
.../katas/coretransforms/map/flatmapelements/Task.java | 1 -
.../Core Transforms/Map/FlatMapElements/task-info.yaml | 4 ++--
.../java/Core Transforms/Map/MapElements/task-info.yaml | 4 ++--
.../Core Transforms/Map/ParDo OneToMany/task-info.yaml | 4 ++--
.../katas/java/Core Transforms/Map/ParDo/task-info.yaml | 4 ++--
.../Core Transforms/Partition/Partition/task-info.yaml | 4 ++--
.../beam/learning/katas/coretransforms/sideinput/Task.java | 8 ++++++++
.../Core Transforms/Side Input/Side Input/task-info.yaml | 4 ++--
.../Core Transforms/Side Output/Side Output/task-info.yaml | 4 ++--
.../java/Examples/Word Count/Word Count/task-info.yaml | 4 ++--
.../java/Introduction/Hello Beam/Hello Beam/task-info.yaml | 4 ++--
.../beam/learning/katas/triggers/earlytriggers/Task.java | 8 ++++++++
.../Triggers/Early Triggers/Early Triggers/task-info.yaml | 2 +-
.../learning/katas/triggers/eventtimetriggers/Task.java | 8 ++++++++
.../Event Time Triggers/Event Time Triggers/task-info.yaml | 2 +-
.../beam/learning/katas/triggers/windowaccummode/Task.java | 8 ++++++++
.../Window Accumulation Mode/task-info.yaml | 2 +-
.../katas/windowing/addingtimestamp/pardo/Task.java | 8 ++++++++
.../java/Windowing/Adding Timestamp/ParDo/task-info.yaml | 2 +-
.../windowing/addingtimestamp/withtimestamps/Task.java | 8 ++++++++
.../Adding Timestamp/WithTimestamps/task-info.yaml | 2 +-
.../Fixed Time Window/Fixed Time Window/task-info.yaml | 4 ++--
learning/katas/java/build.gradle | 14 +++++++-------
44 files changed, 127 insertions(+), 69 deletions(-)
diff --git a/learning/katas/java/Common Transforms/Aggregation/Count/task-info.yaml b/learning/katas/java/Common Transforms/Aggregation/Count/task-info.yaml
index 3240233..29b6c27 100644
--- a/learning/katas/java/Common Transforms/Aggregation/Count/task-info.yaml
+++ b/learning/katas/java/Common Transforms/Aggregation/Count/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/aggregation/count/Task.java
visible: true
placeholders:
- - offset: 1707
- length: 29
+ - offset: 1896
+ length: 36
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/aggregation/count/TaskTest.java
visible: false
diff --git a/learning/katas/java/Common Transforms/Aggregation/Max/task-info.yaml b/learning/katas/java/Common Transforms/Aggregation/Max/task-info.yaml
index cd10c1f..86a8087 100644
--- a/learning/katas/java/Common Transforms/Aggregation/Max/task-info.yaml
+++ b/learning/katas/java/Common Transforms/Aggregation/Max/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/aggregation/max/Task.java
visible: true
placeholders:
- - offset: 1709
- length: 35
+ - offset: 1899
+ length: 42
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/aggregation/max/TaskTest.java
visible: false
diff --git a/learning/katas/java/Common Transforms/Aggregation/Mean/task-info.yaml b/learning/katas/java/Common Transforms/Aggregation/Mean/task-info.yaml
index 5bf18f3..198d7f8 100644
--- a/learning/katas/java/Common Transforms/Aggregation/Mean/task-info.yaml
+++ b/learning/katas/java/Common Transforms/Aggregation/Mean/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/aggregation/mean/Task.java
visible: true
placeholders:
- - offset: 1709
- length: 28
+ - offset: 1920
+ length: 35
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/aggregation/mean/TaskTest.java
visible: false
diff --git a/learning/katas/java/Common Transforms/Aggregation/Min/task-info.yaml b/learning/katas/java/Common Transforms/Aggregation/Min/task-info.yaml
index b49a33f..b017772 100644
--- a/learning/katas/java/Common Transforms/Aggregation/Min/task-info.yaml
+++ b/learning/katas/java/Common Transforms/Aggregation/Min/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/aggregation/min/Task.java
visible: true
placeholders:
- - offset: 1709
- length: 35
+ - offset: 1899
+ length: 42
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/aggregation/min/TaskTest.java
visible: false
diff --git a/learning/katas/java/Common Transforms/Aggregation/Sum/task-info.yaml b/learning/katas/java/Common Transforms/Aggregation/Sum/task-info.yaml
index c2427be..760b3f9 100644
--- a/learning/katas/java/Common Transforms/Aggregation/Sum/task-info.yaml
+++ b/learning/katas/java/Common Transforms/Aggregation/Sum/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/aggregation/sum/Task.java
visible: true
placeholders:
- - offset: 1709
- length: 35
+ - offset: 1899
+ length: 42
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/aggregation/sum/TaskTest.java
visible: false
diff --git a/learning/katas/java/Common Transforms/Filter/Filter/task-info.yaml b/learning/katas/java/Common Transforms/Filter/Filter/task-info.yaml
index e8a3893..8e3cba8 100644
--- a/learning/katas/java/Common Transforms/Filter/Filter/task-info.yaml
+++ b/learning/katas/java/Common Transforms/Filter/Filter/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/filter/filter/Task.java
visible: true
placeholders:
- - offset: 1718
- length: 49
+ - offset: 1925
+ length: 56
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/filter/filter/TaskTest.java
visible: false
diff --git a/learning/katas/java/Common Transforms/Filter/ParDo/task-info.yaml b/learning/katas/java/Common Transforms/Filter/ParDo/task-info.yaml
index 530f7ae..3200501 100644
--- a/learning/katas/java/Common Transforms/Filter/ParDo/task-info.yaml
+++ b/learning/katas/java/Common Transforms/Filter/ParDo/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/filter/pardo/Task.java
visible: true
placeholders:
- - offset: 1752
- length: 292
+ - offset: 1983
+ length: 299
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/filter/pardo/TaskTest.java
visible: false
diff --git a/learning/katas/java/Common Transforms/WithKeys/WithKeys/task-info.yaml b/learning/katas/java/Common Transforms/WithKeys/WithKeys/task-info.yaml
index a89b0ad..de95f5e 100644
--- a/learning/katas/java/Common Transforms/WithKeys/WithKeys/task-info.yaml
+++ b/learning/katas/java/Common Transforms/WithKeys/WithKeys/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/commontransforms/withkeys/Task.java
visible: true
placeholders:
- - offset: 1875
- length: 117
+ - offset: 2092
+ length: 124
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/commontransforms/withkeys/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Branching/Branching/task-info.yaml b/learning/katas/java/Core Transforms/Branching/Branching/task-info.yaml
index 9f8b8f8..60eb43e 100644
--- a/learning/katas/java/Core Transforms/Branching/Branching/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Branching/Branching/task-info.yaml
@@ -22,11 +22,11 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/branching/Task.java
visible: true
placeholders:
- - offset: 1994
- length: 78
+ - offset: 2334
+ length: 85
placeholder_text: TODO()
- - offset: 2175
- length: 80
+ - offset: 2515
+ length: 87
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/branching/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/src/org/apache/beam/learning/katas/coretransforms/cogroupbykey/Task.java b/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/src/org/apache/beam/learning/katas/coretransforms/cogroupbykey/Task.java
index 8d3f999..f11eb64 100644
--- a/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/src/org/apache/beam/learning/katas/coretransforms/cogroupbykey/Task.java
+++ b/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/src/org/apache/beam/learning/katas/coretransforms/cogroupbykey/Task.java
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.cogroupbykey;
+// beam-playground:
+// name: GroupByKey
+// description: Task from katas that joins two PCollections.
+// multifile: false
+// context_line: 48
+// categories:
+// - Combiners
+// - Core Transforms
+
import static org.apache.beam.sdk.values.TypeDescriptors.kvs;
import static org.apache.beam.sdk.values.TypeDescriptors.strings;
diff --git a/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/task-info.yaml b/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/task-info.yaml
index 84ee96d..85babe9 100644
--- a/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/task-info.yaml
+++ b/learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/task-info.yaml
@@ -22,7 +22,7 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/cogroupbykey/Task.java
visible: true
placeholders:
- - offset: 2418
+ - offset: 2629
length: 1198
placeholder_text: TODO()
- name: src/org/apache/beam/learning/katas/coretransforms/cogroupbykey/WordsAlphabet.java
diff --git a/learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/task-info.yaml b/learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/task-info.yaml
index 7498a41..3b59813 100644
--- a/learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/Task.java
visible: true
placeholders:
- - offset: 1922
- length: 46
+ - offset: 2164
+ length: 53
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Combine/BinaryCombineFn/task-info.yaml b/learning/katas/java/Core Transforms/Combine/BinaryCombineFn/task-info.yaml
index c63c45a..4e2df04 100644
--- a/learning/katas/java/Core Transforms/Combine/BinaryCombineFn/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Combine/BinaryCombineFn/task-info.yaml
@@ -22,7 +22,7 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn/Task.java
visible: true
placeholders:
- - offset: 2125
+ - offset: 2355
length: 110
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn/TaskTest.java
diff --git a/learning/katas/java/Core Transforms/Combine/Combine PerKey/task-info.yaml b/learning/katas/java/Core Transforms/Combine/Combine PerKey/task-info.yaml
index 6e55b86..d1e8c90 100644
--- a/learning/katas/java/Core Transforms/Combine/Combine PerKey/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Combine/Combine PerKey/task-info.yaml
@@ -22,10 +22,10 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/combine/combineperkey/Task.java
visible: true
placeholders:
- - offset: 2155
- length: 56
+ - offset: 2382
+ length: 63
placeholder_text: TODO()
- - offset: 2295
+ - offset: 2529
length: 98
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/combine/combineperkey/TaskTest.java
diff --git a/learning/katas/java/Core Transforms/Combine/CombineFn/task-info.yaml b/learning/katas/java/Core Transforms/Combine/CombineFn/task-info.yaml
index 12d049a..7aa5ce8 100644
--- a/learning/katas/java/Core Transforms/Combine/CombineFn/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Combine/CombineFn/task-info.yaml
@@ -22,7 +22,7 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/combine/combinefn/Task.java
visible: true
placeholders:
- - offset: 1962
+ - offset: 2154
length: 1173
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/combine/combinefn/TaskTest.java
diff --git a/learning/katas/java/Core Transforms/Combine/Simple Function/task-info.yaml b/learning/katas/java/Core Transforms/Combine/Simple Function/task-info.yaml
index 8ccafb1..d327a4d 100644
--- a/learning/katas/java/Core Transforms/Combine/Simple Function/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Combine/Simple Function/task-info.yaml
@@ -22,7 +22,7 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/combine/simple/Task.java
visible: true
placeholders:
- - offset: 1923
+ - offset: 2154
length: 166
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/combine/simple/TaskTest.java
diff --git a/learning/katas/java/Core Transforms/Composite Transform/Composite Transform/task-info.yaml b/learning/katas/java/Core Transforms/Composite Transform/Composite Transform/task-info.yaml
index 4278037..eea1ac2 100644
--- a/learning/katas/java/Core Transforms/Composite Transform/Composite Transform/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Composite Transform/Composite Transform/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/composite/Task.java
visible: true
placeholders:
- - offset: 1929
- length: 511
+ - offset: 2179
+ length: 630
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/composite/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task-info.yaml b/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task-info.yaml
index c39551e..7802574 100644
--- a/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task-info.yaml
+++ b/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task-info.yaml
@@ -17,7 +17,7 @@
# under the License.
#
-type: edu
+type: theory
files:
- name: src/org/apache/beam/learning/katas/coretransforms/dofnadditionalparams/Task.java
visible: true
diff --git a/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task.md b/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task.md
index 9c324c1..67d9760 100644
--- a/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task.md
+++ b/learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task.md
@@ -36,3 +36,5 @@ process method by adding it as a parameter.
Refer to the Beam Programming Guide
["Accessing additional parameters in your DoFn"](https://beam.apache.org/documentation/programming-guide/#other-dofn-parameters)
section for more information.
+
+This is a theory-only kata, please proceed to the next kata.
diff --git a/learning/katas/java/Core Transforms/Flatten/Flatten/task-info.yaml b/learning/katas/java/Core Transforms/Flatten/Flatten/task-info.yaml
index 81405f5..115485d 100644
--- a/learning/katas/java/Core Transforms/Flatten/Flatten/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Flatten/Flatten/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/flatten/Task.java
visible: true
placeholders:
- - offset: 2040
- length: 77
+ - offset: 2294
+ length: 85
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/flatten/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/GroupByKey/GroupByKey/task-info.yaml b/learning/katas/java/Core Transforms/GroupByKey/GroupByKey/task-info.yaml
index e5d80a9..23318af 100644
--- a/learning/katas/java/Core Transforms/GroupByKey/GroupByKey/task-info.yaml
+++ b/learning/katas/java/Core Transforms/GroupByKey/GroupByKey/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/groupbykey/Task.java
visible: true
placeholders:
- - offset: 2025
- length: 162
+ - offset: 2239
+ length: 169
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/groupbykey/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java b/learning/katas/java/Core Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java
index 2febae9..a22dc7e 100644
--- a/learning/katas/java/Core Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java
+++ b/learning/katas/java/Core Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java
@@ -58,5 +58,4 @@ public class Task {
.via(sentence -> Arrays.asList(sentence.split(" ")))
);
}
-
}
\ No newline at end of file
diff --git a/learning/katas/java/Core Transforms/Map/FlatMapElements/task-info.yaml b/learning/katas/java/Core Transforms/Map/FlatMapElements/task-info.yaml
index 2d21f7d..fc5f480 100644
--- a/learning/katas/java/Core Transforms/Map/FlatMapElements/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Map/FlatMapElements/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java
visible: true
placeholders:
- - offset: 1835
- length: 139
+ - offset: 2057
+ length: 146
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Map/MapElements/task-info.yaml b/learning/katas/java/Core Transforms/Map/MapElements/task-info.yaml
index 6f378dc..231911d 100644
--- a/learning/katas/java/Core Transforms/Map/MapElements/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Map/MapElements/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/map/mapelements/Task.java
visible: true
placeholders:
- - offset: 1776
- length: 110
+ - offset: 2001
+ length: 117
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/map/mapelements/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Map/ParDo OneToMany/task-info.yaml b/learning/katas/java/Core Transforms/Map/ParDo OneToMany/task-info.yaml
index f9edc2b..ac94314 100644
--- a/learning/katas/java/Core Transforms/Map/ParDo OneToMany/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Map/ParDo OneToMany/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/map/pardoonetomany/Task.java
visible: true
placeholders:
- - offset: 1777
- length: 299
+ - offset: 2025
+ length: 306
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/map/pardoonetomany/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Map/ParDo/task-info.yaml b/learning/katas/java/Core Transforms/Map/ParDo/task-info.yaml
index 9c63446..068d55a 100644
--- a/learning/katas/java/Core Transforms/Map/ParDo/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Map/ParDo/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/map/pardo/Task.java
visible: true
placeholders:
- - offset: 1752
- length: 213
+ - offset: 1959
+ length: 220
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/map/pardo/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Partition/Partition/task-info.yaml b/learning/katas/java/Core Transforms/Partition/Partition/task-info.yaml
index 6537f92..b9068ff 100644
--- a/learning/katas/java/Core Transforms/Partition/Partition/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Partition/Partition/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/partition/Task.java
visible: true
placeholders:
- - offset: 1966
- length: 241
+ - offset: 2330
+ length: 249
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/partition/TaskTest.java
visible: false
diff --git a/learning/katas/java/Core Transforms/Side Input/Side Input/src/org/apache/beam/learning/katas/coretransforms/sideinput/Task.java b/learning/katas/java/Core Transforms/Side Input/Side Input/src/org/apache/beam/learning/katas/coretransforms/sideinput/Task.java
index faa2943..f2160ff 100644
--- a/learning/katas/java/Core Transforms/Side Input/Side Input/src/org/apache/beam/learning/katas/coretransforms/sideinput/Task.java
+++ b/learning/katas/java/Core Transforms/Side Input/Side Input/src/org/apache/beam/learning/katas/coretransforms/sideinput/Task.java
@@ -18,6 +18,14 @@
package org.apache.beam.learning.katas.coretransforms.sideinput;
+// beam-playground:
+// name: SideInput
+// description: Task from katas to enrich each Person with the country based on the city he/she lives in.
+// multifile: false
+// context_line: 38
+// categories:
+// - Side Input
+
import java.util.Map;
import org.apache.beam.learning.katas.util.Log;
import org.apache.beam.sdk.Pipeline;
diff --git a/learning/katas/java/Core Transforms/Side Input/Side Input/task-info.yaml b/learning/katas/java/Core Transforms/Side Input/Side Input/task-info.yaml
index 1568f8c..16e6a00 100644
--- a/learning/katas/java/Core Transforms/Side Input/Side Input/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Side Input/Side Input/task-info.yaml
@@ -22,10 +22,10 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/sideinput/Task.java
visible: true
placeholders:
- - offset: 2716
+ - offset: 2953
length: 37
placeholder_text: TODO()
- - offset: 2914
+ - offset: 3151
length: 500
placeholder_text: TODO()
- name: src/org/apache/beam/learning/katas/coretransforms/sideinput/Person.java
diff --git a/learning/katas/java/Core Transforms/Side Output/Side Output/task-info.yaml b/learning/katas/java/Core Transforms/Side Output/Side Output/task-info.yaml
index bd51850..2ea2004 100644
--- a/learning/katas/java/Core Transforms/Side Output/Side Output/task-info.yaml
+++ b/learning/katas/java/Core Transforms/Side Output/Side Output/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/coretransforms/sideoutput/Task.java
visible: true
placeholders:
- - offset: 2253
- length: 398
+ - offset: 2528
+ length: 406
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/coretransforms/sideoutput/TaskTest.java
visible: false
diff --git a/learning/katas/java/Examples/Word Count/Word Count/task-info.yaml b/learning/katas/java/Examples/Word Count/Word Count/task-info.yaml
index 198ff72..129994a 100644
--- a/learning/katas/java/Examples/Word Count/Word Count/task-info.yaml
+++ b/learning/katas/java/Examples/Word Count/Word Count/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/examples/wordcount/Task.java
visible: true
placeholders:
- - offset: 2075
- length: 466
+ - offset: 2277
+ length: 474
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/examples/wordcount/TaskTest.java
visible: false
diff --git a/learning/katas/java/Introduction/Hello Beam/Hello Beam/task-info.yaml b/learning/katas/java/Introduction/Hello Beam/Hello Beam/task-info.yaml
index 743146c..8b69ed2 100644
--- a/learning/katas/java/Introduction/Hello Beam/Hello Beam/task-info.yaml
+++ b/learning/katas/java/Introduction/Hello Beam/Hello Beam/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/intro/hello/Task.java
visible: true
placeholders:
- - offset: 1552
- length: 39
+ - offset: 1799
+ length: 46
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/intro/hello/TaskTest.java
visible: false
diff --git a/learning/katas/java/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.java b/learning/katas/java/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.java
index fb4a3bc..813392d 100644
--- a/learning/katas/java/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.java
+++ b/learning/katas/java/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.java
@@ -18,6 +18,14 @@
package org.apache.beam.learning.katas.triggers.earlytriggers;
+// beam-playground:
+// name: EarlyTriggers
+// description: Task from katas to count events using early triggers
+// multifile: true
+// context_line: 42
+// categories:
+// - Streaming
+
import org.apache.beam.learning.katas.util.Log;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.options.PipelineOptions;
diff --git a/learning/katas/java/Triggers/Early Triggers/Early Triggers/task-info.yaml b/learning/katas/java/Triggers/Early Triggers/Early Triggers/task-info.yaml
index e22c28c..3b0a8b9 100644
--- a/learning/katas/java/Triggers/Early Triggers/Early Triggers/task-info.yaml
+++ b/learning/katas/java/Triggers/Early Triggers/Early Triggers/task-info.yaml
@@ -24,7 +24,7 @@ files:
- name: src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.java
visible: true
placeholders:
- - offset: 1970
+ - offset: 2166
length: 461
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/triggers/earlytriggers/TaskTest.java
diff --git a/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.java b/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.java
index d7a45af..faf6cdb 100644
--- a/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.java
+++ b/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.java
@@ -18,6 +18,14 @@
package org.apache.beam.learning.katas.triggers.eventtimetriggers;
+// beam-playground:
+// name: EventTimeTriggers
+// description: Task from katas to count events with event time triggers
+// multifile: true
+// context_line: 42
+// categories:
+// - Streaming
+
import org.apache.beam.learning.katas.util.Log;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.options.PipelineOptions;
diff --git a/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/task-info.yaml b/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/task-info.yaml
index c66ccc3..e8cc60c 100644
--- a/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/task-info.yaml
+++ b/learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/task-info.yaml
@@ -22,7 +22,7 @@ files:
- name: src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.java
visible: true
placeholders:
- - offset: 1905
+ - offset: 2109
length: 334
placeholder_text: TODO()
- name: src/org/apache/beam/learning/katas/triggers/eventtimetriggers/GenerateEvent.java
diff --git a/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.java b/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.java
index 5452e2a..cef086d 100644
--- a/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.java
+++ b/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.java
@@ -18,6 +18,14 @@
package org.apache.beam.learning.katas.triggers.windowaccummode;
+// beam-playground:
+// name: WindowAccumulationMode
+// description: Task from katas to count events using ACCUMULATING as accumulation mode
+// multifile: true
+// context_line: 42
+// categories:
+// - Streaming
+
import org.apache.beam.learning.katas.util.Log;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.options.PipelineOptions;
diff --git a/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/task-info.yaml b/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/task-info.yaml
index 73124eb..00af74b 100644
--- a/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/task-info.yaml
+++ b/learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/task-info.yaml
@@ -24,7 +24,7 @@ files:
- name: src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.java
visible: true
placeholders:
- - offset: 1972
+ - offset: 2196
length: 471
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/triggers/windowaccummode/TaskTest.java
diff --git a/learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java b/learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java
index dc1742e..0b9f3de 100644
--- a/learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java
+++ b/learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java
@@ -18,6 +18,14 @@
package org.apache.beam.learning.katas.windowing.addingtimestamp.pardo;
+// beam-playground:
+// name: WindowingAddTimestamp
+// description: Task from katas to assign each element a timestamp based on the `Event.timestamp`.
+// multifile: true
+// context_line: 39
+// categories:
+// - Streaming
+
import org.apache.beam.learning.katas.util.Log;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.options.PipelineOptions;
diff --git a/learning/katas/java/Windowing/Adding Timestamp/ParDo/task-info.yaml b/learning/katas/java/Windowing/Adding Timestamp/ParDo/task-info.yaml
index b31d737..88e650e 100644
--- a/learning/katas/java/Windowing/Adding Timestamp/ParDo/task-info.yaml
+++ b/learning/katas/java/Windowing/Adding Timestamp/ParDo/task-info.yaml
@@ -24,7 +24,7 @@ files:
- name: src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java
visible: true
placeholders:
- - offset: 2249
+ - offset: 2483
length: 241
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/TaskTest.java
diff --git a/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java b/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java
index f82b1eb..b10bbb1 100644
--- a/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java
+++ b/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java
@@ -18,6 +18,14 @@
package org.apache.beam.learning.katas.windowing.addingtimestamp.withtimestamps;
+// beam-playground:
+// name: WithTimestamps
+// description: Task from katas to assign each element a timestamp using `WithTimestamps`.
+// multifile: true
+// context_line: 38
+// categories:
+// - Streaming
+
import org.apache.beam.learning.katas.util.Log;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.options.PipelineOptions;
diff --git a/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/task-info.yaml b/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/task-info.yaml
index a5933ec..611715f 100644
--- a/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/task-info.yaml
+++ b/learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/task-info.yaml
@@ -24,7 +24,7 @@ files:
- name: src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java
visible: true
placeholders:
- - offset: 2223
+ - offset: 2442
length: 69
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/TaskTest.java
diff --git a/learning/katas/java/Windowing/Fixed Time Window/Fixed Time Window/task-info.yaml b/learning/katas/java/Windowing/Fixed Time Window/Fixed Time Window/task-info.yaml
index 546807c..fa9b51e 100644
--- a/learning/katas/java/Windowing/Fixed Time Window/Fixed Time Window/task-info.yaml
+++ b/learning/katas/java/Windowing/Fixed Time Window/Fixed Time Window/task-info.yaml
@@ -22,8 +22,8 @@ files:
- name: src/org/apache/beam/learning/katas/windowing/fixedwindow/Task.java
visible: true
placeholders:
- - offset: 2906
- length: 112
+ - offset: 3167
+ length: 119
placeholder_text: TODO()
- name: test/org/apache/beam/learning/katas/windowing/fixedwindow/TaskTest.java
visible: false
diff --git a/learning/katas/java/build.gradle b/learning/katas/java/build.gradle
index 438c0e0..704cb3c 100644
--- a/learning/katas/java/build.gradle
+++ b/learning/katas/java/build.gradle
@@ -18,15 +18,15 @@
buildscript {
ext {
- beamVersion = '2.19.0'
- guavaVersion = '28.1-jre'
- jodaTimeVersion = '2.10.4'
- slf4jVersion = '1.7.28'
- log4jSlf4jImpl = '2.12.1'
+ beamVersion = '2.36.0'
+ guavaVersion = '31.0.1-jre'
+ jodaTimeVersion = '2.10.10'
+ slf4jVersion = '1.7.30'
+ log4jSlf4jImpl = '2.17.1'
- assertjVersion = '3.13.2'
+ assertjVersion = '3.22.0'
hamcrestVersion = '2.1'
- junitVersion = '4.12'
+ junitVersion = '4.13.1'
}
repositories {