This closes #2948: [BEAM-991] Comply with byte limit for Datastore Commit.
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9a6baefc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9a6baefc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9a6baefc Branch: refs/heads/master Commit: 9a6baefcd8668b145e86140f64b9d18c1c21890c Parents: ce00d24 dcf4056 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Fri May 19 13:11:50 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Fri May 19 13:11:50 2017 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 17 +++++++++ .../sdk/io/gcp/datastore/DatastoreV1Test.java | 36 ++++++++++++++++++++ .../beam/sdk/io/gcp/datastore/V1ReadIT.java | 2 +- .../beam/sdk/io/gcp/datastore/V1TestUtil.java | 15 ++++++-- .../beam/sdk/io/gcp/datastore/V1WriteIT.java | 36 ++++++++++++++++++-- 5 files changed, 100 insertions(+), 6 deletions(-) ----------------------------------------------------------------------
