Cherry pick #3093: [BEAM-2256] Add the last previous range filter This closes #3100
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/cf1ce7b2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/cf1ce7b2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/cf1ce7b2 Branch: refs/heads/release-2.0.0 Commit: cf1ce7b247f68a238022b17fb5ae34cec4aca24b Parents: 74bcc02 d0960c6 Author: Luke Cwik <[email protected]> Authored: Thu May 11 15:16:43 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Thu May 11 15:16:43 2017 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/mongodb/MongoDbIO.java | 47 ++++++++++++++------ .../beam/sdk/io/mongodb/MongoDbIOTest.java | 18 ++++++++ 2 files changed, 52 insertions(+), 13 deletions(-) ----------------------------------------------------------------------
