issues #56, #52, #53

mattcasters · Feb 12, 2020 · 2feb26a · 2feb26a
1 parent 94990f2
commit 2feb26a
Show file tree

Hide file tree

Showing 11 changed files with 947 additions and 186 deletions.
diff --git a/src/main/java/org/kettle/beam/core/partition/SinglePartitionFn.java b/src/main/java/org/kettle/beam/core/partition/SinglePartitionFn.java
@@ -0,0 +1,13 @@
+package org.kettle.beam.core.partition;
+
+import org.apache.beam.sdk.transforms.Partition;
+import org.kettle.beam.core.KettleRow;
+
+public class SinglePartitionFn implements Partition.PartitionFn<KettleRow> {
+
+  private static final long serialVersionUID = 95100000000000001L;
+
+  @Override public int partitionFor( KettleRow elem, int numPartitions ) {
+    return 0;
+  }
+}