Add IntervalWindow coder to the standard registry
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9678b1cc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9678b1cc Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9678b1cc Branch: refs/heads/master Commit: 9678b1cc6c799767e48ebc4d9071db099b4d135d Parents: 59f1fb2 Author: Kenneth Knowles <[email protected]> Authored: Thu Nov 3 20:44:45 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Mon Dec 12 15:12:05 2016 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/9678b1cc/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java index 9110de0..65f4209 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java @@ -40,6 +40,7 @@ import javax.annotation.Nullable; import org.apache.beam.sdk.coders.CannotProvideCoderException.ReasonCode; import org.apache.beam.sdk.coders.protobuf.ProtoCoder; import org.apache.beam.sdk.transforms.SerializableFunction; +import org.apache.beam.sdk.transforms.windowing.IntervalWindow; import org.apache.beam.sdk.util.CoderUtils; import org.apache.beam.sdk.values.KV; import org.apache.beam.sdk.values.TimestampedValue; @@ -107,6 +108,7 @@ public class CoderRegistry implements CoderProvider { registerCoder(TimestampedValue.class, TimestampedValue.TimestampedValueCoder.class); registerCoder(Void.class, VoidCoder.class); registerCoder(byte[].class, ByteArrayCoder.class); + registerCoder(IntervalWindow.class, IntervalWindow.getCoder()); } /**
