Add profiling information on each traversal step - count hits vs elastic controller

Add tagging for each step via ASG strategy (all steps must have tags)

Author: YANG-DB

fuse-asg/src/main/java/com/yangdb/fuse/asg/AsgQueryTransformer.java

@@ -59,7 +59,8 @@ public AsgQuery transform(AsgQuery query) {
         }
 
         AsgStrategyContext asgStrategyContext =  new AsgStrategyContext(new Ontology.Accessor(ontology.get()));
-        Stream.ofAll(this.asgStrategies).forEach(strategy -> strategy.apply(query,asgStrategyContext));
+        Stream.ofAll(this.asgStrategies)
+                .forEach(strategy -> strategy.apply(query,asgStrategyContext));
 
         return query;
     }

fuse-asg/src/main/java/com/yangdb/fuse/asg/strategy/propertyGrouping/Quant1AllQuantGroupingAsgStrategy.java

@@ -43,15 +43,13 @@ public void apply(AsgQuery query, AsgStrategyContext context) {
         while(hasWorkToDo.get()) {
             hasWorkToDo.set(false);
 
-            AsgQueryUtil.<Quant1>elements(query, Quant1.class).forEach(quant -> {
+            AsgQueryUtil.elements(query, Quant1.class).forEach(quant -> {
                 if (quant.geteBase().getqType().equals(QuantType.all)) {
                     AsgQueryUtil.<Quant1, Quant1>nextAdjacentDescendants(quant, Quant1.class).forEach(childQuant -> {
                         if (childQuant.geteBase().getqType().equals(QuantType.all)) {
                             hasWorkToDo.set(true);
-
-                            List<AsgEBase<? extends EBase>> nextChildren = childQuant.getNext();
-                            nextChildren.forEach(childQuant::removeNextChild);
-                            nextChildren.forEach(quant::addNextChild);
+                            AsgQueryUtil.replaceParents(quant,childQuant);
+                            AsgQueryUtil.remove(query,childQuant);
                         }
                     });
                 }

fuse-dv/fuse-dv-asg/src/main/java/com/yangdb/fuse/asg/strategy/schema/ExactConstraintTransformationAsgStrategy.java

@@ -40,12 +40,10 @@
 import javaslang.collection.Stream;
 
 import java.util.ArrayList;
-import java.util.Collections;
 import java.util.Optional;
 import java.util.Set;
 
 import static com.yangdb.fuse.unipop.schemaProviders.GraphElementPropertySchema.IndexingSchema.Type.exact;
-import static java.util.Collections.unmodifiableList;
 
 /**
  * Created by roman.margolis on 08/02/2018.

fuse-model/src/main/java/com/yangdb/fuse/model/asgQuery/AsgEBase.java

@@ -48,7 +48,10 @@
 import com.yangdb.fuse.model.Next;
 import com.yangdb.fuse.model.query.EBase;
 
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 /**
@@ -147,7 +150,7 @@ public AsgEBase<T> clone(int eNum) {
 
     //region Properties
     public List<AsgEBase<? extends EBase>> getNext() {
-        return Collections.unmodifiableList(this.next);
+        return this.next;
     }
 
     public AsgEBase<? extends EBase> addNext(AsgEBase<? extends EBase> node) {
@@ -174,7 +177,7 @@ public void setNext(List<AsgEBase<? extends EBase>> next) {
     }
 
     public List<AsgEBase<? extends EBase>> getB() {
-        return Collections.unmodifiableList(this.b);
+        return this.b;
     }
 
     public T geteBase() {
@@ -196,7 +199,7 @@ public void setParent(List<AsgEBase<? extends EBase>> parent) {
     @JsonIgnore
     @JsonIgnoreProperties
     public List<AsgEBase<? extends EBase>> getParents() {
-        return Collections.unmodifiableList(this.parent);
+        return this.parent;
     }
 
     public int geteNum() {

fuse-model/src/main/java/com/yangdb/fuse/model/asgQuery/AsgQueryUtil.java

@@ -822,6 +822,19 @@ public static void replace(AsgEBase source, AsgEBase target) {
         target.setNext(next);
     }
 
+    /**
+     * replace the targets parent with the new given one
+     * @param newParent
+     * @param oldParent
+     */
+    public static void replaceParents(AsgEBase newParent,AsgEBase oldParent) {
+        //assuming single parent strategy
+        List<AsgEBase<? extends EBase>> next = new ArrayList<>(oldParent.getNext());
+        next.forEach(oldParent::removeNextChild);
+        next.forEach(newParent::addNextChild);
+
+    }
+
 
     public static int count(AsgEBase<? extends EBase> asgEBase, Class<? extends EBase> aClass) {
         return elements(asgEBase, classPredicateFunction.apply(aClass)).size();
@@ -1107,12 +1120,17 @@ private static <T> List<T> values(
 
     public static  <T extends EBase> Optional<AsgEBase<T>> calculateNextAncestor(AsgEBase<? extends EBase> eProp, Class<T> clazz) {
         final List<AsgEBase<? extends EBase>> path = AsgQueryUtil.pathToAncestor(eProp, clazz);
+        if(path.isEmpty()) return Optional.empty();
+        return Optional.of((AsgEBase<T>) path.get(path.size()-1));
+
+/*
         Optional<AsgEBase<T>> element = Optional.empty();
         if(!path.isEmpty() && path.size()==2)
             element = Optional.of((AsgEBase<T>) path.get(1));
         if(!path.isEmpty() && path.size()==3 && QuantBase.class.isAssignableFrom(path.get(1).geteBase().getClass()))
             element = Optional.of((AsgEBase<T>) path.get(2));
         return element;
+*/
     }
 
     public static List<AsgEBase<? extends EBase>> path(