This closes #3585
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c8e3744a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c8e3744a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c8e3744a Branch: refs/heads/DSL_SQL Commit: c8e3744adc6dfdfcfd32221bbbd05ed5b2511c81 Parents: 2e51bde 0a5157e Author: chamik...@google.com <chamik...@google.com> Authored: Thu Jul 20 10:18:55 2017 -0700 Committer: chamik...@google.com <chamik...@google.com> Committed: Thu Jul 20 10:18:55 2017 -0700 ---------------------------------------------------------------------- .../io/gcp/datastore/v1/datastoreio.py | 84 ++++++++++++++--- .../io/gcp/datastore/v1/datastoreio_test.py | 53 +++++++++-- .../apache_beam/io/gcp/datastore/v1/helper.py | 35 ++++++-- .../apache_beam/io/gcp/datastore/v1/util.py | 95 ++++++++++++++++++++ .../io/gcp/datastore/v1/util_test.py | 67 ++++++++++++++ 5 files changed, 310 insertions(+), 24 deletions(-) ----------------------------------------------------------------------
