Propagate getAllowedTimestampSkew from DoFn to its adapter
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a1c06d71 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a1c06d71 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a1c06d71 Branch: refs/heads/python-sdk Commit: a1c06d71876384722982ec24da1607e41af653d9 Parents: 0b18652 Author: Kenneth Knowles <k...@google.com> Authored: Thu Aug 4 14:56:19 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Aug 4 14:56:42 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/transforms/DoFnReflector.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a1c06d71/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnReflector.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnReflector.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnReflector.java index 9bdfde8..c6168b3 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnReflector.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnReflector.java @@ -72,6 +72,7 @@ import net.bytebuddy.jar.asm.Label; import net.bytebuddy.jar.asm.MethodVisitor; import net.bytebuddy.jar.asm.Opcodes; import net.bytebuddy.matcher.ElementMatchers; +import org.joda.time.Duration; import org.joda.time.Instant; import java.io.IOException; @@ -731,6 +732,11 @@ public abstract class DoFnReflector { } @Override + public Duration getAllowedTimestampSkew() { + return fn.getAllowedTimestampSkew(); + } + + @Override public void populateDisplayData(DisplayData.Builder builder) { builder.include(fn); }
