beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [06/12] beam git commit: Register WindowIntoTranslator
Date Fri, 26 May 2017 04:08:12 GMT
Register WindowIntoTranslator


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

Branch: refs/heads/master
Commit: 69bb1be4d3bd20e5c080bcce0eb464fac3d2ff73
Parents: d91c840
Author: Kenneth Knowles <klk@google.com>
Authored: Mon May 22 21:09:33 2017 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Thu May 25 11:16:47 2017 -0700

----------------------------------------------------------------------
 .../beam/runners/core/construction/WindowIntoTranslation.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/69bb1be4/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java
----------------------------------------------------------------------
diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java
b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java
index 5ed4d24..aa17bc9 100644
--- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java
+++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java
@@ -91,7 +91,7 @@ public class WindowIntoTranslation {
         AppliedPTransform<?, ?, Window.Assign<?>> transform, SdkComponents components)
{
       WindowIntoPayload payload = toProto(transform.getTransform(), components);
       return RunnerApi.FunctionSpec.newBuilder()
-          .setUrn(PTransformTranslation.WINDOW_TRANSFORM_URN)
+          .setUrn(getUrn(transform.getTransform()))
           .setParameter(Any.pack(payload))
           .build();
     }


Mime
View raw message