format change only
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/e5b97304 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/e5b97304 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/e5b97304 Branch: refs/heads/master Commit: e5b97304ebe2dcccce32ea18c7d7994130ca5738 Parents: be9bcb0 Author: Dave Johnson <[email protected]> Authored: Thu Nov 19 15:29:39 2015 -0500 Committer: Dave Johnson <[email protected]> Committed: Thu Nov 19 15:29:39 2015 -0500 ---------------------------------------------------------------------- .../corepersistence/asyncevents/EventBuilderImpl.java | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/e5b97304/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 48df8d0..d624132 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 @@ -131,8 +131,7 @@ public class EventBuilderImpl implements EventBuilder { //TODO USERGRID-1123: Implement so we don't iterate logs twice (latest DELETED version, then to get all DELETED) MvccLogEntry mostRecentlyMarked = ecm.getVersions( entityId ).toBlocking() - .firstOrDefault( null, - mvccLogEntry -> mvccLogEntry.getState() == MvccLogEntry.State.DELETED ); + .firstOrDefault( null, mvccLogEntry -> mvccLogEntry.getState() == MvccLogEntry.State.DELETED ); // De-indexing and entity deletes don't check log entiries. We must do that first. If no DELETED logs, then // return an empty observable as our no-op. @@ -145,14 +144,12 @@ public class EventBuilderImpl implements EventBuilder { ecmDeleteObservable = ecm.getVersions( entityId ) - .filter( mvccLogEntry-> UUIDUtils.compare(mvccLogEntry.getVersion(), mostRecentlyMarked.getVersion()) <= 0) + .filter( mvccLogEntry-> + UUIDUtils.compare(mvccLogEntry.getVersion(), mostRecentlyMarked.getVersion()) <= 0) .buffer( serializationFig.getBufferSize() ) .doOnNext( buffer -> ecm.delete( buffer ) ); - - } - // Graph compaction checks the versions inside compactNode, just build this up for the caller to subscribe to final Observable<Id> graphCompactObservable = gm.compactNode(entityId);
