Update filter to allow removal of all entities older than the last marked version.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/faa234a8 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/faa234a8 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/faa234a8 Branch: refs/heads/master Commit: faa234a85f1526a17a6f7d3049a7cb0820816190 Parents: 88f6fea Author: Michael Russo <[email protected]> Authored: Thu Nov 19 10:51:22 2015 -0800 Committer: Michael Russo <[email protected]> Committed: Thu Nov 19 10:51:22 2015 -0800 ---------------------------------------------------------------------- .../usergrid/corepersistence/asyncevents/EventBuilderImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/faa234a8/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java index 9b68c4c..f7f7ba3 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/EventBuilderImpl.java @@ -144,7 +144,7 @@ public class EventBuilderImpl implements EventBuilder { ecmDeleteObservable = ecm.getVersions( entityId ) - .filter( mvccLogEntry-> mvccLogEntry.getState() == MvccLogEntry.State.DELETED) + .filter( mvccLogEntry-> mvccLogEntry.getVersion().timestamp() <= mostRecentlyMarked.getVersion().timestamp()) .buffer( serializationFig.getBufferSize() ) .doOnNext( buffer -> ecm.delete( buffer ) );
