Closes #1100
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8e1793ca Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8e1793ca Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8e1793ca Branch: refs/heads/python-sdk Commit: 8e1793cafa1839456ae007937bc581764749a006 Parents: 6e6d89d cf15ab5 Author: Robert Bradshaw <[email protected]> Authored: Tue Oct 18 13:12:56 2016 -0700 Committer: Robert Bradshaw <[email protected]> Committed: Tue Oct 18 13:12:56 2016 -0700 ---------------------------------------------------------------------- .../examples/cookbook/bigquery_side_input.py | 3 +- sdks/python/apache_beam/pvalue.py | 44 ++++++-- sdks/python/apache_beam/runners/common.pxd | 1 + sdks/python/apache_beam/runners/common.py | 51 +++++++-- .../python/apache_beam/runners/direct_runner.py | 30 +----- .../inprocess/inprocess_evaluation_context.py | 29 +---- .../python/apache_beam/transforms/sideinputs.py | 75 +++++++++++-- .../apache_beam/transforms/sideinputs_test.py | 105 +++++++++++++++++-- sdks/python/apache_beam/transforms/timeutil.py | 4 + sdks/python/apache_beam/transforms/util.py | 5 +- sdks/python/apache_beam/transforms/window.py | 3 + .../transforms/write_ptransform_test.py | 2 +- 12 files changed, 258 insertions(+), 94 deletions(-) ----------------------------------------------------------------------
