You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/05/26 17:47:45 UTC
[2/7] beam git commit: Allow translation to throw IOException
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 <kl...@google.com>
Authored: Thu May 25 13:02:15 2017 -0700
Committer: Kenneth Knowles <kl...@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;
}
/**