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/master Commit: 36aea2d26d7c8ea3299d7a25d617a6ba99794e18 Parents: 4aef938 Author: Robert Bradshaw <[email protected]> Authored: Wed Jun 7 23:35:11 2017 -0700 Committer: Robert Bradshaw <[email protected]> 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'])
