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/06/08 20:58:49 UTC
[1/2] beam git commit: Closes #3325
Repository: beam
Updated Branches:
refs/heads/master 4aef93854 -> 7c5a70edb
Closes #3325
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c5a70ed
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c5a70ed
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7c5a70ed
Branch: refs/heads/master
Commit: 7c5a70edb2d19f22b0a6b81ae516762703358986
Parents: 4aef938 36aea2d
Author: Robert Bradshaw <ro...@google.com>
Authored: Thu Jun 8 13:58:31 2017 -0700
Committer: Robert Bradshaw <ro...@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(-)
----------------------------------------------------------------------
[2/2] beam git commit: Use inner module for non-public coders.
Posted by ro...@apache.org.
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 <ro...@gmail.com>
Authored: Wed Jun 7 23:35:11 2017 -0700
Committer: Robert Bradshaw <ro...@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'])