beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [26/50] [abbrv] beam git commit: Use inner module for non-public coders.
Date Mon, 12 Jun 2017 16:55:41 GMT
Use inner module for non-public coders.


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36aea2d2
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36aea2d2
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36aea2d2

Branch: refs/heads/gearpump-runner
Commit: 36aea2d26d7c8ea3299d7a25d617a6ba99794e18
Parents: 4aef938
Author: Robert Bradshaw <robertwb@gmail.com>
Authored: Wed Jun 7 23:35:11 2017 -0700
Committer: Robert Bradshaw <robertwb@google.com>
Committed: Thu Jun 8 13:58:31 2017 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/runners/worker/operation_specs.py | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/36aea2d2/sdks/python/apache_beam/runners/worker/operation_specs.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/worker/operation_specs.py b/sdks/python/apache_beam/runners/worker/operation_specs.py
index b8d19a1..bdafbea 100644
--- a/sdks/python/apache_beam/runners/worker/operation_specs.py
+++ b/sdks/python/apache_beam/runners/worker/operation_specs.py
@@ -326,11 +326,12 @@ def get_coder_from_spec(coder_spec):
     assert len(coder_spec['component_encodings']) == 2
     value_coder, window_coder = [
         get_coder_from_spec(c) for c in coder_spec['component_encodings']]
-    return coders.WindowedValueCoder(value_coder, window_coder=window_coder)
+    return coders.coders.WindowedValueCoder(
+        value_coder, window_coder=window_coder)
   elif coder_spec['@type'] == 'kind:interval_window':
     assert ('component_encodings' not in coder_spec
             or not coder_spec['component_encodings'])
-    return coders.IntervalWindowCoder()
+    return coders.coders.IntervalWindowCoder()
   elif coder_spec['@type'] == 'kind:global_window':
     assert ('component_encodings' not in coder_spec
             or not coder_spec['component_encodings'])


Mime
View raw message