This closes #1398
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9b9d016c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9b9d016c Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9b9d016c Branch: refs/heads/python-sdk Commit: 9b9d016c80b9a7e73a7485d3e579ead3ada18ac6 Parents: 21f9c6d 2b69cce Author: Davor Bonaci <[email protected]> Authored: Wed Nov 23 10:42:17 2016 -0800 Committer: Davor Bonaci <[email protected]> Committed: Wed Nov 23 10:42:17 2016 -0800 ---------------------------------------------------------------------- .../apache_beam/examples/datastore_wordcount.py | 118 ++++++++ .../apache_beam/io/datastore/v1/datastoreio.py | 287 +++++++++++++++++++ .../io/datastore/v1/datastoreio_test.py | 172 +++++++++++ .../io/datastore/v1/fake_datastore.py | 75 +++++ .../apache_beam/io/datastore/v1/helper.py | 152 ++++++++++ .../apache_beam/io/datastore/v1/helper_test.py | 125 +++++++- .../io/datastore/v1/query_splitter_test.py | 62 +--- 7 files changed, 930 insertions(+), 61 deletions(-) ----------------------------------------------------------------------
