[BEAM-2439] Dynamic sizing of Datastore write RPCs This closes #3390
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9ed0af8f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9ed0af8f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9ed0af8f Branch: refs/heads/master Commit: 9ed0af8f2c5dabf3af5d664c473a49166b96d7d2 Parents: 3dc454a 0292a24 Author: Luke Cwik <[email protected]> Authored: Thu Jun 22 13:34:12 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Thu Jun 22 13:34:12 2017 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 124 ++++++++++++++++--- .../sdk/io/gcp/datastore/MovingAverage.java | 50 ++++++++ .../sdk/io/gcp/datastore/DatastoreV1Test.java | 72 ++++++++++- 3 files changed, 225 insertions(+), 21 deletions(-) ----------------------------------------------------------------------
