beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jamesmal...@apache.org
Subject [01/50] [abbrv] incubator-beam git commit: Allow TransformEvaluatorFactory#forApplication to throw
Date Fri, 26 Feb 2016 22:54:38 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 11e842717 -> 211e76abf


Allow TransformEvaluatorFactory#forApplication to throw

Certain Transforms (like sources) can throw an exception while being
constructed. This allows the transforms to throw an exception while
being constructed rather than on first application.

----Release Notes----
[]
-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=115122695


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

Branch: refs/heads/master
Commit: 015e1afede0abb3fc087d4c5d4072f7801ed5d45
Parents: 234d5eb
Author: tgroh <tgroh@google.com>
Authored: Fri Feb 19 20:08:10 2016 -0800
Committer: Davor Bonaci <davorbonaci@users.noreply.github.com>
Committed: Thu Feb 25 23:58:25 2016 -0800

----------------------------------------------------------------------
 .../sdk/runners/inprocess/TransformEvaluatorFactory.java         | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/015e1afe/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/TransformEvaluatorFactory.java
----------------------------------------------------------------------
diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/TransformEvaluatorFactory.java
b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/TransformEvaluatorFactory.java
index 7941c16..3b672e0 100644
--- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/TransformEvaluatorFactory.java
+++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/TransformEvaluatorFactory.java
@@ -34,8 +34,10 @@ public interface TransformEvaluatorFactory {
    * Any work that must be done before input elements are processed (such as calling
    * {@link DoFn#startBundle(DoFn.Context)}) must be done before the {@link TransformEvaluator}
is
    * made available to the caller.
+   *
+   * @throws Exception whenever constructing the underlying evaluator throws an exception
    */
   <InputT> TransformEvaluator<InputT> forApplication(
       AppliedPTransform<?, ?, ?> application, @Nullable CommittedBundle<?> inputBundle,
-      InProcessEvaluationContext evaluationContext);
+      InProcessEvaluationContext evaluationContext) throws Exception;
 }


Mime
View raw message