This closes #3644
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d0deb6cc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d0deb6cc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d0deb6cc Branch: refs/heads/master Commit: d0deb6cc821b95aa19484a9bfc94abdace1616bd Parents: 724eda3 06bd00c Author: [email protected] <[email protected]> Authored: Wed Aug 16 10:54:05 2017 -0700 Committer: [email protected] <[email protected]> Committed: Wed Aug 16 10:54:05 2017 -0700 ---------------------------------------------------------------------- .../io/gcp/datastore/v1/adaptive_throttler.py | 90 +++++++++++++++++++ .../gcp/datastore/v1/adaptive_throttler_test.py | 94 ++++++++++++++++++++ .../io/gcp/datastore/v1/datastoreio.py | 16 +++- .../apache_beam/io/gcp/datastore/v1/helper.py | 20 ++++- 4 files changed, 212 insertions(+), 8 deletions(-) ----------------------------------------------------------------------
