Add NotSerializable.forUrn to key by URN for non-serializable overrides
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d684ca09 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d684ca09 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d684ca09 Branch: refs/heads/master Commit: d684ca096b524202b0d64e1b4ab1e472528bb3a5 Parents: 5bc77fc Author: Kenneth Knowles <[email protected]> Authored: Tue Oct 17 12:41:42 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Tue Oct 17 12:45:11 2017 -0700 ---------------------------------------------------------------------- .../runners/core/construction/PTransformTranslation.java | 10 ++++++++++ 1 file changed, 10 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/d684ca09/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 785b9e4..8e6829b 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 @@ -297,6 +297,16 @@ public class PTransformTranslation { */ abstract class NotSerializable<T extends PTransform<?, ?>> implements TransformPayloadTranslator<T> { + + public static NotSerializable<?> forUrn(final String urn) { + return new NotSerializable<PTransform<?, ?>>() { + @Override + public String getUrn(PTransform<?, ?> transform) { + return urn; + } + }; + } + @Override public final FunctionSpec translate( AppliedPTransform<?, ?, T> transform, SdkComponents components) throws IOException {
