You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/06/23 03:04:57 UTC
[31/50] beam git commit: [BEAM-2439] Dynamic sizing of Datastore
write RPCs
[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/gearpump-runner
Commit: 9ed0af8f2c5dabf3af5d664c473a49166b96d7d2
Parents: 3dc454a 0292a24
Author: Luke Cwik <lc...@google.com>
Authored: Thu Jun 22 13:34:12 2017 -0700
Committer: Luke Cwik <lc...@google.com>
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(-)
----------------------------------------------------------------------