ilya-kozyrev commented on a change in pull request #16192:
URL: https://github.com/apache/beam/pull/16192#discussion_r768652603
##########
File path: learning/katas/java/Common
Transforms/Aggregation/Max/src/org/apache/beam/learning/katas/commontransforms/aggregation/max/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.aggregation.max;
+// beam-playground:
+// name: AggregationMax
+// description: Task from katas to compute the maximum of elements.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/java/Common
Transforms/Aggregation/Count/src/org/apache/beam/learning/katas/commontransforms/aggregation/count/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.aggregation.count;
+// beam-playground:
+// name: AggregationCount
+// description: Task from katas to count the number of elements.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/java/Common
Transforms/Filter/ParDo/src/org/apache/beam/learning/katas/commontransforms/filter/pardo/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.filter.pardo;
+// beam-playground:
+// name: FilterParDo
+// description: Task from katas to implement a filter function that filters
out the even numbers by using DoFn.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
Review comment:
```suggestion
// - Filtering
```
##########
File path: learning/katas/java/Common
Transforms/Filter/ParDo/src/org/apache/beam/learning/katas/commontransforms/filter/pardo/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.filter.pardo;
+// beam-playground:
+// name: FilterParDo
+// description: Task from katas to implement a filter function that filters
out the even numbers by using DoFn.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/java/Core
Transforms/Map/MapElements/src/org/apache/beam/learning/katas/coretransforms/map/mapelements/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.map.mapelements;
+// beam-playground:
+// name: Map
+// description: Task from katas to implement a simple map function that
multiplies all input elements by 5.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/java/Core
Transforms/Map/ParDo/src/org/apache/beam/learning/katas/coretransforms/map/pardo/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.map.pardo;
+// beam-playground:
+// name: MapPardo
+// description: Task from katas that maps the input element by multiplying
it by 10.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/python/Core Transforms/Composite Transform/Composite
Transform/task.py
##########
@@ -14,6 +14,16 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: CompositeTransform
+# description: Task from katas to implement a composite transform
"ExtractAndMultiplyNumbers"
+# that extracts numbers from comma separated line and then multiplies each
number by 10.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Flatten
```
##########
File path: learning/katas/python/Core Transforms/Map/FlatMap/task.py
##########
@@ -14,6 +14,16 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: FlatMap
+# description: Task from katas to implement a function that maps each input
sentence
+# into words split by whitespace (" ").
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Core Transforms
# - Flatten
```
##########
File path: learning/katas/java/Common
Transforms/Aggregation/Mean/src/org/apache/beam/learning/katas/commontransforms/aggregation/mean/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.aggregation.mean;
+// beam-playground:
+// name: AggregationMean
+// description: Task from katas to count mean value of the given pipeline
with numbers.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/python/Core Transforms/Flatten/Flatten/task.py
##########
@@ -14,6 +14,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: Flatten
+# description: Task from katas that merges two PCollections of words into a
single PCollection.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Flatten
```
##########
File path: learning/katas/java/Common
Transforms/Filter/Filter/src/org/apache/beam/learning/katas/commontransforms/filter/filter/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.filter.filter;
+// beam-playground:
+// name: Filter
+// description: Task from katas to implement a filter function that filters
out odd numbers.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
Review comment:
```suggestion
// - Filtering
```
##########
File path: learning/katas/java/Common
Transforms/Aggregation/Sum/src/org/apache/beam/learning/katas/commontransforms/aggregation/sum/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.aggregation.sum;
+// beam-playground:
+// name: AggregationSum
+// description: Task from katas to compute the sum of all elements.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: playground/categories.yaml
##########
@@ -30,3 +30,4 @@ categories:
- Options
- Coders
- Stateful Processing
+ - Beam SQL
Review comment:
```suggestion
- Beam SQL
- Filtering
- Branching
- Flatten
- Core Transforms
```
##########
File path: learning/katas/java/Common
Transforms/WithKeys/WithKeys/src/org/apache/beam/learning/katas/commontransforms/withkeys/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.withkeys;
+// beam-playground:
+// name: WithKeys
+// description: Task from katas to convert each fruit name into a KV of its
first letter and itself.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/java/Core Transforms/Combine/BinaryCombineFn
Lambda/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/Task.java
##########
@@ -18,6 +18,15 @@
package
org.apache.beam.learning.katas.coretransforms.combine.binarycombinefnlambda;
+// beam-playground:
+// name: BinaryCombineFnLambda
+// description: Task from katas to implement the summation of BigIntegers
using lambda.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/java/Common
Transforms/Aggregation/Min/src/org/apache/beam/learning/katas/commontransforms/aggregation/min/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.aggregation.min;
+// beam-playground:
+// name: AggregationMin
+// description: Task from katas to compute the minimum of elements.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/java/Core
Transforms/Combine/BinaryCombineFn/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.combine.binarycombinefn;
+// beam-playground:
+// name: BinaryCombineFn
+// description: Task from katas to implement the summation of BigIntegers.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/java/Common
Transforms/Filter/Filter/src/org/apache/beam/learning/katas/commontransforms/filter/filter/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.commontransforms.filter.filter;
+// beam-playground:
+// name: Filter
+// description: Task from katas to implement a filter function that filters
out odd numbers.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/java/Core
Transforms/Branching/Branching/src/org/apache/beam/learning/katas/coretransforms/branching/Task.java
##########
@@ -18,6 +18,16 @@
package org.apache.beam.learning.katas.coretransforms.branching;
+// beam-playground:
+// name: Branching
+// description: Task from katas to branch out the numbers to two different
transforms, one transform
+// is multiplying each number by 5 and the other transform is multiplying
each number by 10.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Branching
// - Core Transforms
```
##########
File path: learning/katas/java/Core
Transforms/Combine/CombineFn/src/org/apache/beam/learning/katas/coretransforms/combine/combinefn/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.combine.combinefn;
+// beam-playground:
+// name: CombineFn
+// description: Task from katas averaging.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/java/Core Transforms/Combine/Simple
Function/src/org/apache/beam/learning/katas/coretransforms/combine/simple/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.combine.simple;
+// beam-playground:
+// name: FilterSimpleFunction
+// description: Task from katas to implement the summation of numbers.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/java/Core Transforms/Combine/Combine
PerKey/src/org/apache/beam/learning/katas/coretransforms/combine/combineperkey/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.combine.combineperkey;
+// beam-playground:
+// name: CombinePerKey
+// description: Task from katas to implement the summation of scores per
player.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/java/Core Transforms/Composite Transform/Composite
Transform/src/org/apache/beam/learning/katas/coretransforms/composite/Task.java
##########
@@ -18,6 +18,16 @@
package org.apache.beam.learning.katas.coretransforms.composite;
+// beam-playground:
+// name: CompositeTransform
+// description: Task from katas to implement a composite transform
"ExtractAndMultiplyNumbers"
+// that extracts numbers from comma separated line and then multiplies
each number by 10.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Flatten
// - Core Transforms
```
##########
File path: learning/katas/java/Core
Transforms/GroupByKey/GroupByKey/src/org/apache/beam/learning/katas/coretransforms/groupbykey/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.groupbykey;
+// beam-playground:
+// name: GroupByKey
+// description: Task from katas that groups words by its first letter.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/java/Core
Transforms/Flatten/Flatten/src/org/apache/beam/learning/katas/coretransforms/flatten/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.flatten;
+// beam-playground:
+// name: Flatten
+// description: Task from katas that merges two PCollections of words into a
single PCollection.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Flatten
// - Core Transforms
```
##########
File path: learning/katas/java/Core
Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java
##########
@@ -18,6 +18,16 @@
package org.apache.beam.learning.katas.coretransforms.map.flatmapelements;
+// eam-playground:
+// name: FlatMap
+// description: Task from katas to implement a function that maps each input
sentence
+// into words split by whitespace (" ").
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
Review comment:
```suggestion
// - Flatten
```
##########
File path: learning/katas/java/Core Transforms/Map/ParDo
OneToMany/src/org/apache/beam/learning/katas/coretransforms/map/pardoonetomany/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.coretransforms.map.pardoonetomany;
+// beam-playground:
+// name: MapParDoOneToMany
+// description: Task from katas that maps each input sentence into words
split by whitespace (" ").
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Flatten
// - Core Transforms
```
##########
File path: learning/katas/java/Examples/Word Count/Word
Count/src/org/apache/beam/learning/katas/examples/wordcount/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.examples.wordcount;
+// beam-playground:
+// name: WordCount
+// description: Task from katas to create a pipeline that counts the number
of words.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
```
##########
File path: learning/katas/java/Core
Transforms/Partition/Partition/src/org/apache/beam/learning/katas/coretransforms/partition/Task.java
##########
@@ -18,6 +18,16 @@
package org.apache.beam.learning.katas.coretransforms.partition;
+// beam-playground:
+// name: Partition
+// description: Task from katas that splits a PCollection of numbers into
two PCollections. The first PCollection
+// contains numbers greater than 100, and the second PCollection contains
the remaining numbers.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
// - Multiple Outputs
```
##########
File path: learning/katas/java/Core Transforms/Side Output/Side
Output/src/org/apache/beam/learning/katas/coretransforms/sideoutput/Task.java
##########
@@ -18,6 +18,16 @@
package org.apache.beam.learning.katas.coretransforms.sideoutput;
+// beam-playground:
+// name: SideOutput
+// description: Task from katas to implement additional output to your ParDo
for numbers bigger than 100.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Core Transforms
```
##########
File path: learning/katas/python/Core Transforms/Branching/Branching/task.py
##########
@@ -14,6 +14,16 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: Branching
+# description: Task from katas to branch out the numbers to two different
transforms, one transform
+# is multiplying each number by 5 and the other transform is multiplying
each number by 10.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Branching
# - Multiple Outputs
```
##########
File path: learning/katas/java/Windowing/Fixed Time Window/Fixed Time
Window/src/org/apache/beam/learning/katas/windowing/fixedwindow/Task.java
##########
@@ -18,6 +18,15 @@
package org.apache.beam.learning.katas.windowing.fixedwindow;
+// beam-playground:
+// name: FixedTimeWindow
+// description: Task from katas to count the number of events that happened
based on fixed window with 1-day duration.
+// multifile: false
+// pipeline_options:
+// categories:
+// - Combiners
+// - Testing
Review comment:
```suggestion
// - Streaming
```
##########
File path: learning/katas/python/Common Transforms/Filter/ParDo/task.py
##########
@@ -14,6 +14,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: FilterParDo
+# description: Task from katas to implement a filter function that filters
out the even numbers.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Filtering
```
##########
File path: learning/katas/python/Core Transforms/Map/Map/task.py
##########
@@ -14,6 +14,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: Map
+# description: Task from katas to implement a simple map function that
multiplies all input elements by 5.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Core Transforms
```
##########
File path: learning/katas/python/Core Transforms/Map/ParDo OneToMany/task.py
##########
@@ -14,6 +14,16 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: MapParDoOneToMany
+# description: Task from katas is a ParDo that maps each input sentence into
+# words splitter by whitespace (" ").
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Core Transforms
# - Flatten
```
##########
File path: learning/katas/python/Common Transforms/Filter/Filter/task.py
##########
@@ -14,6 +14,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: Filter
+# description: Task from katas to implement a filter function that filters
out odd numbers.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Filtering
```
##########
File path: learning/katas/python/Core Transforms/Partition/Partition/task.py
##########
@@ -14,6 +14,16 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: Partition
+# description: Task from katas that splits a PCollection of numbers into two
PCollections. The first PCollection
+# contains numbers greater than 100, and the second PCollection contains
the remaining numbers.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Multiple Outputs
```
##########
File path: learning/katas/python/Core Transforms/Map/ParDo/task.py
##########
@@ -14,6 +14,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: MapPardo
+# description: Task from katas is simple ParDo that maps the input element
by multiplying it by 10.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Core Transforms
```
##########
File path: learning/katas/python/Core Transforms/Side Input/Side Input/task.py
##########
@@ -22,6 +22,16 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# 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
+# pipeline_options:
+# categories:
+# - Side Input
+# - Combiners
Review comment:
```suggestion
```
##########
File path: learning/katas/python/Core Transforms/Side Output/Side Output/task.py
##########
@@ -14,6 +14,16 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: SideOutput
+# description: Task from katas to implement additional output to your ParDo
for numbers bigger than 100.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Filtering
```
##########
File path: learning/katas/python/Windowing/Adding Timestamp/ParDo/task.py
##########
@@ -14,6 +14,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: WindowingParDo
+# description: Task from katas to assign each element a timestamp based on
the the `Event.timestamp`.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Streaming
```
##########
File path: learning/katas/python/Windowing/Fixed Time Window/Fixed Time
Window/task.py
##########
@@ -14,6 +14,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
+# beam-playground:
+# name: WindowingFixedTime
+# description: Task from katas to count the number of events that happened
based on fixed window with 1-day duration.
+# multifile: false
+# pipeline_options:
+# categories:
+# - Combiners
Review comment:
```suggestion
# - Streaming
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
