You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2019/06/12 23:00:21 UTC
[beam] branch master updated (d754094 -> 3e3961b)
This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from d754094 Merge pull request #8820: [BEAM-7529] Add Sums.ofFloats() and Sums.ofDoubles()
new 7421a17 Add side input and side output java katas
new bb39cf0 Add side input and side output python katas
new 2bddf9c Modify the TestPipeline declaration to be 'final transient'
new a5ed7c3 Add Create.of transform names in CoGroupByKey kata
new c34f8a7 Improve the task description of ParDo OneToMany to describe OutputReceiver
new ab40ce5 Update offset for some tasks
new e2959b3 Merge branch 'master' into add-katas
new 2ac75ce Update the task descriptions: formatting, conventions, and styles
new 4e53ea4 Update Beam version to v2.13.0
new f19cf0e Add BinaryCombineFn Lambda java kata
new 29f0553 Add packages for all Java katas
new ac6faff Add composite transform Java kata
new 64bd536 Add composite transform Python kata
new 8adf0e3 Add 'public' modifier to early Task classes
new a7e64d4 Rename Tests classes to TaskTest
new 7a410ea Add branching Java kata
new 6f14fe0 Add branching Python kata
new 3541d17 Add TextIO Read Java kata
new 23ed747 Add the Kata descriptions for Branching and TextIO Read
new d43a97b Add TextIO ReadFromText Python kata
new 58738a8 Add Kata description from Branching Python kata
new 1a524aa Add Built-in IOs Java kata
new 8502d8e Add Built-in IOs Python kata
new 7ebe261 Add missing copyright for Python kata "Built-in IOs" test file
new ef8665e Add rat exclusion for Katas IO txt files
new e60e173 Removed unused entry in Java kata study_project.xml
new 3e3961b Merge pull request #8804 from henryken/add-katas
The 21934 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
build.gradle | 5 +-
learning/katas/java/.idea/study_project.xml | 1020 ++++++++++++++++----
.../Aggregation/Count/src/Task.java | 46 -
.../commontransforms/aggregation/count/Task.java | 48 +
.../Common Transforms/Aggregation/Count/task.html | 12 +-
.../aggregation/count}/TaskTest.java | 4 +-
.../Aggregation/Max/src/Task.java | 46 -
.../commontransforms/aggregation/max/Task.java | 48 +
.../Common Transforms/Aggregation/Max/task.html | 12 +-
.../aggregation/max}/TaskTest.java | 4 +-
.../Aggregation/Mean/src/Task.java | 46 -
.../commontransforms/aggregation/mean/Task.java | 48 +
.../Common Transforms/Aggregation/Mean/task.html | 12 +-
.../aggregation/mean}/TaskTest.java | 4 +-
.../Aggregation/Min/src/Task.java | 46 -
.../commontransforms/aggregation/min/Task.java | 48 +
.../Common Transforms/Aggregation/Min/task.html | 12 +-
.../aggregation/min}/TaskTest.java | 4 +-
.../Aggregation/Sum/src/Task.java | 46 -
.../commontransforms/aggregation/sum/Task.java | 48 +
.../Common Transforms/Aggregation/Sum/task.html | 12 +-
.../aggregation/sum}/TaskTest.java | 4 +-
.../Common Transforms/Filter/Filter/src/Task.java | 47 -
.../katas/commontransforms/filter/filter/Task.java | 49 +
.../java/Common Transforms/Filter/Filter/task.html | 19 +-
.../commontransforms/filter/filter}/TaskTest.java | 4 +-
.../katas/commontransforms/filter/pardo}/Task.java | 30 +-
.../java/Common Transforms/Filter/ParDo/task.html | 19 +-
.../commontransforms/filter/pardo}/TaskTest.java | 4 +-
.../katas/coretransforms/branching/Task.java | 57 ++
.../Core Transforms/Branching/Branching/task.html | 35 +
.../katas/coretransforms/branching/TaskTest.java | 50 +
.../katas/coretransforms/cogroupbykey}/Task.java | 8 +-
.../cogroupbykey}/WordsAlphabet.java | 2 +
.../CoGroupByKey/CoGroupByKey/task.html | 33 +-
.../coretransforms/cogroupbykey}/TaskTest.java | 4 +-
.../combine/binarycombinefnlambda/Task.java | 54 ++
.../Combine/BinaryCombineFn Lambda/task.html | 43 +
.../combine/binarycombinefnlambda/TaskTest.java | 50 +
.../combine/binarycombinefn}/Task.java | 4 +-
.../Combine/BinaryCombineFn/task.html | 30 +-
.../combine/binarycombinefn}/TaskTest.java | 4 +-
.../combine/combineperkey}/Task.java | 4 +-
.../Combine/Combine PerKey/task.html | 34 +-
.../combine/combineperkey}/TaskTest.java | 4 +-
.../coretransforms/combine/combinefn}/Task.java | 4 +-
.../Core Transforms/Combine/CombineFn/task.html | 31 +-
.../combine/combinefn}/TaskTest.java | 4 +-
.../katas/coretransforms/combine/simple}/Task.java | 4 +-
.../Combine/Simple Function/task.html | 29 +-
.../coretransforms/combine/simple}/TaskTest.java | 4 +-
.../katas/coretransforms/composite/Task.java | 69 ++
.../Composite Transform/task.html | 51 +
.../katas/coretransforms/composite/TaskTest.java | 49 +
.../katas/coretransforms/flatten}/Task.java | 4 +-
.../java/Core Transforms/Flatten/Flatten/task.html | 25 +-
.../katas/coretransforms/flatten}/TaskTest.java | 4 +-
.../katas/coretransforms/groupbykey}/Task.java | 4 +-
.../GroupByKey/GroupByKey/task.html | 36 +-
.../katas/coretransforms/groupbykey}/TaskTest.java | 4 +-
.../coretransforms/map/flatmapelements}/Task.java | 4 +-
.../Core Transforms/Map/FlatMapElements/task.html | 30 +-
.../map/flatmapelements}/TaskTest.java | 4 +-
.../coretransforms/map/mapelements}/Task.java | 4 +-
.../java/Core Transforms/Map/MapElements/task.html | 28 +-
.../coretransforms/map/mapelements}/TaskTest.java | 4 +-
.../coretransforms/map/pardoonetomany}/Task.java | 4 +-
.../Core Transforms/Map/ParDo OneToMany/task.html | 17 +-
.../map/pardoonetomany}/TaskTest.java | 4 +-
.../katas/coretransforms/map/pardo}/Task.java | 4 +-
.../katas/java/Core Transforms/Map/ParDo/task.html | 30 +-
.../katas/coretransforms/map/pardo}/TaskTest.java | 4 +-
.../katas/coretransforms/partition}/Task.java | 4 +-
.../Core Transforms/Partition/Partition/task.html | 26 +-
.../katas/coretransforms/partition}/TaskTest.java | 4 +-
.../katas/coretransforms/sideinput/Person.java | 79 ++
.../katas/coretransforms/sideinput/Task.java | 93 ++
.../Side Input/Side Input/task.html | 54 ++
.../katas/coretransforms/sideinput/TaskTest.java | 75 ++
.../katas/coretransforms/sideoutput/Task.java | 70 ++
.../Side Output/Side Output/task.html | 44 +
.../katas/coretransforms/sideoutput/TaskTest.java | 54 ++
.../learning/katas/examples/wordcount}/Task.java | 30 +-
.../java/Examples/Word Count/Word Count/task.html | 24 +-
.../katas/examples/wordcount}/TaskTest.java | 4 +-
.../IO/Built-in IOs/Built-in IOs/src/Task.java | 34 +
.../java/IO/Built-in IOs/Built-in IOs/task.html | 29 +
.../katas/java/IO/TextIO/TextIO Read/countries.txt | 10 +
.../beam/learning/katas/io/textio/read/Task.java | 53 +
.../katas/java/IO/TextIO/TextIO Read/task.html | 47 +
.../learning/katas/io/textio/read/TaskTest.java | 57 ++
.../beam/learning/katas/intro/hello}/Task.java | 4 +-
.../Introduction/Hello Beam/Hello Beam/task.html | 20 +-
.../beam/learning/katas/intro/hello}/TaskTest.java | 2 +
learning/katas/java/build.gradle | 10 +-
learning/katas/python/.idea/study_project.xml | 832 +++++++++++++---
.../Common Transforms/Aggregation/Count/task.html | 10 +-
.../Aggregation/Largest/task.html | 8 +-
.../Common Transforms/Aggregation/Mean/task.html | 11 +-
.../Aggregation/Smallest/task.html | 8 +-
.../Common Transforms/Aggregation/Sum/task.html | 12 +-
.../Common Transforms/Filter/Filter/task.html | 19 +-
.../Common Transforms/Filter/ParDo/task.html | 15 +-
.../Core Transforms/Branching/Branching/task.html | 35 +
.../Core Transforms/Branching/Branching/task.py | 31 +
.../Core Transforms/Branching/Branching/tests.py | 43 +
.../CoGroupByKey/CoGroupByKey/task.html | 29 +-
.../Combine/Combine PerKey/task.html | 31 +-
.../Core Transforms/Combine/CombineFn/task.html | 26 +-
.../Combine/Simple Function/task.html | 19 +-
.../Composite Transform/task.html | 49 +
.../Composite Transform/task.py | 37 +
.../Composite Transform/tests.py | 44 +
.../Core Transforms/Flatten/Flatten/task.html | 19 +-
.../GroupByKey/GroupByKey/task.html | 34 +-
.../python/Core Transforms/Map/FlatMap/task.html | 29 +-
.../katas/python/Core Transforms/Map/Map/task.html | 24 +-
.../Core Transforms/Map/ParDo OneToMany/task.html | 22 +-
.../python/Core Transforms/Map/ParDo/task.html | 30 +-
.../Core Transforms/Partition/Partition/task.html | 25 +-
.../Side Input/Side Input/task.html | 53 +
.../Core Transforms/Side Input/Side Input/task.py | 69 ++
.../Core Transforms/Side Input/Side Input/tests.py | 70 ++
.../Side Output/Side Output/task.html | 44 +
.../Side Output/Side Output/task.py | 45 +
.../Side Output/Side Output/tests.py | 65 ++
.../Examples/Word Count/Word Count/task.html | 22 +-
.../python/IO/Built-in IOs/Built-in IOs/task.html | 29 +
.../python/IO/Built-in IOs/Built-in IOs/task.py | 22 +
.../python/IO/Built-in IOs/Built-in IOs/tests.py | 16 +
.../python/IO/TextIO/ReadFromText/countries.txt | 10 +
.../katas/python/IO/TextIO/ReadFromText/task.html | 45 +
.../katas/python/IO/TextIO/ReadFromText/task.py | 29 +
.../katas/python/IO/TextIO/ReadFromText/tests.py | 55 ++
.../Introduction/Hello Beam/Hello Beam/task.html | 19 +-
learning/katas/python/requirements.txt | 4 +-
136 files changed, 4531 insertions(+), 957 deletions(-)
delete mode 100644 learning/katas/java/Common Transforms/Aggregation/Count/src/Task.java
create mode 100644 learning/katas/java/Common Transforms/Aggregation/Count/src/org/apache/beam/learning/katas/commontransforms/aggregation/count/Task.java
rename learning/katas/java/Common Transforms/Aggregation/Count/test/{ => org/apache/beam/learning/katas/commontransforms/aggregation/count}/TaskTest.java (90%)
delete mode 100644 learning/katas/java/Common Transforms/Aggregation/Max/src/Task.java
create mode 100644 learning/katas/java/Common Transforms/Aggregation/Max/src/org/apache/beam/learning/katas/commontransforms/aggregation/max/Task.java
rename learning/katas/java/Common Transforms/Aggregation/Max/test/{ => org/apache/beam/learning/katas/commontransforms/aggregation/max}/TaskTest.java (90%)
delete mode 100644 learning/katas/java/Common Transforms/Aggregation/Mean/src/Task.java
create mode 100644 learning/katas/java/Common Transforms/Aggregation/Mean/src/org/apache/beam/learning/katas/commontransforms/aggregation/mean/Task.java
rename learning/katas/java/Common Transforms/Aggregation/Mean/test/{ => org/apache/beam/learning/katas/commontransforms/aggregation/mean}/TaskTest.java (90%)
delete mode 100644 learning/katas/java/Common Transforms/Aggregation/Min/src/Task.java
create mode 100644 learning/katas/java/Common Transforms/Aggregation/Min/src/org/apache/beam/learning/katas/commontransforms/aggregation/min/Task.java
rename learning/katas/java/Common Transforms/Aggregation/Min/test/{ => org/apache/beam/learning/katas/commontransforms/aggregation/min}/TaskTest.java (90%)
delete mode 100644 learning/katas/java/Common Transforms/Aggregation/Sum/src/Task.java
create mode 100644 learning/katas/java/Common Transforms/Aggregation/Sum/src/org/apache/beam/learning/katas/commontransforms/aggregation/sum/Task.java
rename learning/katas/java/Common Transforms/Aggregation/Sum/test/{ => org/apache/beam/learning/katas/commontransforms/aggregation/sum}/TaskTest.java (90%)
delete mode 100644 learning/katas/java/Common Transforms/Filter/Filter/src/Task.java
create mode 100644 learning/katas/java/Common Transforms/Filter/Filter/src/org/apache/beam/learning/katas/commontransforms/filter/filter/Task.java
rename learning/katas/java/Common Transforms/Filter/Filter/test/{ => org/apache/beam/learning/katas/commontransforms/filter/filter}/TaskTest.java (90%)
rename learning/katas/java/Common Transforms/Filter/ParDo/src/{ => org/apache/beam/learning/katas/commontransforms/filter/pardo}/Task.java (56%)
rename learning/katas/java/Common Transforms/Filter/ParDo/test/{ => org/apache/beam/learning/katas/commontransforms/filter/pardo}/TaskTest.java (90%)
create mode 100644 learning/katas/java/Core Transforms/Branching/Branching/src/org/apache/beam/learning/katas/coretransforms/branching/Task.java
create mode 100644 learning/katas/java/Core Transforms/Branching/Branching/task.html
create mode 100644 learning/katas/java/Core Transforms/Branching/Branching/test/org/apache/beam/learning/katas/coretransforms/branching/TaskTest.java
rename learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/src/{ => org/apache/beam/learning/katas/coretransforms/cogroupbykey}/Task.java (95%)
rename learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/src/{ => org/apache/beam/learning/katas/coretransforms/cogroupbykey}/WordsAlphabet.java (95%)
rename learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/test/{ => org/apache/beam/learning/katas/coretransforms/cogroupbykey}/TaskTest.java (92%)
create mode 100644 learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/Task.java
create mode 100644 learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/task.html
create mode 100644 learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/test/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/TaskTest.java
rename learning/katas/java/Core Transforms/Combine/BinaryCombineFn/src/{ => org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn}/Task.java (95%)
rename learning/katas/java/Core Transforms/Combine/BinaryCombineFn/test/{ => org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn}/TaskTest.java (91%)
rename learning/katas/java/Core Transforms/Combine/Combine PerKey/src/{ => org/apache/beam/learning/katas/coretransforms/combine/combineperkey}/Task.java (95%)
rename learning/katas/java/Core Transforms/Combine/Combine PerKey/test/{ => org/apache/beam/learning/katas/coretransforms/combine/combineperkey}/TaskTest.java (91%)
rename learning/katas/java/Core Transforms/Combine/CombineFn/src/{ => org/apache/beam/learning/katas/coretransforms/combine/combinefn}/Task.java (96%)
rename learning/katas/java/Core Transforms/Combine/CombineFn/test/{ => org/apache/beam/learning/katas/coretransforms/combine/combinefn}/TaskTest.java (90%)
rename learning/katas/java/Core Transforms/Combine/Simple Function/src/{ => org/apache/beam/learning/katas/coretransforms/combine/simple}/Task.java (95%)
rename learning/katas/java/Core Transforms/Combine/Simple Function/test/{ => org/apache/beam/learning/katas/coretransforms/combine/simple}/TaskTest.java (90%)
create mode 100644 learning/katas/java/Core Transforms/Composite Transform/Composite Transform/src/org/apache/beam/learning/katas/coretransforms/composite/Task.java
create mode 100644 learning/katas/java/Core Transforms/Composite Transform/Composite Transform/task.html
create mode 100644 learning/katas/java/Core Transforms/Composite Transform/Composite Transform/test/org/apache/beam/learning/katas/coretransforms/composite/TaskTest.java
rename learning/katas/java/Core Transforms/Flatten/Flatten/src/{ => org/apache/beam/learning/katas/coretransforms/flatten}/Task.java (95%)
rename learning/katas/java/Core Transforms/Flatten/Flatten/test/{ => org/apache/beam/learning/katas/coretransforms/flatten}/TaskTest.java (92%)
rename learning/katas/java/Core Transforms/GroupByKey/GroupByKey/src/{ => org/apache/beam/learning/katas/coretransforms/groupbykey}/Task.java (95%)
rename learning/katas/java/Core Transforms/GroupByKey/GroupByKey/test/{ => org/apache/beam/learning/katas/coretransforms/groupbykey}/TaskTest.java (92%)
rename learning/katas/java/Core Transforms/Map/FlatMapElements/src/{ => org/apache/beam/learning/katas/coretransforms/map/flatmapelements}/Task.java (95%)
rename learning/katas/java/Core Transforms/Map/FlatMapElements/test/{ => org/apache/beam/learning/katas/coretransforms/map/flatmapelements}/TaskTest.java (90%)
rename learning/katas/java/Core Transforms/Map/MapElements/src/{ => org/apache/beam/learning/katas/coretransforms/map/mapelements}/Task.java (95%)
rename learning/katas/java/Core Transforms/Map/MapElements/test/{ => org/apache/beam/learning/katas/coretransforms/map/mapelements}/TaskTest.java (90%)
rename learning/katas/java/Core Transforms/Map/ParDo OneToMany/src/{ => org/apache/beam/learning/katas/coretransforms/map/pardoonetomany}/Task.java (95%)
rename learning/katas/java/Core Transforms/Map/ParDo OneToMany/test/{ => org/apache/beam/learning/katas/coretransforms/map/pardoonetomany}/TaskTest.java (90%)
rename learning/katas/java/Core Transforms/Map/ParDo/src/{ => org/apache/beam/learning/katas/coretransforms/map/pardo}/Task.java (95%)
rename learning/katas/java/Core Transforms/Map/ParDo/test/{ => org/apache/beam/learning/katas/coretransforms/map/pardo}/TaskTest.java (90%)
rename learning/katas/java/Core Transforms/Partition/Partition/src/{ => org/apache/beam/learning/katas/coretransforms/partition}/Task.java (96%)
rename learning/katas/java/Core Transforms/Partition/Partition/test/{ => org/apache/beam/learning/katas/coretransforms/partition}/TaskTest.java (91%)
create mode 100644 learning/katas/java/Core Transforms/Side Input/Side Input/src/org/apache/beam/learning/katas/coretransforms/sideinput/Person.java
create mode 100644 learning/katas/java/Core Transforms/Side Input/Side Input/src/org/apache/beam/learning/katas/coretransforms/sideinput/Task.java
create mode 100644 learning/katas/java/Core Transforms/Side Input/Side Input/task.html
create mode 100644 learning/katas/java/Core Transforms/Side Input/Side Input/test/org/apache/beam/learning/katas/coretransforms/sideinput/TaskTest.java
create mode 100644 learning/katas/java/Core Transforms/Side Output/Side Output/src/org/apache/beam/learning/katas/coretransforms/sideoutput/Task.java
create mode 100644 learning/katas/java/Core Transforms/Side Output/Side Output/task.html
create mode 100644 learning/katas/java/Core Transforms/Side Output/Side Output/test/org/apache/beam/learning/katas/coretransforms/sideoutput/TaskTest.java
rename learning/katas/java/Examples/Word Count/Word Count/src/{ => org/apache/beam/learning/katas/examples/wordcount}/Task.java (65%)
rename learning/katas/java/Examples/Word Count/Word Count/test/{ => org/apache/beam/learning/katas/examples/wordcount}/TaskTest.java (92%)
create mode 100644 learning/katas/java/IO/Built-in IOs/Built-in IOs/src/Task.java
create mode 100644 learning/katas/java/IO/Built-in IOs/Built-in IOs/task.html
create mode 100644 learning/katas/java/IO/TextIO/TextIO Read/countries.txt
create mode 100644 learning/katas/java/IO/TextIO/TextIO Read/src/org/apache/beam/learning/katas/io/textio/read/Task.java
create mode 100644 learning/katas/java/IO/TextIO/TextIO Read/task.html
create mode 100644 learning/katas/java/IO/TextIO/TextIO Read/test/org/apache/beam/learning/katas/io/textio/read/TaskTest.java
rename learning/katas/java/Introduction/Hello Beam/Hello Beam/src/{ => org/apache/beam/learning/katas/intro/hello}/Task.java (95%)
rename learning/katas/java/Introduction/Hello Beam/Hello Beam/test/{ => org/apache/beam/learning/katas/intro/hello}/TaskTest.java (96%)
create mode 100644 learning/katas/python/Core Transforms/Branching/Branching/task.html
create mode 100644 learning/katas/python/Core Transforms/Branching/Branching/task.py
create mode 100644 learning/katas/python/Core Transforms/Branching/Branching/tests.py
create mode 100644 learning/katas/python/Core Transforms/Composite Transform/Composite Transform/task.html
create mode 100644 learning/katas/python/Core Transforms/Composite Transform/Composite Transform/task.py
create mode 100644 learning/katas/python/Core Transforms/Composite Transform/Composite Transform/tests.py
create mode 100644 learning/katas/python/Core Transforms/Side Input/Side Input/task.html
create mode 100644 learning/katas/python/Core Transforms/Side Input/Side Input/task.py
create mode 100644 learning/katas/python/Core Transforms/Side Input/Side Input/tests.py
create mode 100644 learning/katas/python/Core Transforms/Side Output/Side Output/task.html
create mode 100644 learning/katas/python/Core Transforms/Side Output/Side Output/task.py
create mode 100644 learning/katas/python/Core Transforms/Side Output/Side Output/tests.py
create mode 100644 learning/katas/python/IO/Built-in IOs/Built-in IOs/task.html
create mode 100644 learning/katas/python/IO/Built-in IOs/Built-in IOs/task.py
create mode 100644 learning/katas/python/IO/Built-in IOs/Built-in IOs/tests.py
create mode 100644 learning/katas/python/IO/TextIO/ReadFromText/countries.txt
create mode 100644 learning/katas/python/IO/TextIO/ReadFromText/task.html
create mode 100644 learning/katas/python/IO/TextIO/ReadFromText/task.py
create mode 100644 learning/katas/python/IO/TextIO/ReadFromText/tests.py