Add packages for all Java katas

mransley · Jun 9, 2019 · 29f0553 · 29f0553
1 parent f19cf0e
commit 29f0553
Show file tree

Hide file tree

Showing 51 changed files with 243 additions and 143 deletions.
diff --git a/learning/katas/java/.idea/study_project.xml b/learning/katas/java/.idea/study_project.xml
diff --git a/...ransforms/Aggregation/Count/src/Task.java → ...montransforms/aggregation/count/Task.java b/...ransforms/Aggregation/Count/src/Task.java → ...montransforms/aggregation/count/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.count;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...orms/Aggregation/Count/test/TaskTest.java → ...ransforms/aggregation/count/TaskTest.java b/...orms/Aggregation/Count/test/TaskTest.java → ...ransforms/aggregation/count/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.count;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/... Transforms/Aggregation/Max/src/Task.java → ...ommontransforms/aggregation/max/Task.java b/... Transforms/Aggregation/Max/src/Task.java → ...ommontransforms/aggregation/max/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.max;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...sforms/Aggregation/Max/test/TaskTest.java → ...ntransforms/aggregation/max/TaskTest.java b/...sforms/Aggregation/Max/test/TaskTest.java → ...ntransforms/aggregation/max/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.max;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...Transforms/Aggregation/Mean/src/Task.java → ...mmontransforms/aggregation/mean/Task.java b/...Transforms/Aggregation/Mean/src/Task.java → ...mmontransforms/aggregation/mean/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.mean;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...forms/Aggregation/Mean/test/TaskTest.java → ...transforms/aggregation/mean/TaskTest.java b/...forms/Aggregation/Mean/test/TaskTest.java → ...transforms/aggregation/mean/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.mean;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/... Transforms/Aggregation/Min/src/Task.java → ...ommontransforms/aggregation/min/Task.java b/... Transforms/Aggregation/Min/src/Task.java → ...ommontransforms/aggregation/min/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.min;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...sforms/Aggregation/Min/test/TaskTest.java → ...ntransforms/aggregation/min/TaskTest.java b/...sforms/Aggregation/Min/test/TaskTest.java → ...ntransforms/aggregation/min/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.min;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/... Transforms/Aggregation/Sum/src/Task.java → ...ommontransforms/aggregation/sum/Task.java b/... Transforms/Aggregation/Sum/src/Task.java → ...ommontransforms/aggregation/sum/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.sum;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...sforms/Aggregation/Sum/test/TaskTest.java → ...ntransforms/aggregation/sum/TaskTest.java b/...sforms/Aggregation/Sum/test/TaskTest.java → ...ntransforms/aggregation/sum/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.aggregation.sum;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...on Transforms/Filter/Filter/src/Task.java → .../commontransforms/filter/filter/Task.java b/...on Transforms/Filter/Filter/src/Task.java → .../commontransforms/filter/filter/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.filter.filter;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...ansforms/Filter/Filter/test/TaskTest.java → ...montransforms/filter/filter/TaskTest.java b/...ansforms/Filter/Filter/test/TaskTest.java → ...montransforms/filter/filter/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.filter.filter;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...mon Transforms/Filter/ParDo/src/Task.java → ...s/commontransforms/filter/pardo/Task.java b/...mon Transforms/Filter/ParDo/src/Task.java → ...s/commontransforms/filter/pardo/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.filter.pardo;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...ransforms/Filter/ParDo/test/TaskTest.java → ...mmontransforms/filter/pardo/TaskTest.java b/...ransforms/Filter/ParDo/test/TaskTest.java → ...mmontransforms/filter/pardo/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.commontransforms.filter.pardo;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...s/CoGroupByKey/CoGroupByKey/src/Task.java → ...tas/coretransforms/cogroupbykey/Task.java b/...s/CoGroupByKey/CoGroupByKey/src/Task.java → ...tas/coretransforms/cogroupbykey/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.cogroupbykey;
+
 import static org.apache.beam.sdk.values.TypeDescriptors.kvs;
 import static org.apache.beam.sdk.values.TypeDescriptors.strings;
 

