You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2017/04/20 15:55:22 UTC
[4/6] beam git commit: Enable IntervalWindowCoder test check.
Enable IntervalWindowCoder test check.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/68c00426
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/68c00426
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/68c00426
Branch: refs/heads/master
Commit: 68c00426261c54a32be509f9ab53cf3543d49d78
Parents: d98294c
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Tue Apr 11 10:52:44 2017 -0700
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Thu Apr 20 08:55:04 2017 -0700
----------------------------------------------------------------------
sdks/python/apache_beam/coders/coders_test_common.py | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/68c00426/sdks/python/apache_beam/coders/coders_test_common.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/coders/coders_test_common.py b/sdks/python/apache_beam/coders/coders_test_common.py
index da0bde3..e5bfe35 100644
--- a/sdks/python/apache_beam/coders/coders_test_common.py
+++ b/sdks/python/apache_beam/coders/coders_test_common.py
@@ -61,8 +61,7 @@ class CodersTest(unittest.TestCase):
standard -= set([coders.Coder,
coders.FastCoder,
coders.ProtoCoder,
- coders.ToStringCoder,
- coders.IntervalWindowCoder])
+ coders.ToStringCoder])
assert not standard - cls.seen, standard - cls.seen
assert not standard - cls.seen_nested, standard - cls.seen_nested
@@ -171,6 +170,9 @@ class CodersTest(unittest.TestCase):
*[window.IntervalWindow(x, y)
for x in [-2**52, 0, 2**52]
for y in range(-100, 100)])
+ self.check_coder(
+ coders.TupleCoder((coders.IntervalWindowCoder(),)),
+ (window.IntervalWindow(0, 10),))
def test_timestamp_coder(self):
self.check_coder(coders.TimestampCoder(),