Correctly determine if DoFn has an anonymous class in ParDo
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0b186529 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0b186529 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0b186529 Branch: refs/heads/master Commit: 0b1865295cb89d88878d0a021df103ed45240924 Parents: fcf6b1d Author: Kenneth Knowles <[email protected]> Authored: Thu Aug 4 14:54:56 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Thu Aug 4 14:56:42 2016 -0700 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0b186529/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java index bb1af9c..91f6203 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java @@ -958,7 +958,7 @@ public class ParDo { @Override protected String getKindString() { Class<?> clazz = DoFnReflector.getDoFnClass(fn); - if (fn.getClass().isAnonymousClass()) { + if (clazz.isAnonymousClass()) { return "AnonymousParMultiDo"; } else { return String.format("ParMultiDo(%s)", StringUtils.approximateSimpleName(clazz));
