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 <[email protected]> Authored: Fri Feb 19 20:08:10 2016 -0800 Committer: Davor Bonaci <[email protected]> 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; }
