Add package for "Early Triggers" and "Window Accumulation Mode"

mransley · Jun 16, 2019 · 8d25f7b · 8d25f7b
1 parent 0afe06b
commit 8d25f7b
Show file tree

Hide file tree

Showing 7 changed files with 67 additions and 55 deletions.
diff --git a/learning/katas/java/.idea/study_project.xml b/learning/katas/java/.idea/study_project.xml
diff --git a/...ers/Early Triggers/src/GenerateEvent.java → ...triggers/earlytriggers/GenerateEvent.java b/...ers/Early Triggers/src/GenerateEvent.java → ...triggers/earlytriggers/GenerateEvent.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.triggers.earlytriggers;
+
 import static org.apache.beam.sdk.values.TypeDescriptors.strings;
 
 import org.apache.beam.sdk.io.GenerateSequence;

diff --git a/...rly Triggers/Early Triggers/src/Task.java → ...ng/katas/triggers/earlytriggers/Task.java b/...rly Triggers/Early Triggers/src/Task.java → ...ng/katas/triggers/earlytriggers/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.triggers.earlytriggers;
+
 import org.apache.beam.learning.katas.util.Log;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;

diff --git a/...riggers/Early Triggers/test/TaskTest.java → ...atas/triggers/earlytriggers/TaskTest.java b/...riggers/Early Triggers/test/TaskTest.java → ...atas/triggers/earlytriggers/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.triggers.earlytriggers;
+
 import java.io.Serializable;
 import org.apache.beam.sdk.coders.SerializableCoder;
 import org.apache.beam.sdk.testing.PAssert;

diff --git a/... Accumulation Mode/src/GenerateEvent.java → ...iggers/windowaccummode/GenerateEvent.java b/... Accumulation Mode/src/GenerateEvent.java → ...iggers/windowaccummode/GenerateEvent.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.triggers.windowaccummode;
+
 import static org.apache.beam.sdk.values.TypeDescriptors.strings;
 
 import org.apache.beam.sdk.io.GenerateSequence;

diff --git a/...de/Window Accumulation Mode/src/Task.java → .../katas/triggers/windowaccummode/Task.java b/...de/Window Accumulation Mode/src/Task.java → .../katas/triggers/windowaccummode/Task.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.triggers.windowaccummode;
+
 import org.apache.beam.learning.katas.util.Log;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.options.PipelineOptions;

diff --git a/...ndow Accumulation Mode/test/TaskTest.java → ...as/triggers/windowaccummode/TaskTest.java b/...ndow Accumulation Mode/test/TaskTest.java → ...as/triggers/windowaccummode/TaskTest.java
@@ -16,6 +16,8 @@
  * limitations under the License.
  */
 
+package org.apache.beam.learning.katas.triggers.windowaccummode;
+
 import java.io.Serializable;
 import org.apache.beam.sdk.coders.SerializableCoder;
 import org.apache.beam.sdk.testing.PAssert;