[BEAM-2556] Add client-side throttling. This closes #3507
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a22f1a05 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a22f1a05 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a22f1a05 Branch: refs/heads/master Commit: a22f1a05a2d4d4ff643a7cb175542a635a8b8c02 Parents: 138641f 435cbcf Author: Luke Cwik <lc...@google.com> Authored: Tue Jul 11 09:40:16 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Tue Jul 11 09:40:16 2017 -0700 ---------------------------------------------------------------------- .../sdk/io/gcp/datastore/AdaptiveThrottler.java | 103 +++++++++++++++++ .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 25 ++++- .../io/gcp/datastore/AdaptiveThrottlerTest.java | 111 +++++++++++++++++++ 3 files changed, 238 insertions(+), 1 deletion(-) ----------------------------------------------------------------------