beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [2/7] beam git commit: Allow translation to throw IOException
Date Fri, 26 May 2017 17:47:45 GMT
Allow translation to throw IOException


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

Branch: refs/heads/master
Commit: b0dc523c72a68e870392fbac8ff9f3a87459ab22
Parents: c8478fe
Author: Kenneth Knowles <klk@google.com>
Authored: Thu May 25 13:02:15 2017 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Fri May 26 10:22:37 2017 -0700

----------------------------------------------------------------------
 .../beam/runners/core/construction/PTransformTranslation.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/b0dc523c/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java
----------------------------------------------------------------------
diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java
b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java
index 9f5f3b5..00ea55e 100644
--- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java
+++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java
@@ -138,7 +138,8 @@ public class PTransformTranslation {
    */
   public interface TransformPayloadTranslator<T extends PTransform<?, ?>> {
     String getUrn(T transform);
-    FunctionSpec translate(AppliedPTransform<?, ?, T> application, SdkComponents components);
+    FunctionSpec translate(AppliedPTransform<?, ?, T> application, SdkComponents components)
+        throws IOException;
   }
 
   /**


Mime
View raw message