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/01/23 17:49:20 UTC
[1/2] beam git commit: Add some typing to prevent speed regression
for old_dofn.
Repository: beam
Updated Branches:
refs/heads/python-sdk d0474ab5b -> 894461e64
Add some typing to prevent speed regression for old_dofn.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f68c9dc8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f68c9dc8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f68c9dc8
Branch: refs/heads/python-sdk
Commit: f68c9dc8d17881c43c31922375fec9593265cc5d
Parents: d0474ab
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Sat Jan 21 20:52:02 2017 -0800
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Sat Jan 21 20:52:02 2017 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/runners/common.pxd | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/f68c9dc8/sdks/python/apache_beam/runners/common.pxd
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/runners/common.pxd b/sdks/python/apache_beam/runners/common.pxd
index 06fe434..10d1f96 100644
--- a/sdks/python/apache_beam/runners/common.pxd
+++ b/sdks/python/apache_beam/runners/common.pxd
@@ -36,15 +36,17 @@ cdef class DoFnRunner(Receiver):
cdef object tagged_receivers
cdef LoggingContext logging_context
cdef object step_name
- cdef object is_new_dofn
+ cdef bint is_new_dofn
cdef object args
- cdef object kwargs
+ cdef dict kwargs
cdef object side_inputs
cdef bint has_windowed_side_inputs
cdef Receiver main_receivers
cpdef process(self, WindowedValue element)
+ cdef old_dofn_process(self, WindowedValue element)
+ cdef new_dofn_process(self, WindowedValue element)
@cython.locals(windowed_value=WindowedValue)
cpdef _process_outputs(self, WindowedValue element, results)
[2/2] beam git commit: Closes #1810
Posted by ro...@apache.org.
Closes #1810
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/894461e6
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/894461e6
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/894461e6
Branch: refs/heads/python-sdk
Commit: 894461e64b09e6d719ba3eef282cd36cea550f7b
Parents: d0474ab f68c9dc
Author: Robert Bradshaw <ro...@google.com>
Authored: Mon Jan 23 09:48:55 2017 -0800
Committer: Robert Bradshaw <ro...@google.com>
Committed: Mon Jan 23 09:48:55 2017 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/runners/common.pxd | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------