[beam] branch master updated: Register another generic iterable type.

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

robertwb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new c73ffec  Register another generic iterable type.
     new b47fdfe  Merge pull request #7686 Register another generic iterable type.
c73ffec is described below

commit c73ffec50210e640fd42d55d1c235d1008e40388
Author: Robert Bradshaw <ro...@google.com>
AuthorDate: Thu Jan 31 13:20:45 2019 +0100

    Register another generic iterable type.
---
 sdks/python/apache_beam/transforms/trigger.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/sdks/python/apache_beam/transforms/trigger.py b/sdks/python/apache_beam/transforms/trigger.py
index 460e711..2838a84 100644
--- a/sdks/python/apache_beam/transforms/trigger.py
+++ b/sdks/python/apache_beam/transforms/trigger.py
@@ -34,6 +34,7 @@ from future.moves.itertools import zip_longest
 from future.utils import iteritems
 from future.utils import with_metaclass
 
+from apache_beam.coders import coder_impl
 from apache_beam.coders import observable
 from apache_beam.portability.api import beam_runner_api_pb2
 from apache_beam.transforms import combiners
@@ -1001,6 +1002,10 @@ class _UnwindowedValues(observable.ObservableMixin):
     return not self == other
 
 
+coder_impl.FastPrimitivesCoderImpl.register_iterable_like_type(
+    _UnwindowedValues)
+
+
 class DiscardingGlobalTriggerDriver(TriggerDriver):
   """Groups all received values together.
   """