diff --git a/...ByKey/CoGroupByKey/src/WordsAlphabet.java → ...ransforms/cogroupbykey/WordsAlphabet.java b/...ByKey/CoGroupByKey/src/WordsAlphabet.java → ...ransforms/cogroupbykey/WordsAlphabet.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.cogroupbykey;
+
 public class WordsAlphabet {
 
  private String alphabet;

diff --git a/...roupByKey/CoGroupByKey/test/TaskTest.java → ...coretransforms/cogroupbykey/TaskTest.java b/...roupByKey/CoGroupByKey/test/TaskTest.java → ...coretransforms/cogroupbykey/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.cogroupbykey;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...bine/BinaryCombineFn Lambda/src/Task.java → ...s/combine/binarycombinefnlambda/Task.java b/...bine/BinaryCombineFn Lambda/src/Task.java → ...s/combine/binarycombinefnlambda/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.binarycombinefnlambda;
+
 import java.math.BigInteger;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;

diff --git a/...ne/BinaryCombineFn Lambda/test/Tests.java → .../combine/binarycombinefnlambda/Tests.java b/...ne/BinaryCombineFn Lambda/test/Tests.java → .../combine/binarycombinefnlambda/Tests.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.binarycombinefnlambda;
+
 import java.math.BigInteger;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;

diff --git a/...rms/Combine/BinaryCombineFn/src/Task.java → ...nsforms/combine/binarycombinefn/Task.java b/...rms/Combine/BinaryCombineFn/src/Task.java → ...nsforms/combine/binarycombinefn/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.binarycombinefn;
+
 import java.math.BigInteger;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;

diff --git a/...ombine/BinaryCombineFn/test/TaskTest.java → ...rms/combine/binarycombinefn/TaskTest.java b/...ombine/BinaryCombineFn/test/TaskTest.java → ...rms/combine/binarycombinefn/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.binarycombinefn;
+
 import java.math.BigInteger;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;

diff --git a/...orms/Combine/Combine PerKey/src/Task.java → ...ransforms/combine/combineperkey/Task.java b/...orms/Combine/Combine PerKey/src/Task.java → ...ransforms/combine/combineperkey/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.combineperkey;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...Combine/Combine PerKey/test/TaskTest.java → ...forms/combine/combineperkey/TaskTest.java b/...Combine/Combine PerKey/test/TaskTest.java → ...forms/combine/combineperkey/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.combineperkey;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...ransforms/Combine/CombineFn/src/Task.java → ...oretransforms/combine/combinefn/Task.java b/...ransforms/Combine/CombineFn/src/Task.java → ...oretransforms/combine/combinefn/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.combinefn;
+
 import java.io.Serializable;
 import java.util.Objects;
 import org.apache.beam.sdk.Pipeline;

diff --git a/...orms/Combine/CombineFn/test/TaskTest.java → ...ransforms/combine/combinefn/TaskTest.java b/...orms/Combine/CombineFn/test/TaskTest.java → ...ransforms/combine/combinefn/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.combinefn;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...rms/Combine/Simple Function/src/Task.java → ...s/coretransforms/combine/simple/Task.java b/...rms/Combine/Simple Function/src/Task.java → ...s/coretransforms/combine/simple/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.simple;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...ombine/Simple Function/test/TaskTest.java → ...retransforms/combine/simple/TaskTest.java b/...ombine/Simple Function/test/TaskTest.java → ...retransforms/combine/simple/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.combine.simple;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/... Transforms/Flatten/Flatten/src/Task.java → ...ng/katas/coretransforms/flatten/Task.java b/... Transforms/Flatten/Flatten/src/Task.java → ...ng/katas/coretransforms/flatten/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.flatten;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...sforms/Flatten/Flatten/test/TaskTest.java → ...atas/coretransforms/flatten/TaskTest.java b/...sforms/Flatten/Flatten/test/TaskTest.java → ...atas/coretransforms/flatten/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.flatten;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...forms/GroupByKey/GroupByKey/src/Task.java → ...katas/coretransforms/groupbykey/Task.java b/...forms/GroupByKey/GroupByKey/src/Task.java → ...katas/coretransforms/groupbykey/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.groupbykey;
+
 import static org.apache.beam.sdk.values.TypeDescriptors.kvs;
 import static org.apache.beam.sdk.values.TypeDescriptors.strings;
 

diff --git a/.../GroupByKey/GroupByKey/test/TaskTest.java → ...s/coretransforms/groupbykey/TaskTest.java b/.../GroupByKey/GroupByKey/test/TaskTest.java → ...s/coretransforms/groupbykey/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.groupbykey;
+
 import static test.util.ContainsKvs.containsKvs;
 
 import com.google.common.collect.ImmutableList;

diff --git a/...nsforms/Map/FlatMapElements/src/Task.java → ...etransforms/map/flatmapelements/Task.java b/...nsforms/Map/FlatMapElements/src/Task.java → ...etransforms/map/flatmapelements/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.flatmapelements;
+
 import java.util.Arrays;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;

diff --git a/...ms/Map/FlatMapElements/test/TaskTest.java → ...nsforms/map/flatmapelements/TaskTest.java b/...ms/Map/FlatMapElements/test/TaskTest.java → ...nsforms/map/flatmapelements/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.flatmapelements;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/... Transforms/Map/MapElements/src/Task.java → .../coretransforms/map/mapelements/Task.java b/... Transforms/Map/MapElements/src/Task.java → .../coretransforms/map/mapelements/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.mapelements;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...sforms/Map/MapElements/test/TaskTest.java → ...etransforms/map/mapelements/TaskTest.java b/...sforms/Map/MapElements/test/TaskTest.java → ...etransforms/map/mapelements/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.mapelements;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...nsforms/Map/ParDo OneToMany/src/Task.java → ...retransforms/map/pardoonetomany/Task.java b/...nsforms/Map/ParDo OneToMany/src/Task.java → ...retransforms/map/pardoonetomany/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.pardoonetomany;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...ms/Map/ParDo OneToMany/test/TaskTest.java → ...ansforms/map/pardoonetomany/TaskTest.java b/...ms/Map/ParDo OneToMany/test/TaskTest.java → ...ansforms/map/pardoonetomany/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.pardoonetomany;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...a/Core Transforms/Map/ParDo/src/Task.java → .../katas/coretransforms/map/pardo/Task.java b/...a/Core Transforms/Map/ParDo/src/Task.java → .../katas/coretransforms/map/pardo/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.pardo;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...e Transforms/Map/ParDo/test/TaskTest.java → ...as/coretransforms/map/pardo/TaskTest.java b/...e Transforms/Map/ParDo/test/TaskTest.java → ...as/coretransforms/map/pardo/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.map.pardo;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...nsforms/Partition/Partition/src/Task.java → .../katas/coretransforms/partition/Task.java b/...nsforms/Partition/Partition/src/Task.java → .../katas/coretransforms/partition/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.partition;
+
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.options.PipelineOptionsFactory;

diff --git a/...ms/Partition/Partition/test/TaskTest.java → ...as/coretransforms/partition/TaskTest.java b/...ms/Partition/Partition/test/TaskTest.java → ...as/coretransforms/partition/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.partition;
+
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;
 import org.apache.beam.sdk.transforms.Create;

diff --git a/...rms/Side Input/Side Input/src/Person.java → ...atas/coretransforms/sideinput/Person.java b/...rms/Side Input/Side Input/src/Person.java → ...atas/coretransforms/sideinput/Person.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.sideinput;
+
 import java.io.Serializable;
 import java.util.Objects;
 

diff --git a/...forms/Side Input/Side Input/src/Task.java → .../katas/coretransforms/sideinput/Task.java b/...forms/Side Input/Side Input/src/Task.java → .../katas/coretransforms/sideinput/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.sideinput;
+
 import java.util.Map;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;

diff --git a/.../Side Input/Side Input/test/TaskTest.java → ...as/coretransforms/sideinput/TaskTest.java b/.../Side Input/Side Input/test/TaskTest.java → ...as/coretransforms/sideinput/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.coretransforms.sideinput;
+
 import java.util.Map;
 import org.apache.beam.sdk.testing.PAssert;
 import org.apache.beam.sdk.testing.TestPipeline;