Repository: incubator-beam Updated Branches: refs/heads/python-sdk 3dbeb8edf -> 1530a1727
Closes #1433 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1530a172 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1530a172 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1530a172 Branch: refs/heads/python-sdk Commit: 1530a17279d098ae7459f689ef02401f5116e54e Parents: 3dbeb8e d46203b Author: Dan Halperin <dhalp...@google.com> Authored: Mon Nov 28 15:54:27 2016 -0800 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon Nov 28 15:54:27 2016 -0800 ---------------------------------------------------------------------- .../apache_beam/examples/datastore_wordcount.py | 137 +++++++++++++++---- .../apache_beam/io/datastore/v1/datastoreio.py | 104 +++++++++++++- .../io/datastore/v1/datastoreio_test.py | 46 +++++++ .../io/datastore/v1/fake_datastore.py | 17 +++ .../apache_beam/io/datastore/v1/helper.py | 35 ++++- .../apache_beam/io/datastore/v1/helper_test.py | 36 +++++ .../io/datastore/v1/query_splitter.py | 7 +- 7 files changed, 349 insertions(+), 33 deletions(-) ----------------------------------------------------------------------