Added version verification.
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/be2113c7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/be2113c7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/be2113c7 Branch: refs/heads/USERGRID-669 Commit: be2113c7a7636b3227aff2af6f69d5a87ec24754 Parents: 14a1def Author: GERey <[email protected]> Authored: Tue May 26 12:35:28 2015 -0700 Committer: GERey <[email protected]> Committed: Tue May 26 12:35:28 2015 -0700 ---------------------------------------------------------------------- .../persistence/index/impl/EsApplicationEntityIndexImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/be2113c7/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java index 347a7b9..e1dd2bb 100644 --- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java +++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsApplicationEntityIndexImpl.java @@ -222,7 +222,7 @@ public class EsApplicationEntityIndexImpl implements ApplicationEntityIndex { //The settings for the scroll aren't tested and so we aren't sure what vlaues would be best in a production enviroment //TODO: review this and make them not magic numbers when acking this PR. searchResponse = srb.setScroll( new TimeValue( 6000 ) ).setSize( 100 ).execute().actionGet(); - + while(true){ //add search result hits to some sort of running tally of hits. @@ -263,8 +263,8 @@ public class EsApplicationEntityIndexImpl implements ApplicationEntityIndex { public CandidateResults getAllEntityVersionsBeforeMarkedVersion( final Id entityId, final UUID markedVersion ) { Preconditions.checkNotNull( entityId, "entityId cannot be null" ); - //TODO: check to see if there is some version verifcation. I know there is but i forget where. Preconditions.checkNotNull( markedVersion, "markedVersion cannot be null" ); + ValidationUtils.verifyVersion( markedVersion ); SearchResponse searchResponse;
