beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [01/12] beam git commit: Add URN for Splittable ProcessElement pseudo-primitive
Date Fri, 26 May 2017 04:08:07 GMT
Repository: beam
Updated Branches:
  refs/heads/master 50200f23a -> 9cd12907e


Add URN for Splittable ProcessElement pseudo-primitive


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/877408e0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/877408e0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/877408e0

Branch: refs/heads/master
Commit: 877408e078b783b3a782ae1ba0e335ea44c4a0e2
Parents: 1dc134c
Author: Kenneth Knowles <klk@google.com>
Authored: Wed May 24 15:28:38 2017 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Thu May 25 11:14:29 2017 -0700

----------------------------------------------------------------------
 .../apache/beam/runners/core/construction/SplittableParDo.java    | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/877408e0/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java
----------------------------------------------------------------------
diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java
b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java
index 23ba66a..dfca7d2 100644
--- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java
+++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java
@@ -64,6 +64,9 @@ public class SplittableParDo<InputT, OutputT, RestrictionT>
     extends PTransform<PCollection<InputT>, PCollectionTuple> {
   private final ParDo.MultiOutput<InputT, OutputT> parDo;
 
+  public static final String SPLITTABLE_PROCESS_URN =
+      "urn:beam:runners_core:transforms:splittable_process:v1";
+
   /**
    * Creates the transform for the given original multi-output {@link ParDo}.
    *


Mime
View raw message