beam-commits mailing list archives

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


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

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

----------------------------------------------------------------------
 .../beam/runners/core/construction/ReadTranslation.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/d91c840f/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java
----------------------------------------------------------------------
diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java
b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java
index aff5fc9..3ddde8d 100644
--- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java
+++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java
@@ -143,7 +143,7 @@ public class ReadTranslation {
 
     @Override
     public String getUrn(Read.Unbounded<?> transform) {
-      return PTransformTranslation.WINDOW_TRANSFORM_URN;
+      return PTransformTranslation.READ_TRANSFORM_URN;
     }
 
     @Override
@@ -151,7 +151,7 @@ public class ReadTranslation {
         AppliedPTransform<?, ?, Read.Unbounded<?>> transform, SdkComponents components)
{
       ReadPayload payload = toProto(transform.getTransform());
       return RunnerApi.FunctionSpec.newBuilder()
-          .setUrn(PTransformTranslation.READ_TRANSFORM_URN)
+          .setUrn(getUrn(transform.getTransform()))
           .setParameter(Any.pack(payload))
           .build();
     }
@@ -170,7 +170,7 @@ public class ReadTranslation {
 
     @Override
     public String getUrn(Read.Bounded<?> transform) {
-      return PTransformTranslation.WINDOW_TRANSFORM_URN;
+      return PTransformTranslation.READ_TRANSFORM_URN;
     }
 
     @Override
@@ -178,7 +178,7 @@ public class ReadTranslation {
         AppliedPTransform<?, ?, Read.Bounded<?>> transform, SdkComponents components)
{
       ReadPayload payload = toProto(transform.getTransform());
       return RunnerApi.FunctionSpec.newBuilder()
-          .setUrn(PTransformTranslation.READ_TRANSFORM_URN)
+          .setUrn(getUrn(transform.getTransform()))
           .setParameter(Any.pack(payload))
           .build();
     }


Mime
View raw message