[BEAM-698] This closes #1054
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8130bc36 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8130bc36 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8130bc36 Branch: refs/heads/master Commit: 8130bc36feca77737a4e171e14307f53410201c7 Parents: f27354f 26474c7 Author: Jean-Baptiste Onofré <jbono...@apache.org> Authored: Thu Oct 6 14:02:34 2016 +0200 Committer: Jean-Baptiste Onofré <jbono...@apache.org> Committed: Thu Oct 6 14:02:34 2016 +0200 ---------------------------------------------------------------------- .../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 197 ++++++++++--------- .../apache/beam/sdk/io/mongodb/MongoDbIO.java | 20 +- .../sdk/io/mongodb/MongoDBGridFSIOTest.java | 13 +- 3 files changed, 117 insertions(+), 113 deletions(-) ----------------------------------------------------------------------