if(entityType.isPresent()) --> never gets into this path for getting connections. hence removing it.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/4531adfc Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/4531adfc Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/4531adfc Branch: refs/heads/datastax-cass-driver Commit: 4531adfcd802df01d3382c6a2dae413d359fc253 Parents: 1a83bfc Author: Ayesha Dastagiri <[email protected]> Authored: Fri Aug 12 09:40:41 2016 -0700 Committer: Ayesha Dastagiri <[email protected]> Committed: Fri Aug 12 09:40:41 2016 -0700 ---------------------------------------------------------------------- .../corepersistence/pipeline/builder/IdBuilder.java | 11 +---------- 1 file changed, 1 insertion(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/4531adfc/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/builder/IdBuilder.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/builder/IdBuilder.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/builder/IdBuilder.java index b7d1f86..85e9069 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/builder/IdBuilder.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/pipeline/builder/IdBuilder.java @@ -72,17 +72,8 @@ public class IdBuilder { * @return */ public IdBuilder traverseReverseConnection( final String connectionName, final Optional<String> entityType ) { - final PipelineOperation<FilterResult<Id>, FilterResult<Id>> filter; - - if(entityType.isPresent()){ - //todo: change this too. - filter = filterFactory.readGraphConnectionByTypeFilter( connectionName, entityType.get() ); - }else{ - filter = filterFactory.readGraphReverseConnectionFilter( connectionName ); - } - - + filter = filterFactory.readGraphReverseConnectionFilter( connectionName ); return new IdBuilder( pipeline.withFilter(filter ), filterFactory ); }
