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 <rober...@gmail.com> Authored: Sat Jan 21 20:52:02 2017 -0800 Committer: Robert Bradshaw <rober...@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)