Clarify comment in Create coder inference
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ae80b5da Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ae80b5da Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ae80b5da Branch: refs/heads/master Commit: ae80b5da3b4ea15ceadf38ecc30789b5d3b332e0 Parents: f0e1258 Author: Kenneth Knowles <k...@google.com> Authored: Tue May 24 13:41:52 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Tue May 24 13:41:52 2016 -0700 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/beam/sdk/transforms/Create.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/ae80b5da/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java index 0752113..538966d 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java @@ -519,7 +519,7 @@ public class Create<T> { Coder<T> coder = (Coder<T>) registry.getDefaultCoder(TypeDescriptor.of(elementClazz)); return coder; } catch (CannotProvideCoderException exc) { - // let the next stage try + // Can't get a coder from the class of the elements, try with the elements next } }
