AMBARI-2254 - reverting merge

git-svn-id: https://svn.apache.org/repos/asf/incubator/ambari/trunk@1489363 13f79535-47bb-0310-9956-ffa450edef68

ambari-server/src/main/java/org/apache/ambari/server/api/query/QueryImpl.java

@@ -0,0 +1,356 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ambari.server.api.query;
+
+import org.apache.ambari.server.api.resources.ResourceInstance;
+import org.apache.ambari.server.api.services.ResultImpl;
+import org.apache.ambari.server.controller.utilities.ClusterControllerHelper;
+import org.apache.ambari.server.controller.utilities.PropertyHelper;
+import org.apache.ambari.server.controller.predicate.AndPredicate;
+import org.apache.ambari.server.controller.predicate.EqualsPredicate;
+import org.apache.ambari.server.api.services.Result;
+import org.apache.ambari.server.controller.spi.*;
+import org.apache.ambari.server.api.util.TreeNode;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.*;
+
+/**
+ * Default read query.
+ */
+public class QueryImpl implements Query {
+
+  /**
+   * Resource instance.
+   */
+  private ResourceInstance m_resource;
+
+  /**
+   * Properties of the query which make up the select portion of the query.
+   */
+  private Set<String> m_setQueryProperties = new HashSet<String>();
+
+  /**
+   * Indicates that the query should include all available properties.
+   */
+  private boolean allProperties = false;
+
+  /**
+   * Map that associates each property set on the query to temporal data.
+   */
+  private Map<String, TemporalInfo> m_mapPropertyTemporalInfo = new HashMap<String, TemporalInfo>();
+
+  /**
+   * Map that associates categories with temporal data.
+   */
+  private Map<String, TemporalInfo> m_mapCategoryTemporalInfo = new HashMap<String, TemporalInfo>();
+
+  /**
+   * Sub-resources of the resource which is being operated on.
+   */
+  private Map<String, ResourceInstance> m_mapSubResources = new HashMap<String, ResourceInstance>();
+
+  /**
+   * The user supplied predicate.
+   */
+  private Predicate m_userPredicate;
+
+  /**
+   * The logger.
+   */
+  private final static Logger LOG =
+      LoggerFactory.getLogger(QueryImpl.class);
+
+  /**
+   * Constructor.
+   *
+   * @param resource the resource being operated on
+   */
+  public QueryImpl(ResourceInstance resource) {
+    m_resource = resource;
+  }
+
+  @Override
+  public void addProperty(String category, String name, TemporalInfo temporalInfo) {
+    if (category == null && name.equals("*")) {
+      // wildcard
+      addAllProperties(temporalInfo);
+    } else{
+      if (addPropertyToSubResource(category, name, temporalInfo)){
+        // add pk/fk properties of the resource to this query
+        Resource.Type resourceType = m_resource.getResourceDefinition().getType();
+        Schema        schema       = getClusterController().getSchema(resourceType);
+
+        for (Resource.Type type : m_resource.getIds().keySet()) {
+          addLocalProperty(schema.getKeyPropertyId(type));
+        }
+      } else {
+        String propertyId = PropertyHelper.getPropertyId(category, name.equals("*") ? null : name);
+        addLocalProperty(propertyId);
+        if (temporalInfo != null) {
+          m_mapCategoryTemporalInfo.put(propertyId, temporalInfo);
+        }
+      }
+    }
+  }
+
+  @Override
+  public void addLocalProperty(String property) {
+    m_setQueryProperties.add(property);
+  }
+
+  @Override
+  public Result execute()
+      throws UnsupportedPropertyException, SystemException, NoSuchResourceException, NoSuchParentResourceException {
+
+    Result result = createResult();
+    Resource.Type resourceType = m_resource.getResourceDefinition().getType();
+    if (m_resource.getIds().get(resourceType) == null) {
+      addCollectionProperties(resourceType);
+      result.getResultTree().setProperty("isCollection", "true");
+    }
+
+    if (m_setQueryProperties.isEmpty() && m_mapSubResources.isEmpty()) {
+      //Add sub resource properties for default case where no fields are specified.
+      m_mapSubResources.putAll(m_resource.getSubResources());
+    }
+
+    if (LOG.isDebugEnabled()) {
+      //todo: include predicate info.  Need to implement toString for all predicates.
+      LOG.debug("Executing resource query: " + m_resource.getIds());
+    }
+
+    Predicate predicate = createPredicate(m_resource);
+    Iterable<Resource> iterResource = getClusterController().getResources(
+        resourceType, createRequest(), predicate);
+
+    TreeNode<Resource> tree = result.getResultTree();
+    int count = 1;
+    for (Resource resource : iterResource) {
+      // add a child node for the resource and provide a unique name.  The name is never used.
+      //todo: provide a more meaningful node name
+      TreeNode<Resource> node = tree.addChild(resource, resource.getType() + ":" + count++);
+      for (Map.Entry<String, ResourceInstance> entry : m_mapSubResources.entrySet()) {
+        String subResCategory = entry.getKey();
+        ResourceInstance r = entry.getValue();
+
+        setParentIdsOnSubResource(resource, r);
+
+        TreeNode<Resource> childResult = r.getQuery().execute().getResultTree();
+        childResult.setName(subResCategory);
+        childResult.setProperty("isCollection", "false");
+        node.addChild(childResult);
+      }
+    }
+    return result;
+  }
+
+  @Override
+  public Predicate getPredicate() {
+    //todo: create predicate once
+    return createPredicate(m_resource);
+  }
+
+  @Override
+  public Set<String> getProperties() {
+    return Collections.unmodifiableSet(m_setQueryProperties);
+  }
+
+  @Override
+  public void setUserPredicate(Predicate predicate) {
+    m_userPredicate = predicate;
+  }
+
+  ClusterController getClusterController() {
+    return ClusterControllerHelper.getClusterController();
+  }
+
+  private void addCollectionProperties(Resource.Type resourceType) {
+    Schema schema = getClusterController().getSchema(resourceType);
+    // add pk
+    String property = schema.getKeyPropertyId(resourceType);
+    addProperty(PropertyHelper.getPropertyCategory(property), PropertyHelper.getPropertyName(property), null);
+
+    for (Resource.Type type : m_resource.getIds().keySet()) {
+      // add fk's
+      String keyPropertyId = schema.getKeyPropertyId(type);
+      //todo: property id can be null in some cases such as host_component queries which obtain
+      //todo: component sub-resources.  Component will not have host fk.
+      //todo: refactor so that null check is not required.
+      if (keyPropertyId != null) {
+        addProperty(PropertyHelper.getPropertyCategory(keyPropertyId), PropertyHelper.getPropertyName(keyPropertyId), null);
+      }
+    }
+  }
+
+  private void addAllProperties(TemporalInfo temporalInfo) {
+    allProperties = true;
+    if (temporalInfo != null) {
+      m_mapCategoryTemporalInfo.put(null, temporalInfo);
+    }
+
+    for (Map.Entry<String, ResourceInstance> entry : m_resource.getSubResources().entrySet()) {
+      String name = entry.getKey();
+      if (! m_mapSubResources.containsKey(name)) {
+        m_mapSubResources.put(name, entry.getValue());
+      }
+    }
+  }
+
+  private boolean addPropertyToSubResource(String path, String property, TemporalInfo temporalInfo) {
+    // cases:
+    // - path is null, property is path (all sub-resource props will have a path)
+    // - path is single token and prop in non null
+    //      (path only will presented as above case with property only)
+    // - path is multi level and prop is non null
+
+    boolean resourceAdded = false;
+    if (path == null) {
+      path = property;
+      property = null;
+    }
+
+    int i = path.indexOf("/");
+    String p = i == -1 ? path : path.substring(0, i);
+
+    ResourceInstance subResource = m_resource.getSubResources().get(p);
+    if (subResource != null) {
+      m_mapSubResources.put(p, subResource);
+      //todo: handle case of trailing '/' (for example fields=subResource/)
+
+      if (property != null || !path.equals(p)) {
+        //only add if a sub property is set or if a sub category is specified
+        subResource.getQuery().addProperty(i == -1 ? null : path.substring(i + 1), property, temporalInfo);
+      }
+      resourceAdded = true;
+    }
+    return resourceAdded;
+  }
+
+  private Predicate createInternalPredicate(ResourceInstance resource) {
+    Resource.Type resourceType = resource.getResourceDefinition().getType();
+    Map<Resource.Type, String> mapResourceIds = resource.getIds();
+    Schema schema = getClusterController().getSchema(resourceType);
+
+    Set<Predicate> setPredicates = new HashSet<Predicate>();
+    for (Map.Entry<Resource.Type, String> entry : mapResourceIds.entrySet()) {
+      if (entry.getValue() != null) {
+        String keyPropertyId = schema.getKeyPropertyId(entry.getKey());
+        if (keyPropertyId != null) {
+          setPredicates.add(new EqualsPredicate<String>(keyPropertyId, entry.getValue()));
+        }
+      }
+    }
+
+    if (setPredicates.size() == 1) {
+      return setPredicates.iterator().next();
+    } else if (setPredicates.size() > 1) {
+      return new AndPredicate(setPredicates.toArray(new Predicate[setPredicates.size()]));
+    } else {
+      return null;
+    }
+  }
+
+  private Predicate createPredicate(ResourceInstance resource) {
+    Predicate predicate = null;
+    //todo: change reference type to Predicate when predicate hierarchy is fixed
+    Predicate internalPredicate = createInternalPredicate(resource);
+    if (internalPredicate == null) {
+      if (m_userPredicate != null) {
+        predicate = m_userPredicate;
+      }
+    } else {
+      predicate = (m_userPredicate == null ? internalPredicate :
+          new AndPredicate(m_userPredicate, internalPredicate));
+    }
+    return predicate;
+  }
+
+  private Request createRequest() {
+    Set<String> setProperties = new HashSet<String>();
+
+    Map<String, TemporalInfo> mapTemporalInfo    = new HashMap<String, TemporalInfo>();
+    TemporalInfo              globalTemporalInfo = m_mapCategoryTemporalInfo.get(null);
+
+    for (String group : m_setQueryProperties) {
+      TemporalInfo temporalInfo = m_mapCategoryTemporalInfo.get(group);
+      if (temporalInfo != null) {
+        mapTemporalInfo.put(group, temporalInfo);
+      } else if (globalTemporalInfo != null) {
+        mapTemporalInfo.put(group, globalTemporalInfo);
+      }
+      setProperties.add(group);
+    }
+
+    return PropertyHelper.getReadRequest(allProperties ? Collections.<String>emptySet() : setProperties, mapTemporalInfo);
+  }
+
+  private void setParentIdsOnSubResource(Resource resource, ResourceInstance r) {
+    Map<Resource.Type, String> mapParentIds = m_resource.getIds();
+    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>(mapParentIds.size());
+    for (Map.Entry<Resource.Type, String> resourceIdEntry : mapParentIds.entrySet()) {
+      Resource.Type type = resourceIdEntry.getKey();
+      String value = resourceIdEntry.getValue();
+
+      if (value == null) {
+        Object o = resource.getPropertyValue(getClusterController().getSchema(type).getKeyPropertyId(type));
+        value = o == null ? null : o.toString();
+      }
+      if (value != null) {
+        mapResourceIds.put(type, value);
+      }
+    }
+    String resourceKeyProp = getClusterController().getSchema(resource.getType()).
+        getKeyPropertyId(resource.getType());
+    //todo: shouldn't use toString here
+    mapResourceIds.put(resource.getType(), resource.getPropertyValue(resourceKeyProp).toString());
+    r.setIds(mapResourceIds);
+  }
+
+  Result createResult() {
+    return new ResultImpl(true);
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) return true;
+    if (o == null || getClass() != o.getClass()) return false;
+
+    QueryImpl that = (QueryImpl) o;
+
+    return m_mapCategoryTemporalInfo.equals(that.m_mapCategoryTemporalInfo) &&
+           m_mapPropertyTemporalInfo.equals(that.m_mapPropertyTemporalInfo) &&
+           m_setQueryProperties.equals(that.m_setQueryProperties) &&
+           m_mapSubResources.equals(that.m_mapSubResources) &&
+           m_resource.equals(that.m_resource) &&
+           m_userPredicate == null ? that.m_userPredicate == null : m_userPredicate.equals(that.m_userPredicate);
+  }
+
+  @Override
+  public int hashCode() {
+    int result = m_resource.hashCode();
+    result = 31 * result + m_setQueryProperties.hashCode();
+    result = 31 * result + m_mapPropertyTemporalInfo.hashCode();
+    result = 31 * result + m_mapCategoryTemporalInfo.hashCode();
+    result = 31 * result + m_mapSubResources.hashCode();
+    result = 31 * result + (m_userPredicate != null ? m_userPredicate.hashCode() : 0);
+    return result;
+  }
+}

ambari-server/src/main/java/org/apache/ambari/server/api/resources/ResourceInstanceFactoryImpl.java

@@ -31,19 +31,12 @@ public class ResourceInstanceFactoryImpl implements ResourceInstanceFactory {
   @Override
   public ResourceInstance createResource(Resource.Type type, Map<Resource.Type, String> mapIds) {
 
-    return new ResourceInstanceImpl(mapIds, createResourceDefinition(type, mapIds));
-  }
+    /**
+     * The resource definition for the specified type.
+     */
+    ResourceDefinition resourceDefinition;
 
-  /**
-   * Create a resource definition for the specified type.
-   *
-   * @param type    the resource type
-   * @param mapIds  the ids
-   *
-   * @return the resource definition
-   */
-  protected static ResourceDefinition createResourceDefinition(Resource.Type type, Map<Resource.Type, String> mapIds) {
-    ResourceDefinition resourceDefinition;//todo: consider ResourceDependencyManager : Map<Resource.Type, ResourceDefinition>
+    //todo: consider ResourceDependencyManager : Map<Resource.Type, ResourceDefinition>
     switch (type) {
       case Cluster:
         resourceDefinition = new ClusterResourceDefinition();
@@ -59,7 +52,7 @@ public class ResourceInstanceFactoryImpl implements ResourceInstanceFactory {
         break;
 
       case Component:
-        resourceDefinition = new ComponentResourceDefinition();
+        resourceDefinition = new  ComponentResourceDefinition();
         break;
 
       case HostComponent:
@@ -89,27 +82,27 @@ public class ResourceInstanceFactoryImpl implements ResourceInstanceFactory {
       case Stack:
         resourceDefinition = new StackResourceDefinition();
         break;
-
+        
       case StackVersion:
         resourceDefinition = new StackVersionResourceDefinition();
         break;
-
+        
       case StackService:
         resourceDefinition = new StackServiceResourceDefinition();
         break;
-
+        
       case StackServiceComponent:
         resourceDefinition = new StackServiceComponentResourceDefinition();
         break;
-
+        
       case StackConfiguration:
         resourceDefinition = new StackConfigurationResourceDefinition();
         break;
-
+        
       case OperatingSystem:
         resourceDefinition = new OperatingSystemResourceDefinition();
         break;
-
+        
       case Repository:
         resourceDefinition = new RepositoryResourceDefinition();
         break;
@@ -141,6 +134,7 @@ public class ResourceInstanceFactoryImpl implements ResourceInstanceFactory {
       default:
         throw new IllegalArgumentException("Unsupported resource type: " + type);
     }
-    return resourceDefinition;
+
+    return new ResourceInstanceImpl(mapIds, resourceDefinition, this);
   }
 }

ambari-server/src/main/java/org/apache/ambari/server/api/resources/ResourceInstanceImpl.java

@@ -20,37 +20,24 @@
 package org.apache.ambari.server.api.resources;
 
 import org.apache.ambari.server.api.query.Query;
-import org.apache.ambari.server.api.services.Result;
-import org.apache.ambari.server.api.services.ResultImpl;
-import org.apache.ambari.server.api.util.TreeNode;
-import org.apache.ambari.server.controller.predicate.AndPredicate;
-import org.apache.ambari.server.controller.predicate.EqualsPredicate;
-import org.apache.ambari.server.controller.predicate.OrPredicate;
+import org.apache.ambari.server.api.query.QueryImpl;
 import org.apache.ambari.server.controller.spi.ClusterController;
-import org.apache.ambari.server.controller.spi.NoSuchParentResourceException;
-import org.apache.ambari.server.controller.spi.NoSuchResourceException;
-import org.apache.ambari.server.controller.spi.Predicate;
-import org.apache.ambari.server.controller.spi.Request;
 import org.apache.ambari.server.controller.spi.Resource;
-import org.apache.ambari.server.controller.spi.Schema;
-import org.apache.ambari.server.controller.spi.SystemException;
-import org.apache.ambari.server.controller.spi.TemporalInfo;
-import org.apache.ambari.server.controller.spi.UnsupportedPropertyException;
 import org.apache.ambari.server.controller.utilities.ClusterControllerHelper;
-import org.apache.ambari.server.controller.utilities.PropertyHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
-import java.util.Collections;
 import java.util.HashMap;
-import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
 
 /**
  * Resource instance which contains request specific state.
  */
-public class ResourceInstanceImpl implements ResourceInstance, Query{
+public class ResourceInstanceImpl implements ResourceInstance {
+
+  /**
+   * Query associated with the resource definition.
+   */
+  private Query m_query;
 
   /**
    * Map of primary and foreign keys and values necessary to identify the resource.
@@ -67,62 +54,31 @@ public class ResourceInstanceImpl implements ResourceInstance, Query{
    * Sub-resource instances of this resource.
    * Map of resource resource name to resource instance.
    */
-  private Map<String, ResourceInstanceImpl> m_mapSubResources;
-
-  /**
-   * Sub-resources of the resource which is being operated on.
-   */
-  private Map<String, ResourceInstanceImpl> m_mapQuerySubResources = new HashMap<String, ResourceInstanceImpl>();
-
-  /**
-   * Properties of the query which make up the select portion of the query.
-   */
-  private Set<String> m_setQueryProperties = new HashSet<String>();
-
-  /**
-   * Indicates that the query should include all available properties.
-   */
-  private boolean allProperties = false;
-
-  /**
-   * Map that associates each property set on the query to temporal data.
-   */
-  private Map<String, TemporalInfo> m_mapPropertyTemporalInfo = new HashMap<String, TemporalInfo>();
-
-  /**
-   * Map that associates categories with temporal data.
-   */
-  private Map<String, TemporalInfo> m_mapCategoryTemporalInfo = new HashMap<String, TemporalInfo>();
-
-  /**
-   * The user supplied predicate.
-   */
-  private Predicate m_userPredicate;
+  private Map<String, ResourceInstance> m_mapSubResources;
 
   /**
-   * The predicate to use for this query.
+   * Factory for creating resource instances.
+   * Used to create sub-resource instances.
    */
-  private Predicate m_predicate;
+  private ResourceInstanceFactory m_resourceFactory;
 
   /**
-   * The logger.
+   * Cluster controller reference.
    */
-  private final static Logger LOG =
-      LoggerFactory.getLogger(ResourceInstanceImpl.class);
+  //todo: should be injected.
+  private ClusterController m_controller = ClusterControllerHelper.getClusterController();
 
 
-  // ----- Constructors ------------------------------------------------------
-
-  public ResourceInstanceImpl(Map<Resource.Type, String> mapIds, ResourceDefinition resourceDefinition) {
+  public ResourceInstanceImpl(Map<Resource.Type, String> mapIds, ResourceDefinition resourceDefinition,
+                              ResourceInstanceFactory resourceFactory) {
 
     m_resourceDefinition = resourceDefinition;
+    m_query              = new QueryImpl(this);
+    m_resourceFactory    = resourceFactory;
 
     setIds(mapIds);
   }
 
-
-  // ----- ResourceInstance --------------------------------------------------
-
   @Override
   public void setIds(Map<Resource.Type, String> mapIds) {
     m_mapResourceIds.putAll(mapIds);
@@ -135,7 +91,7 @@ public class ResourceInstanceImpl implements ResourceInstance, Query{
 
   @Override
   public Query getQuery() {
-    return this;
+    return m_query;
   }
 
   @Override
@@ -143,86 +99,38 @@ public class ResourceInstanceImpl implements ResourceInstance, Query{
     return m_resourceDefinition;
   }
 
-  @Override
-  public Map<String, ResourceInstance> getSubResources() {
-    return new HashMap<String, ResourceInstance>(ensureSubResources());
-  }
 
   @Override
-  public boolean isCollectionResource() {
-    return getIds().get(getResourceDefinition().getType()) == null;
-  }
-
-
-  // ----- Query -------------------------------------------------------------
+  public Map<String, ResourceInstance> getSubResources() {
+    if (m_mapSubResources == null) {
+      m_mapSubResources = new HashMap<String, ResourceInstance>();
+      Set<SubResourceDefinition> setSubResourceDefs = getResourceDefinition().getSubResourceDefinitions();
 
-  @Override
-  public void addProperty(String category, String name, TemporalInfo temporalInfo) {
-    if (category == null && name.equals("*")) {
-      // wildcard
-      addAllProperties(temporalInfo);
-    } else{
-      if (addPropertyToSubResource(category, name, temporalInfo)){
-        // add pk/fk properties of the resource to this query
-        Resource.Type resourceType = getResourceDefinition().getType();
-        Schema schema              = getClusterController().getSchema(resourceType);
+      for (SubResourceDefinition subResDef : setSubResourceDefs) {
+        ResourceInstance resource = m_resourceFactory.createResource(subResDef.getType(), getIds());
 
-        for (Resource.Type type : getIds().keySet()) {
-          addLocalProperty(schema.getKeyPropertyId(type));
-        }
-      } else {
-        String propertyId = PropertyHelper.getPropertyId(category, name.equals("*") ? null : name);
-        addLocalProperty(propertyId);
-        if (temporalInfo != null) {
-          m_mapCategoryTemporalInfo.put(propertyId, temporalInfo);
+        // ensure pk is returned
+        resource.getQuery().addLocalProperty(m_controller.getSchema(
+            subResDef.getType()).getKeyPropertyId(subResDef.getType()));
+        // add additionally required fk properties
+        for (Resource.Type fkType : subResDef.getAdditionalForeignKeys()) {
+          resource.getQuery().addLocalProperty(m_controller.getSchema(subResDef.getType()).getKeyPropertyId(fkType));
         }
-      }
-    }
-  }
-
-  @Override
-  public void addLocalProperty(String property) {
-    m_setQueryProperties.add(property);
-  }
-
-  @Override
-  public Result execute()
-      throws UnsupportedPropertyException, SystemException, NoSuchResourceException, NoSuchParentResourceException {
-
-    QueryResult queryResult = queryForResources();
 
-    return applyResult(queryResult, null);
-  }
+        String subResourceName = subResDef.isCollection() ? resource.getResourceDefinition().getPluralName() :
+            resource.getResourceDefinition().getSingularName();
 
-  @Override
-  public Predicate getPredicate() {
-    if (m_predicate == null) {
-      Predicate internalPredicate = createInternalPredicate(this);
-      if (internalPredicate == null) {
-        if (m_userPredicate != null) {
-          m_predicate = m_userPredicate;
-        }
-      } else {
-        m_predicate = (m_userPredicate == null ? internalPredicate :
-            new AndPredicate(m_userPredicate, internalPredicate));
+        m_mapSubResources.put(subResourceName, resource);
       }
     }
-    return m_predicate;
-  }
-
-  @Override
-  public Set<String> getProperties() {
-    return Collections.unmodifiableSet(m_setQueryProperties);
+    return m_mapSubResources;
   }
 
   @Override
-  public void setUserPredicate(Predicate predicate) {
-    m_userPredicate = predicate;
+  public boolean isCollectionResource() {
+    return getIds().get(getResourceDefinition().getType()) == null;
   }
 
-
-  // ----- Object overrides --------------------------------------------------
-
   @Override
   public boolean equals(Object o) {
     if (this == o) return true;
@@ -231,15 +139,10 @@ public class ResourceInstanceImpl implements ResourceInstance, Query{
     ResourceInstanceImpl that = (ResourceInstanceImpl) o;
 
     return m_mapResourceIds.equals(that.m_mapResourceIds) &&
-        m_resourceDefinition.equals(that.m_resourceDefinition) &&
-        m_mapSubResources == null ? that.m_mapSubResources == null :
-            m_mapSubResources.equals(that.m_mapSubResources) &&
-        m_mapQuerySubResources == null ? that.m_mapQuerySubResources == null :
-            m_mapQuerySubResources.equals(that.m_mapQuerySubResources) &&
-        m_mapCategoryTemporalInfo.equals(that.m_mapCategoryTemporalInfo) &&
-        m_mapPropertyTemporalInfo.equals(that.m_mapPropertyTemporalInfo) &&
-        m_setQueryProperties.equals(that.m_setQueryProperties) &&
-        m_userPredicate == null ? that.m_userPredicate == null : m_userPredicate.equals(that.m_userPredicate);
+           m_query == that.m_query &&
+           m_resourceDefinition.equals(that.m_resourceDefinition) &&
+           m_mapSubResources == null ? that.m_mapSubResources == null :
+               m_mapSubResources.equals(that.m_mapSubResources);
   }
 
   @Override
@@ -248,369 +151,6 @@ public class ResourceInstanceImpl implements ResourceInstance, Query{
     result = 31 * result + m_mapResourceIds.hashCode();
     result = 31 * result + m_resourceDefinition.hashCode();
     result = 31 * result + (m_mapSubResources != null ? m_mapSubResources.hashCode() : 0);
-    result = 31 * result + (m_mapQuerySubResources != null ? m_mapQuerySubResources.hashCode() : 0);
-    result = 31 * result + m_setQueryProperties.hashCode();
-    result = 31 * result + m_mapPropertyTemporalInfo.hashCode();
-    result = 31 * result + m_mapCategoryTemporalInfo.hashCode();
-    result = 31 * result + (m_userPredicate != null ? m_userPredicate.hashCode() : 0);
-
     return result;
   }
-
-
-  // ----- helper methods ----------------------------------------------------
-
-  /**
-   * Factory method.
-   */
-  private static ResourceInstanceImpl createResource(
-      Resource.Type type, Map<Resource.Type, String> mapIds) {
-
-    return new ResourceInstanceImpl(mapIds,
-        ResourceInstanceFactoryImpl.createResourceDefinition(type, mapIds));
-  }
-
-  /**
-   * Get the associated cluster controller.
-   */
-  protected ClusterController getClusterController() {
-    return ClusterControllerHelper.getClusterController();
-  }
-
-  /**
-   * Get the map of sub-resources.  Lazily construct it if necessary.
-   */
-  protected Map<String, ResourceInstanceImpl> ensureSubResources() {
-    if (m_mapSubResources == null) {
-      m_mapSubResources = new HashMap<String, ResourceInstanceImpl>();
-      Set<SubResourceDefinition> setSubResourceDefs = getResourceDefinition().getSubResourceDefinitions();
-
-      for (SubResourceDefinition subResDef : setSubResourceDefs) {
-
-        Map<Resource.Type, String> mapIds = getIds();
-
-        ResourceInstanceImpl resource =createResource(subResDef.getType(), mapIds);
-
-        // ensure pk is returned
-        resource.getQuery().addLocalProperty(getClusterController().getSchema(
-            subResDef.getType()).getKeyPropertyId(subResDef.getType()));
-        // add additionally required fk properties
-        for (Resource.Type fkType : subResDef.getAdditionalForeignKeys()) {
-          resource.getQuery().addLocalProperty(getClusterController().getSchema(subResDef.getType()).getKeyPropertyId(fkType));
-        }
-
-        String subResourceName = subResDef.isCollection() ? resource.getResourceDefinition().getPluralName() :
-            resource.getResourceDefinition().getSingularName();
-
-        m_mapSubResources.put(subResourceName, resource);
-      }
-    }
-    return m_mapSubResources;
-  }
-
-  /**
-   * Apply the query result to this resource.
-   */
-  private Result applyResult(QueryResult queryResult, Predicate parentPredicate) {
-    Result result = createResult();
-
-    Map<String, ResourceInstanceImpl> mapSubResources = queryResult.getResourceInstance().m_mapQuerySubResources;
-    ResourceInstance resourceInstance = queryResult.getResourceInstance();
-
-    Resource.Type resourceType = resourceInstance.getResourceDefinition().getType();
-    if (resourceInstance.getIds().get(resourceType) == null) {
-      addCollectionProperties(resourceType);
-      result.getResultTree().setProperty("isCollection", "true");
-    }
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    int count = 1;
-    for (Resource resource : queryResult.getResources()) {
-
-      if (parentPredicate == null || parentPredicate.evaluate(resource)) {
-        // add a child node for the resource and provide a unique name.  The name is never used.
-        //todo: provide a more meaningful node name
-        TreeNode<Resource> node = tree.addChild(resource, resource.getType() + ":" + count++);
-        for (Map.Entry<String, ResourceInstanceImpl> entry : mapSubResources.entrySet()) {
-          String subResCategory = entry.getKey();
-          ResourceInstanceImpl r = entry.getValue();
-
-          Resource.Type subResourceType = r.getResourceDefinition().getType();
-
-          QueryResult subQueryResult = queryResult.getSubResources().get(subResourceType);
-
-          if (subQueryResult != null) {
-
-            setParentIdsOnSubResource(resource, r);
-
-            Predicate subPredicate = r.getQuery().getPredicate();
-
-            TreeNode<Resource> childResult = r.applyResult(subQueryResult, subPredicate).getResultTree();
-            childResult.setName(subResCategory);
-            childResult.setProperty("isCollection", "false");
-            node.addChild(childResult);
-          }
-
-        }
-      }
-    }
-    return result;
-  }
-
-  /**
-   * Query the cluster controller for the associated resources.
-   */
-  private QueryResult queryForResources()
-      throws UnsupportedPropertyException, SystemException, NoSuchResourceException, NoSuchParentResourceException {
-    Set<Resource> resources = new HashSet<Resource>();
-
-    Resource.Type resourceType = getResourceDefinition().getType();
-
-    Predicate predicate = getPredicate();
-
-    Request request = createRequest();
-
-    if (LOG.isDebugEnabled()) {
-      LOG.debug("Executing resource query: " + request + " where " + predicate);
-    }
-
-    if (m_setQueryProperties.isEmpty() && m_mapQuerySubResources.isEmpty()) {
-      //Add sub resource properties for default case where no fields are specified.
-      m_mapQuerySubResources.putAll(ensureSubResources());
-    }
-
-    Iterable<Resource> iterResource = getClusterController().getResources(
-        resourceType, request, predicate);
-
-    for (Resource resource : iterResource) {
-      resources.add(resource);
-    }
-
-    return new QueryResult(resources, queryForSubResources(this, resources), this);
-  }
-
-  /**
-   * Query the cluster controller for the associated sub-resources.
-   */
-  private Map<Resource.Type, QueryResult> queryForSubResources(ResourceInstanceImpl resourceInstance, Set<Resource> resources)
-      throws UnsupportedPropertyException, SystemException, NoSuchResourceException, NoSuchParentResourceException {
-
-    Map<Resource.Type, QueryResult> subResourceMap = new HashMap<Resource.Type, QueryResult>();
-
-    Map<String, Predicate> predicateMap = new HashMap<String, Predicate>();
-
-    for (Resource resource : resources) {
-
-      for (Map.Entry<String, ResourceInstanceImpl> entry : resourceInstance.m_mapQuerySubResources.entrySet()) {
-        String subResCategory = entry.getKey();
-        ResourceInstanceImpl r = entry.getValue();
-
-        Predicate predicate = predicateMap.get(subResCategory);
-
-        setParentIdsOnSubResource(resource, r);
-
-        if (predicate == null) {
-          predicate = r.getQuery().getPredicate();
-        } else {
-          predicate = new OrPredicate(predicate, r.getQuery().getPredicate());
-        }
-        predicateMap.put(subResCategory, predicate);
-      }
-    }
-
-    for (Map.Entry<String, ResourceInstanceImpl> entry : resourceInstance.m_mapQuerySubResources.entrySet()) {
-      String subResCategory = entry.getKey();
-      ResourceInstanceImpl subResource = entry.getValue();
-
-
-      Predicate predicate = predicateMap.get(subResCategory);
-
-      Request   request   = subResource.createRequest();
-
-      Resource.Type resourceType = subResource.getResourceDefinition().getType();
-
-      if (LOG.isDebugEnabled()) {
-        LOG.debug("Executing resource query: " + request + " where " + predicate);
-      }
-
-      Map<String, ResourceInstanceImpl> mapSubResources = subResource.m_mapQuerySubResources;
-      if (subResource.m_setQueryProperties.isEmpty() && mapSubResources.isEmpty()) {
-        //Add sub resource properties for default case where no fields are specified.
-        mapSubResources.putAll(subResource.ensureSubResources());
-      }
-
-      Iterable<Resource> iterResource = getClusterController().getResources(
-          resourceType, request, predicate);
-
-      Set<Resource> subResources = new HashSet<Resource>();
-      for (Resource resource : iterResource) {
-        subResources.add(resource);
-      }
-
-      subResourceMap.put(resourceType, new QueryResult(subResources, queryForSubResources(subResource, subResources), subResource));
-    }
-
-    return subResourceMap;
-  }
-
-  private void addCollectionProperties(Resource.Type resourceType) {
-    Schema schema = getClusterController().getSchema(resourceType);
-    // add pk
-    String property = schema.getKeyPropertyId(resourceType);
-    addProperty(PropertyHelper.getPropertyCategory(property), PropertyHelper.getPropertyName(property), null);
-
-    for (Resource.Type type : getIds().keySet()) {
-      // add fk's
-      String keyPropertyId = schema.getKeyPropertyId(type);
-      //todo: property id can be null in some cases such as host_component queries which obtain
-      //todo: component sub-resources.  Component will not have host fk.
-      //todo: refactor so that null check is not required.
-      if (keyPropertyId != null) {
-        addProperty(PropertyHelper.getPropertyCategory(keyPropertyId), PropertyHelper.getPropertyName(keyPropertyId), null);
-      }
-    }
-  }
-
-  private void addAllProperties(TemporalInfo temporalInfo) {
-    allProperties = true;
-    if (temporalInfo != null) {
-      m_mapCategoryTemporalInfo.put(null, temporalInfo);
-    }
-
-    for (Map.Entry<String, ResourceInstanceImpl> entry : ensureSubResources().entrySet()) {
-      String name = entry.getKey();
-      if (! m_mapQuerySubResources.containsKey(name)) {
-        m_mapQuerySubResources.put(name, entry.getValue());
-      }
-    }
-  }
-
-  private boolean addPropertyToSubResource(String path, String property, TemporalInfo temporalInfo) {
-    // cases:
-    // - path is null, property is path (all sub-resource props will have a path)
-    // - path is single token and prop in non null
-    //      (path only will presented as above case with property only)
-    // - path is multi level and prop is non null
-
-    boolean resourceAdded = false;
-    if (path == null) {
-      path = property;
-      property = null;
-    }
-
-    int i = path.indexOf("/");
-    String p = i == -1 ? path : path.substring(0, i);
-
-    ResourceInstanceImpl subResource = ensureSubResources().get(p);
-    if (subResource != null) {
-      m_mapQuerySubResources.put(p, subResource);
-      //todo: handle case of trailing '/' (for example fields=subResource/)
-
-      if (property != null || !path.equals(p)) {
-        //only add if a sub property is set or if a sub category is specified
-        subResource.getQuery().addProperty(i == -1 ? null : path.substring(i + 1), property, temporalInfo);
-      }
-      resourceAdded = true;
-    }
-    return resourceAdded;
-  }
-
-  private Predicate createInternalPredicate(ResourceInstance resource) {
-    Resource.Type resourceType = resource.getResourceDefinition().getType();
-    Map<Resource.Type, String> mapResourceIds = resource.getIds();
-    Schema schema = getClusterController().getSchema(resourceType);
-
-    Set<Predicate> setPredicates = new HashSet<Predicate>();
-    for (Map.Entry<Resource.Type, String> entry : mapResourceIds.entrySet()) {
-      if (entry.getValue() != null) {
-        String keyPropertyId = schema.getKeyPropertyId(entry.getKey());
-        if (keyPropertyId != null) {
-          setPredicates.add(new EqualsPredicate<String>(keyPropertyId, entry.getValue()));
-        }
-      }
-    }
-
-    if (setPredicates.size() == 1) {
-      return setPredicates.iterator().next();
-    } else if (setPredicates.size() > 1) {
-      return new AndPredicate(setPredicates.toArray(new Predicate[setPredicates.size()]));
-    } else {
-      return null;
-    }
-  }
-
-  private Request createRequest() {
-    Set<String> setProperties = new HashSet<String>();
-
-    Map<String, TemporalInfo> mapTemporalInfo    = new HashMap<String, TemporalInfo>();
-    TemporalInfo              globalTemporalInfo = m_mapCategoryTemporalInfo.get(null);
-
-    for (String group : m_setQueryProperties) {
-      TemporalInfo temporalInfo = m_mapCategoryTemporalInfo.get(group);
-      if (temporalInfo != null) {
-        mapTemporalInfo.put(group, temporalInfo);
-      } else if (globalTemporalInfo != null) {
-        mapTemporalInfo.put(group, globalTemporalInfo);
-      }
-      setProperties.add(group);
-    }
-
-    return PropertyHelper.getReadRequest(allProperties ? Collections.<String>emptySet() : setProperties, mapTemporalInfo);
-  }
-
-  private void setParentIdsOnSubResource(Resource resource, ResourceInstance r) {
-    Map<Resource.Type, String> mapParentIds = getIds();
-    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>(mapParentIds.size());
-    for (Map.Entry<Resource.Type, String> resourceIdEntry : mapParentIds.entrySet()) {
-      Resource.Type type = resourceIdEntry.getKey();
-      String value = resourceIdEntry.getValue();
-
-      if (value == null) {
-        Object o = resource.getPropertyValue(getClusterController().getSchema(type).getKeyPropertyId(type));
-        value = o == null ? null : o.toString();
-      }
-      if (value != null) {
-        mapResourceIds.put(type, value);
-      }
-    }
-    String resourceKeyProp = getClusterController().getSchema(resource.getType()).
-        getKeyPropertyId(resource.getType());
-    //todo: shouldn't use toString here
-    mapResourceIds.put(resource.getType(), resource.getPropertyValue(resourceKeyProp).toString());
-    r.setIds(mapResourceIds);
-  }
-
-  protected Result createResult() {
-    return new ResultImpl(true);
-  }
-
-
-  // ----- inner classes -----------------------------------------------------
-
-  private static class QueryResult {
-    private  final ResourceInstanceImpl resourceInstance;
-    private final Set<Resource> resources;
-    private final Map<Resource.Type, QueryResult> subResourceMap;
-
-    private QueryResult(Set<Resource> resources,
-                        Map<Resource.Type, QueryResult> subResourceMap,
-                        ResourceInstanceImpl resourceInstance) {
-      this.resources        = resources;
-      this.subResourceMap   = subResourceMap;
-      this.resourceInstance = resourceInstance;
-    }
-
-    public ResourceInstanceImpl getResourceInstance() {
-      return resourceInstance;
-    }
-
-    public Set<Resource> getResources() {
-      return resources;
-    }
-
-    public Map<Resource.Type, QueryResult> getSubResources() {
-      return subResourceMap;
-    }
-  }
 }

ambari-server/src/main/java/org/apache/ambari/server/controller/predicate/AlwaysPredicate.java

@@ -43,12 +43,4 @@ public class AlwaysPredicate implements BasePredicate {
   public void accept(PredicateVisitor visitor) {
     visitor.acceptAlwaysPredicate(this);
   }
-
-
-  // ----- Object overrides --------------------------------------------------
-
-  @Override
-  public String toString() {
-    return "TRUE";
-  }
 }

ambari-server/src/main/java/org/apache/ambari/server/controller/predicate/ArrayPredicate.java

@@ -87,28 +87,4 @@ public abstract class ArrayPredicate implements BasePredicate {
   }
 
   public abstract String getOperator();
-
-
-  // ----- Object overrides --------------------------------------------------
-
-  @Override
-  public String toString() {
-    StringBuilder sb = new StringBuilder();
-
-    for (Predicate predicate : predicates) {
-
-      boolean arrayPredicate = predicate instanceof ArrayPredicate;
-
-      if (sb.length() > 0) {
-        sb.append(" ").append(getOperator()).append(" ");
-      }
-
-      if (arrayPredicate) {
-        sb.append("(").append(predicate).append(")");
-      } else {
-        sb.append(predicate);
-      }
-    }
-    return sb.toString();
-  }
 }

ambari-server/src/main/java/org/apache/ambari/server/controller/predicate/CategoryIsEmptyPredicate.java

@@ -46,11 +46,4 @@ public class CategoryIsEmptyPredicate extends CategoryPredicate {
     Map<String, Object> properties = resource.getPropertiesMap().get(propertyId);
     return properties == null ? true : properties.isEmpty();
   }
-
-  // ----- Object overrides --------------------------------------------------
-
-  @Override
-  public String toString() {
-    return "isEmpty(" + getPropertyId() + ")";
-  }
 }

ambari-server/src/main/java/org/apache/ambari/server/controller/predicate/ComparisonPredicate.java

@@ -105,11 +105,4 @@ public abstract class ComparisonPredicate<T> extends PropertyPredicate implement
   }
 
   public abstract String getOperator();
-
-  // ----- Object overrides --------------------------------------------------
-
-  @Override
-  public String toString() {
-    return getPropertyId() + getOperator() + getValue();
-  }
 }

ambari-server/src/main/java/org/apache/ambari/server/controller/predicate/UnaryPredicate.java

@@ -63,12 +63,4 @@ public abstract class UnaryPredicate implements BasePredicate {
   }
 
   public abstract String getOperator();
-
-
-  // ----- Object overrides --------------------------------------------------
-
-  @Override
-  public String toString() {
-    return getOperator() + "(" + getPredicate() + ")";
-  }
 }

ambari-server/src/test/java/org/apache/ambari/server/api/TestSuite.java

@@ -26,6 +26,7 @@ import org.apache.ambari.server.api.handlers.*;
 import org.apache.ambari.server.api.predicate.QueryLexerTest;
 import org.apache.ambari.server.api.predicate.QueryParserTest;
 import org.apache.ambari.server.api.predicate.operators.*;
+import org.apache.ambari.server.api.query.QueryImplTest;
 import org.apache.ambari.server.api.resources.ResourceInstanceImplTest;
 import org.apache.ambari.server.api.services.*;
 import org.apache.ambari.server.api.services.parsers.BodyParseExceptionTest;
@@ -36,7 +37,7 @@ import org.junit.runners.Suite;
 
 @RunWith(Suite.class)
 @Suite.SuiteClasses({ClusterServiceTest.class, HostServiceTest.class, ServiceServiceTest.class,
-    ComponentServiceTest.class, HostComponentServiceTest.class, ReadHandlerTest.class,
+    ComponentServiceTest.class, HostComponentServiceTest.class, ReadHandlerTest.class, QueryImplTest.class,
     JsonRequestBodyParserTest.class, CreateHandlerTest.class, UpdateHandlerTest.class, DeleteHandlerTest.class,
     PersistenceManagerImplTest.class, GetRequestTest.class, PutRequestTest.class, PostRequestTest.class,
     DeleteRequestTest.class, QueryPostRequestTest.class, JsonSerializerTest.class, QueryCreateHandlerTest.class,

ambari-server/src/test/java/org/apache/ambari/server/api/query/QueryImplTest.java

@@ -0,0 +1,615 @@
+package org.apache.ambari.server.api.query;
+
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import org.apache.ambari.server.api.resources.ResourceDefinition;
+import org.apache.ambari.server.api.util.TreeNode;
+import org.apache.ambari.server.api.util.TreeNodeImpl;
+import org.apache.ambari.server.controller.predicate.AndPredicate;
+import org.apache.ambari.server.controller.spi.*;
+import org.apache.ambari.server.controller.utilities.PredicateBuilder;
+import org.apache.ambari.server.api.resources.ResourceInstance;
+import org.apache.ambari.server.api.services.Result;
+import org.apache.ambari.server.controller.utilities.PropertyHelper;
+import org.junit.After;
+import org.junit.Test;
+
+import java.util.*;
+
+import static org.easymock.EasyMock.*;
+
+import static org.easymock.EasyMock.eq;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertSame;
+import static org.junit.Assert.assertTrue;
+
+
+//todo: add assertions for temporal info
+public class QueryImplTest {
+
+  ClusterController m_controller = createNiceMock(ClusterController.class);
+
+  @Test
+  public void testExecute__Component_instance_noSpecifiedProps() throws Exception {
+    Result result = createNiceMock(Result.class);
+    ResourceInstance componentResourceInstance = createNiceMock(ResourceInstance.class);
+    ResourceDefinition componentResourceDefinition = createNiceMock(ResourceDefinition.class);
+    ResourceInstance hostResourceInstance = createNiceMock(ResourceInstance.class);
+    ResourceDefinition hostResourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema componentSchema = createNiceMock(Schema.class);
+    Resource componentResource = createNiceMock(Resource.class);
+    String componentPropertyId = "componentId";
+    Query hostComponentQuery = createStrictMock(Query.class);
+    Result hostComponentQueryResult = createNiceMock(Result.class);
+
+    TreeNode<Resource> tree = new TreeNodeImpl<Resource>(null, null, null);
+    TreeNode<Resource> hostComponentResultNode = new TreeNodeImpl<Resource>(null, null, null);
+    List<Resource> listResources = Collections.singletonList(componentResource);
+
+    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>();
+    mapResourceIds.put(Resource.Type.Cluster, "clusterName");
+    mapResourceIds.put(Resource.Type.Service, "serviceName");
+    mapResourceIds.put(Resource.Type.Component, "componentName");
+
+    Map<String, ResourceInstance> mapChildren = new HashMap<String, ResourceInstance>();
+    mapChildren.put("host_components", hostResourceInstance);
+
+    PredicateBuilder pb = new PredicateBuilder();
+    Predicate predicate = pb.property("clusterId").equals("clusterName").and().
+        property("serviceId").equals("serviceName").and().
+        property("componentId").equals("componentName").toPredicate();
+
+    // expectations
+    expect(componentResourceInstance.getResourceDefinition()).andReturn(componentResourceDefinition).anyTimes();
+    expect(componentResourceInstance.getSubResources()).andReturn(mapChildren).anyTimes();
+    expect(componentResourceInstance.getIds()).andReturn(mapResourceIds).anyTimes();
+
+    expect(componentResourceDefinition.getType()).andReturn(Resource.Type.Component).anyTimes();
+
+    expect(componentResource.getType()).andReturn(Resource.Type.Component).anyTimes();
+    expect(componentResource.getPropertyValue(componentPropertyId)).andReturn("keyVal");
+
+    expect(m_controller.getSchema(Resource.Type.Component)).andReturn(componentSchema).anyTimes();
+
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Cluster)).andReturn("clusterId");
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Service)).andReturn("serviceId");
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Component)).andReturn(componentPropertyId).atLeastOnce();
+
+    expect(m_controller.getResources(eq(Resource.Type.Component), eq(PropertyHelper.getReadRequest(Collections.<String>emptySet())),
+        eq(predicate))).andReturn(listResources);
+
+    expect(result.getResultTree()).andReturn(tree).anyTimes();
+
+    Map<Resource.Type, String> mapResourceIdsSet = new HashMap<Resource.Type, String>(mapResourceIds);
+    mapResourceIdsSet.put(Resource.Type.Component, "keyVal");
+    hostResourceInstance.setIds(mapResourceIdsSet);
+    expect(hostResourceInstance.getResourceDefinition()).andReturn(hostResourceDefinition).anyTimes();
+    expect(hostResourceInstance.getQuery()).andReturn(hostComponentQuery).anyTimes();
+
+    expect(hostResourceDefinition.getType()).andReturn(Resource.Type.Host);
+    expect(hostComponentQuery.execute()).andReturn(hostComponentQueryResult);
+    expect(hostComponentQueryResult.getResultTree()).andReturn(hostComponentResultNode);
+
+    replay(m_controller, result, componentResourceInstance, componentResourceDefinition, hostResourceInstance, componentSchema, componentResource,
+        hostComponentQuery, hostComponentQueryResult);
+
+    QueryImpl query = new TestQuery(componentResourceInstance, result);
+    query.execute();
+
+    verify(m_controller, result, componentResourceInstance, componentResourceDefinition, hostResourceInstance, componentSchema, componentResource,
+        hostComponentQuery, hostComponentQueryResult);
+
+    assertEquals(1, tree.getChildren().size());
+    TreeNode<Resource> componentNode = tree.getChild("Component:1");
+    assertEquals("Component:1", componentNode.getName());
+    assertEquals(componentResource, componentNode.getObject());
+    assertEquals(1, componentNode.getChildren().size());
+    assertSame(hostComponentResultNode, componentNode.getChild("host_components"));
+    assertEquals("false", hostComponentResultNode.getProperty("isCollection"));
+  }
+
+  @Test
+  public void testExecute__Component_collection_noSpecifiedProps() throws Exception {
+    Result result = createNiceMock(Result.class);
+    ResourceInstance componentResourceInstance = createNiceMock(ResourceInstance.class);
+    ResourceDefinition componentResourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema componentSchema = createNiceMock(Schema.class);
+    Resource componentResource = createNiceMock(Resource.class);
+    String componentPropertyId = "componentId";
+    String servicePropertyId = "serviceId";
+    String clusterPropertyId = "clusterId";
+
+    Set<String> setPropertyIds = new HashSet<String>();
+    setPropertyIds.add(clusterPropertyId);
+    setPropertyIds.add(servicePropertyId);
+    setPropertyIds.add(componentPropertyId);
+
+    TreeNode<Resource> tree = new TreeNodeImpl<Resource>(null, null, null);
+    List<Resource> listResources = Collections.singletonList(componentResource);
+
+    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>();
+    mapResourceIds.put(Resource.Type.Cluster, "clusterName");
+    mapResourceIds.put(Resource.Type.Service, "serviceName");
+    mapResourceIds.put(Resource.Type.Component, null);
+
+    PredicateBuilder pb = new PredicateBuilder();
+    Predicate predicate = pb.property("clusterId").equals("clusterName").and().
+        property("serviceId").equals("serviceName").toPredicate();
+
+    // expectations
+    expect(componentResource.getType()).andReturn(Resource.Type.Component).anyTimes();
+
+    expect(componentResourceInstance.getIds()).andReturn(mapResourceIds).anyTimes();
+    expect(componentResourceInstance.getResourceDefinition()).andReturn(componentResourceDefinition).anyTimes();
+
+    expect(componentResourceDefinition.getType()).andReturn(Resource.Type.Component).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Component)).andReturn(componentSchema).anyTimes();
+
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Component)).andReturn(componentPropertyId).anyTimes();
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Cluster)).andReturn("clusterId").anyTimes();
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Service)).andReturn("serviceId").anyTimes();
+
+    expect(result.getResultTree()).andReturn(tree).anyTimes();
+
+    expect(m_controller.getResources(eq(Resource.Type.Component), eq(PropertyHelper.getReadRequest(setPropertyIds)),
+        eq(predicate))).andReturn(listResources);
+
+    expect(componentResourceInstance.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, result,componentResourceInstance, componentResourceDefinition, componentSchema, componentResource);
+
+    QueryImpl query = new TestQuery(componentResourceInstance, result);
+    query.execute();
+
+    verify(m_controller, result, componentResourceInstance, componentResourceDefinition, componentSchema, componentResource);
+
+    assertEquals("true", tree.getProperty("isCollection"));
+    assertEquals(1, tree.getChildren().size());
+    TreeNode<Resource> componentNode = tree.getChild("Component:1");
+    assertSame(componentResource, componentNode.getObject());
+    assertEquals(0, componentNode.getChildren().size());
+  }
+
+  @Test
+  public void testExecute__collection_nullInternalPredicate_nullUserPredicate() throws Exception {
+    Result result = createNiceMock(Result.class);
+    ResourceInstance clusterResourceInstance = createNiceMock(ResourceInstance.class);
+    ResourceDefinition clusterResourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema clusterSchema = createNiceMock(Schema.class);
+    Resource clusterResource = createNiceMock(Resource.class);
+    String clusterPropertyId = "clusterId";
+
+    TreeNode<Resource> tree = new TreeNodeImpl<Resource>(null, null, null);
+    List<Resource> listResources = Collections.singletonList(clusterResource);
+
+    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>();
+
+    // expectations
+    expect(clusterResource.getType()).andReturn(Resource.Type.Cluster).anyTimes();
+
+    expect(clusterResourceInstance.getIds()).andReturn(mapResourceIds).anyTimes();
+    expect(clusterResourceInstance.getResourceDefinition()).andReturn(clusterResourceDefinition).anyTimes();
+
+    expect(clusterResourceDefinition.getType()).andReturn(Resource.Type.Component).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Component)).andReturn(clusterSchema).atLeastOnce();
+
+    expect(clusterSchema.getKeyPropertyId(Resource.Type.Component)).andReturn(clusterPropertyId).atLeastOnce();
+
+    expect(result.getResultTree()).andReturn(tree).atLeastOnce();
+
+    expect(m_controller.getResources(eq(Resource.Type.Component), eq(PropertyHelper.getReadRequest(Collections.singleton(clusterPropertyId))),
+        (Predicate) isNull())).andReturn(listResources);
+
+
+    expect(clusterResourceInstance.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, result, clusterResourceInstance, clusterResourceDefinition, clusterSchema, clusterResource);
+
+    QueryImpl query = new TestQuery(clusterResourceInstance, result);
+    query.execute();
+
+    verify(m_controller, result, clusterResourceInstance, clusterResourceDefinition, clusterSchema, clusterResource);
+
+    assertEquals("true", tree.getProperty("isCollection"));
+    assertEquals(1, tree.getChildren().size());
+    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
+    assertSame(clusterResource, clusterNode.getObject());
+    assertEquals(0, clusterNode.getChildren().size());
+
+  }
+
+  @Test
+  public void testExecute__collection_nullInternalPredicate_nonNullUserPredicate() throws Exception {
+    Result result = createNiceMock(Result.class);
+    ResourceInstance clusterResourceInstance = createNiceMock(ResourceInstance.class);
+    ResourceDefinition clusterResourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema clusterSchema = createNiceMock(Schema.class);
+    Resource clusterResource = createNiceMock(Resource.class);
+    String clusterPropertyId = "clusterId";
+    Predicate userPredicate = createNiceMock(Predicate.class);
+
+    TreeNode<Resource> tree = new TreeNodeImpl<Resource>(null, null, null);
+    List<Resource> listResources = Collections.singletonList(clusterResource);
+
+    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>();
+
+    // expectations
+    expect(clusterResource.getType()).andReturn(Resource.Type.Cluster).anyTimes();
+
+    expect(clusterResourceInstance.getIds()).andReturn(mapResourceIds).anyTimes();
+    expect(clusterResourceInstance.getResourceDefinition()).andReturn(clusterResourceDefinition).anyTimes();
+
+    expect(clusterResourceDefinition.getType()).andReturn(Resource.Type.Component).atLeastOnce();
+
+    expect(m_controller.getSchema(Resource.Type.Component)).andReturn(clusterSchema).anyTimes();
+    expect(clusterSchema.getKeyPropertyId(Resource.Type.Component)).andReturn(clusterPropertyId).anyTimes();
+
+    expect(result.getResultTree()).andReturn(tree).anyTimes();
+
+    expect(m_controller.getResources(eq(Resource.Type.Component), eq(PropertyHelper.getReadRequest(Collections.singleton(clusterPropertyId))),
+        eq(userPredicate))).andReturn(listResources);
+
+    expect(clusterResourceInstance.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, result,clusterResourceInstance, clusterResourceDefinition, clusterSchema, clusterResource, userPredicate);
+
+    QueryImpl query = new TestQuery(clusterResourceInstance, result);
+    query.setUserPredicate(userPredicate);
+    query.execute();
+
+    verify(m_controller, result, clusterResourceInstance, clusterResourceDefinition, clusterSchema, clusterResource, userPredicate);
+
+    assertEquals("true", tree.getProperty("isCollection"));
+    assertEquals(1, tree.getChildren().size());
+    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
+    assertSame(clusterResource, clusterNode.getObject());
+    assertEquals(0, clusterNode.getChildren().size());
+  }
+
+  @Test
+  public void testExecute__collection_nonNullInternalPredicate_nonNullUserPredicate() throws Exception {
+    Result result = createNiceMock(Result.class);
+    ResourceInstance componentResourceInstance = createNiceMock(ResourceInstance.class);
+    ResourceDefinition componentResourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema componentSchema = createNiceMock(Schema.class);
+    Resource componentResource = createNiceMock(Resource.class);
+    String componentPropertyId = "componentId";
+    String servicePropertyId = "serviceId";
+    String clusterPropertyId = "clusterId";
+
+    Set<String> setPropertyIds = new HashSet<String>();
+    setPropertyIds.add(clusterPropertyId);
+    setPropertyIds.add(servicePropertyId);
+    setPropertyIds.add(componentPropertyId);
+
+    TreeNode<Resource> tree = new TreeNodeImpl<Resource>(null, null, null);
+    List<Resource> listResources = Collections.singletonList(componentResource);
+
+    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>();
+    mapResourceIds.put(Resource.Type.Cluster, "clusterName");
+    mapResourceIds.put(Resource.Type.Service, "serviceName");
+    mapResourceIds.put(Resource.Type.Component, null);
+
+    PredicateBuilder pb = new PredicateBuilder();
+    Predicate internalPredicate = pb.property("clusterId").equals("clusterName").and().
+        property("serviceId").equals("serviceName").toPredicate();
+
+    pb = new PredicateBuilder();
+    Predicate userPredicate = pb.property("foo").equals("bar").toPredicate();
+    // combine internal predicate and user predicate
+    //todo: for now, need to cast to BasePredicate
+    Predicate predicate = new AndPredicate(internalPredicate, userPredicate);
+
+    // expectations
+    expect(componentResource.getType()).andReturn(Resource.Type.Component).anyTimes();
+
+    expect(componentResourceInstance.getIds()).andReturn(mapResourceIds).anyTimes();
+    expect(componentResourceInstance.getResourceDefinition()).andReturn(componentResourceDefinition).anyTimes();
+
+    expect(componentResourceDefinition.getType()).andReturn(Resource.Type.Component).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Component)).andReturn(componentSchema).anyTimes();
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Component)).andReturn(componentPropertyId).atLeastOnce();
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Cluster)).andReturn("clusterId").anyTimes();
+    expect(componentSchema.getKeyPropertyId(Resource.Type.Service)).andReturn("serviceId").anyTimes();
+
+    expect(result.getResultTree()).andReturn(tree).anyTimes();
+
+    expect(m_controller.getResources(eq(Resource.Type.Component), eq(PropertyHelper.getReadRequest(setPropertyIds)),
+        eq(predicate))).andReturn(listResources);
+
+    expect(componentResourceInstance.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, result, componentResourceInstance, componentResourceDefinition, componentSchema, componentResource);
+
+    QueryImpl query = new TestQuery(componentResourceInstance, result);
+    query.setUserPredicate(userPredicate);
+    query.execute();
+
+    verify(m_controller, result, componentResourceInstance, componentResourceDefinition, componentSchema, componentResource);
+
+    assertEquals("true", tree.getProperty("isCollection"));
+    assertEquals(1, tree.getChildren().size());
+    TreeNode<Resource> componentNode = tree.getChild("Component:1");
+    assertSame(componentResource, componentNode.getObject());
+    assertEquals(0, componentNode.getChildren().size());
+  }
+
+  @Test
+  public void testAddProperty__localProperty() throws Exception {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+    expect(resource.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+
+    replay(m_controller, resource, resourceDefinition, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty("category", "property", null);
+
+    assertEquals(1, query.getProperties().size());
+    assertTrue(query.getProperties().contains("category/property"));
+
+    query.addProperty(null, "property2", null);
+
+    assertEquals(2, query.getProperties().size());
+    assertTrue(query.getProperties().contains("property2"));
+
+    verify(m_controller, resource, resourceDefinition, schema);
+  }
+
+  @Test
+  public void testAddProperty__allProperties() throws Exception {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+    expect(resource.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+
+    replay(m_controller, resource, resourceDefinition, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty(null, "*", null);
+
+    assertEquals(0, query.getProperties().size());
+
+    verify(m_controller, resource, resourceDefinition, schema);
+  }
+
+  @Test
+  public void testAddProperty__allCategoryProperties() throws Exception {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+    expect(resource.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+
+    replay(m_controller, resource, resourceDefinition, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty("category", "*", null);
+
+    assertEquals(1, query.getProperties().size());
+    assertTrue(query.getProperties().contains("category"));
+
+    verify(m_controller, resource, resourceDefinition, schema);
+  }
+
+  // this is the case where service can't differentiate category and property name
+  // the category name is give as the property name
+  @Test
+  public void testAddProperty__localCategory_asPropertyName() throws Exception  {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+    expect(resource.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, resource, resourceDefinition, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty(null, "category", null);
+
+    Set<String> setProperties = query.getProperties();
+    assertEquals(1, setProperties.size());
+    assertTrue(setProperties.contains("category"));
+
+    verify(m_controller, resource, resourceDefinition, schema);
+  }
+
+  // This is the case where the service can determine that only a category was provided because it contained
+  // a trailing '/'
+  @Test
+  public void testAddProperty__localCategory_categoryNameOnly() throws Exception {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+    expect(resource.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, resource, resourceDefinition, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty("category/", "", null);
+
+    Set<String> setProperties = query.getProperties();
+    assertEquals(1, setProperties.size());
+    assertTrue(setProperties.contains("category"));
+
+    verify(m_controller, resource, resourceDefinition, schema);
+  }
+
+  @Test
+  public void testAddProperty__localSubCategory() throws Exception {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+
+    expect(resource.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, resource, resourceDefinition, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty("category", "nestedCategory", null);
+
+    Set<String> setProperties = query.getProperties();
+    assertEquals(1, setProperties.size());
+    assertTrue(setProperties.contains("category/nestedCategory"));
+
+    verify(m_controller, resource, resourceDefinition, schema);
+  }
+
+  @Test
+  public void testAddProperty__localCategorySubPropsOnly() throws Exception {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+    expect(resource.getSubResources()).andReturn(Collections.<String, ResourceInstance>emptyMap()).anyTimes();
+
+    replay(m_controller, resource, resourceDefinition, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty(null, "category", null);
+
+    Set<String> setProperties = query.getProperties();
+    assertEquals(1, setProperties.size());
+    assertTrue(setProperties.contains("category"));
+
+    verify(m_controller, resource, resourceDefinition, schema);
+  }
+
+  @Test
+  public void testAddProperty__subProperty() throws Exception {
+    ResourceInstance resource = createNiceMock(ResourceInstance.class);
+    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
+    ResourceInstance subResource = createNiceMock(ResourceInstance.class);
+    Schema schema = createNiceMock(Schema.class);
+
+    Map<Resource.Type, String> mapResourceIds = new HashMap<Resource.Type, String>();
+    mapResourceIds.put(Resource.Type.Service, "serviceName");
+    mapResourceIds.put(Resource.Type.Component, "componentName");
+
+    //expectations
+    expect(resource.getResourceDefinition()).andReturn(resourceDefinition).anyTimes();
+
+    expect(resourceDefinition.getType()).andReturn(Resource.Type.Service).anyTimes();
+
+    expect(m_controller.getSchema(Resource.Type.Service)).andReturn(schema).anyTimes();
+
+    expect(schema.getKeyPropertyId(Resource.Type.Service)).andReturn("serviceName").anyTimes();
+    expect(schema.getKeyPropertyId(Resource.Type.Component)).andReturn("componentName").anyTimes();
+
+    expect(resource.getSubResources()).andReturn(Collections.singletonMap("components", subResource)).anyTimes();
+    expect(resource.getIds()).andReturn(mapResourceIds).anyTimes();
+
+    //todo: ensure that sub-resource was added.
+
+    replay(m_controller, resource, resourceDefinition, subResource, schema);
+
+    Query query = new TestQuery(resource, null);
+    query.addProperty(null, "components", null);
+
+    // verify that only the key properties of the parent resource have been added to the query
+    Set<String> properties = query.getProperties();
+    assertEquals(2, properties.size());
+    assertTrue(properties.contains("serviceName"));
+    assertTrue(properties.contains("componentName"));
+
+    verify(m_controller, resource, resourceDefinition, subResource, schema);
+  }
+
+  //todo: sub-resource with property and with sub-path
+
+//  @Test
+//  public void testAddProperty__invalidProperty() {
+//
+//  }
+
+  private class TestQuery extends QueryImpl {
+
+    private Result m_result;
+
+    public TestQuery(ResourceInstance ResourceInstance, Result result) {
+      super(ResourceInstance);
+      m_result = result;
+    }
+
+    @Override
+    ClusterController getClusterController() {
+      return m_controller;
+    }
+
+    @Override
+    Result createResult() {
+      return m_result;
+    }
+  }
+
+  @After
+  public void resetGlobalMocks() {
+    reset(m_controller);
+  }
+}

ambari-server/src/test/java/org/apache/ambari/server/api/resources/ResourceInstanceImplTest.java

@@ -20,20 +20,11 @@
 package org.apache.ambari.server.api.resources;
 
 
-import org.apache.ambari.server.api.services.Result;
-import org.apache.ambari.server.api.util.TreeNode;
-import org.apache.ambari.server.controller.internal.ClusterControllerImpl;
-import org.apache.ambari.server.controller.internal.ClusterControllerImplTest;
-import org.apache.ambari.server.controller.spi.ClusterController;
-import org.apache.ambari.server.controller.spi.Predicate;
 import org.apache.ambari.server.controller.spi.Resource;
-import org.apache.ambari.server.controller.utilities.PredicateBuilder;
-import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.Collections;
 import java.util.HashMap;
-import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
 
@@ -46,7 +37,6 @@ import static org.junit.Assert.assertTrue;
  * ResourceInstanceImpl unit tests.
  */
 public class ResourceInstanceImplTest {
-
   @Test
   public void testIsCollection__True() {
     ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
@@ -62,7 +52,7 @@ public class ResourceInstanceImplTest {
     replay(resourceDefinition);
 
     //test
-    ResourceInstance instance = new ResourceInstanceImpl(mapIds, resourceDefinition);
+    ResourceInstance instance = new ResourceInstanceImpl(mapIds, resourceDefinition, null);
     assertTrue(instance.isCollectionResource());
 
     verify(resourceDefinition);
@@ -83,423 +73,9 @@ public class ResourceInstanceImplTest {
     replay(resourceDefinition);
 
     //test
-    ResourceInstance instance = new ResourceInstanceImpl(mapIds, resourceDefinition);
+    ResourceInstance instance = new ResourceInstanceImpl(mapIds, resourceDefinition, null);
     assertFalse(instance.isCollectionResource());
 
     verify(resourceDefinition);
   }
-
-  @Test
-  public void testExecute__Cluster_instance_noSpecifiedProps() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-    mapIds.put(Resource.Type.Cluster, "cluster");
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Cluster).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-    setChildren.add(new SubResourceDefinition(Resource.Type.Host));
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
-    Assert.assertEquals("Cluster:1", clusterNode.getName());
-    Assert.assertEquals(Resource.Type.Cluster, clusterNode.getObject().getType());
-    Assert.assertEquals(1, clusterNode.getChildren().size());
-    TreeNode<Resource> hostNode = clusterNode.getChild("hosts");
-    Assert.assertEquals(4, hostNode.getChildren().size());
-  }
-
-  @Test
- public void testExecute__Host_collection_noSpecifiedProps() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Host).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(4, tree.getChildren().size());
-    TreeNode<Resource> hostNode = tree.getChild("Host:1");
-    Assert.assertEquals("Host:1", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-
-    hostNode = tree.getChild("Host:2");
-    Assert.assertEquals("Host:2", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-
-    hostNode = tree.getChild("Host:3");
-    Assert.assertEquals("Host:3", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-
-    hostNode = tree.getChild("Host:4");
-    Assert.assertEquals("Host:4", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-  }
-
-  @Test
-  public void testExecute__collection_nullInternalPredicate_nullUserPredicate() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Cluster).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-    setChildren.add(new SubResourceDefinition(Resource.Type.Host));
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
-    Assert.assertEquals("Cluster:1", clusterNode.getName());
-    Assert.assertEquals(Resource.Type.Cluster, clusterNode.getObject().getType());
-    Assert.assertEquals(1, clusterNode.getChildren().size());
-    TreeNode<Resource> hostNode = clusterNode.getChild("hosts");
-    Assert.assertEquals(4, hostNode.getChildren().size());
-  }
-
-  @Test
-  public void testExecute__collection_nullInternalPredicate_nonNullUserPredicate() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-    mapIds.put(Resource.Type.Cluster, "cluster");
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Host).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    PredicateBuilder pb = new PredicateBuilder();
-    Predicate predicate = pb.property("Hosts/host_name").equals("host:2").toPredicate();
-
-    instance.setUserPredicate(predicate);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> hostNode = tree.getChild("Host:1");
-    Assert.assertEquals("Host:1", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-    Assert.assertEquals("host:2", hostNode.getObject().getPropertyValue("Hosts/host_name"));
-  }
-
-  @Test
-  public void testExecute__collection_nonNullInternalPredicate_nonNullUserPredicate() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Host).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    PredicateBuilder pb = new PredicateBuilder();
-    Predicate predicate = pb.property("Hosts/host_name").equals("host:2").toPredicate();
-
-    instance.setUserPredicate(predicate);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> hostNode = tree.getChild("Host:1");
-    Assert.assertEquals("Host:1", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-    Assert.assertEquals("host:2", hostNode.getObject().getPropertyValue("Hosts/host_name"));  }
-
-  @Test
-  public void testAddProperty__localProperty() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Host).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    instance.addLocalProperty("c1/p1");
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(4, tree.getChildren().size());
-    TreeNode<Resource> hostNode = tree.getChild("Host:1");
-    Assert.assertEquals("Host:1", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-    Assert.assertNotNull(hostNode.getObject().getPropertyValue("c1/p1"));
-
-    hostNode = tree.getChild("Host:2");
-    Assert.assertEquals("Host:2", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-    Assert.assertNotNull(hostNode.getObject().getPropertyValue("c1/p1"));
-
-    hostNode = tree.getChild("Host:3");
-    Assert.assertEquals("Host:3", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-    Assert.assertNotNull(hostNode.getObject().getPropertyValue("c1/p1"));
-
-    hostNode = tree.getChild("Host:4");
-    Assert.assertEquals("Host:4", hostNode.getName());
-    Assert.assertEquals(Resource.Type.Host, hostNode.getObject().getType());
-    Assert.assertNotNull(hostNode.getObject().getPropertyValue("c1/p1"));
-  }
-
-  @Test
-  public void testAddProperty__allProperties() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-    mapIds.put(Resource.Type.Cluster, "cluster");
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Cluster).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-    setChildren.add(new SubResourceDefinition(Resource.Type.Host));
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
-    Assert.assertEquals("Cluster:1", clusterNode.getName());
-    Assert.assertEquals(Resource.Type.Cluster, clusterNode.getObject().getType());
-    Assert.assertEquals(1, clusterNode.getChildren().size());
-    TreeNode<Resource> hostNode = clusterNode.getChild("hosts");
-    Assert.assertEquals(4, hostNode.getChildren().size());
-  }
-
-  @Test
-  public void testAddProperty__allCategoryProperties() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-    mapIds.put(Resource.Type.Cluster, "cluster");
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Cluster).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-    setChildren.add(new SubResourceDefinition(Resource.Type.Host));
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
-    Assert.assertEquals("Cluster:1", clusterNode.getName());
-    Assert.assertEquals(Resource.Type.Cluster, clusterNode.getObject().getType());
-    Assert.assertEquals(1, clusterNode.getChildren().size());
-    TreeNode<Resource> hostNode = clusterNode.getChild("hosts");
-    Assert.assertEquals(4, hostNode.getChildren().size());
-  }
-
-  @Test
-  public void testAddProperty__localCategory_asPropertyName() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-    mapIds.put(Resource.Type.Cluster, "cluster");
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Cluster).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-    setChildren.add(new SubResourceDefinition(Resource.Type.Host));
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
-    Assert.assertEquals("Cluster:1", clusterNode.getName());
-    Assert.assertEquals(Resource.Type.Cluster, clusterNode.getObject().getType());
-    Assert.assertEquals(1, clusterNode.getChildren().size());
-    TreeNode<Resource> hostNode = clusterNode.getChild("hosts");
-    Assert.assertEquals(4, hostNode.getChildren().size());
-  }
-
-  @Test
-  public void testAddProperty__localSubCategory() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-    mapIds.put(Resource.Type.Cluster, "cluster");
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Cluster).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-    setChildren.add(new SubResourceDefinition(Resource.Type.Host));
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
-    Assert.assertEquals("Cluster:1", clusterNode.getName());
-    Assert.assertEquals(Resource.Type.Cluster, clusterNode.getObject().getType());
-    Assert.assertEquals(1, clusterNode.getChildren().size());
-    TreeNode<Resource> hostNode = clusterNode.getChild("hosts");
-    Assert.assertEquals(4, hostNode.getChildren().size());
-  }
-
-  @Test
-  public void testAddProperty__subProperty() throws Exception {
-    ResourceDefinition resourceDefinition = createNiceMock(ResourceDefinition.class);
-
-    Map<Resource.Type, String> mapIds = new HashMap<Resource.Type, String>();
-    mapIds.put(Resource.Type.Cluster, "cluster");
-
-    // expectations
-    expect(resourceDefinition.getType()).andReturn(Resource.Type.Cluster).anyTimes();
-    Set<SubResourceDefinition> setChildren = new HashSet<SubResourceDefinition>();
-    setChildren.add(new SubResourceDefinition(Resource.Type.Host));
-
-    expect(resourceDefinition.getSubResourceDefinitions()).andReturn(setChildren).anyTimes();
-
-    replay(resourceDefinition);
-
-    //test
-    ResourceInstanceImpl instance = new TestQuery(mapIds, resourceDefinition);
-
-    Result result = instance.execute();
-
-    verify(resourceDefinition);
-
-    TreeNode<Resource> tree = result.getResultTree();
-
-    Assert.assertEquals(1, tree.getChildren().size());
-    TreeNode<Resource> clusterNode = tree.getChild("Cluster:1");
-    Assert.assertEquals("Cluster:1", clusterNode.getName());
-    Assert.assertEquals(Resource.Type.Cluster, clusterNode.getObject().getType());
-    Assert.assertEquals(1, clusterNode.getChildren().size());
-    TreeNode<Resource> hostNode = clusterNode.getChild("hosts");
-    Assert.assertEquals(4, hostNode.getChildren().size());
-  }
-
-  private class TestQuery extends ResourceInstanceImpl {
-
-    private ClusterController m_controller;
-
-    public TestQuery(Map<Resource.Type, String> mapIds, ResourceDefinition resourceDefinition) {
-      super(mapIds, resourceDefinition);
-
-      ClusterControllerImplTest.TestProviderModule providerModule = new ClusterControllerImplTest.TestProviderModule();
-      m_controller = new ClusterControllerImpl(providerModule);
-
-    }
-
-    @Override
-    protected ClusterController getClusterController() {
-      return m_controller;
-    }
-  }
 }
-

ambari-server/src/test/java/org/apache/ambari/server/controller/internal/ClusterControllerImplTest.java

@@ -85,16 +85,13 @@ public class ClusterControllerImplTest {
   private static final Map<Resource.Type, String> keyPropertyIds = new HashMap<Resource.Type, String>();
 
   static {
-    keyPropertyIds.put(Resource.Type.Cluster, PropertyHelper.getPropertyId("Hosts", "cluster_name"));
-    keyPropertyIds.put(Resource.Type.Host, PropertyHelper.getPropertyId("Hosts", "host_name"));
+    keyPropertyIds.put(Resource.Type.Cluster, PropertyHelper.getPropertyId("c1", "p1"));
+    keyPropertyIds.put(Resource.Type.Host, PropertyHelper.getPropertyId("c1", "p2"));
   }
 
   private static final Set<String> resourceProviderProperties = new HashSet<String>();
 
   static {
-    resourceProviderProperties.add(PropertyHelper.getPropertyId("Hosts", "cluster_name"));
-    resourceProviderProperties.add(PropertyHelper.getPropertyId("Hosts", "host_name"));
-    resourceProviderProperties.add(PropertyHelper.getPropertyId("c1", "p1"));
     resourceProviderProperties.add(PropertyHelper.getPropertyId("c1", "p1"));
     resourceProviderProperties.add(PropertyHelper.getPropertyId("c1", "p2"));
     resourceProviderProperties.add(PropertyHelper.getPropertyId("c1", "p3"));
@@ -434,12 +431,15 @@ public class ClusterControllerImplTest {
 //    }
 //  }
 
-  public static class TestProviderModule implements ProviderModule {
+  private static class TestProviderModule implements ProviderModule {
     private Map<Resource.Type, ResourceProvider> providers = new HashMap<Resource.Type, ResourceProvider>();
 
-    public TestProviderModule() {
-      providers.put(Resource.Type.Cluster, new TestClusterResourceProvider());
+    private TestProviderModule() {
+      providers.put(Resource.Type.Cluster, new TestResourceProvider());
+      providers.put(Resource.Type.Service, new TestResourceProvider());
+      providers.put(Resource.Type.Component, new TestResourceProvider());
       providers.put(Resource.Type.Host, new TestResourceProvider());
+      providers.put(Resource.Type.HostComponent, new TestResourceProvider());
     }
 
     @Override
@@ -453,42 +453,6 @@ public class ClusterControllerImplTest {
     }
   }
 
-  private static class TestClusterResourceProvider implements ResourceProvider {
-    @Override
-    public RequestStatus createResources(Request request) throws SystemException, UnsupportedPropertyException, ResourceAlreadyExistsException, NoSuchParentResourceException {
-      throw new UnsupportedOperationException(); // not needed for testing
-    }
-
-    @Override
-    public Set<Resource> getResources(Request request, Predicate predicate) throws SystemException, UnsupportedPropertyException, NoSuchResourceException, NoSuchParentResourceException {
-      ResourceImpl resource = new ResourceImpl(Resource.Type.Cluster);
-
-      resource.setProperty(PropertyHelper.getPropertyId("Clusters", "cluster_name"), "cluster");
-
-      return Collections.<Resource>singleton(resource);
-    }
-
-    @Override
-    public RequestStatus updateResources(Request request, Predicate predicate) throws SystemException, UnsupportedPropertyException, NoSuchResourceException, NoSuchParentResourceException {
-      throw new UnsupportedOperationException(); // not needed for testing
-    }
-
-    @Override
-    public RequestStatus deleteResources(Predicate predicate) throws SystemException, UnsupportedPropertyException, NoSuchResourceException, NoSuchParentResourceException {
-      throw new UnsupportedOperationException(); // not needed for testing
-    }
-
-    @Override
-    public Map<Resource.Type, String> getKeyPropertyIds() {
-      return Collections.singletonMap(Resource.Type.Cluster, PropertyHelper.getPropertyId("Clusters", "cluster_name"));
-    }
-
-    @Override
-    public Set<String> checkPropertyIds(Set<String> propertyIds) {
-      return Collections.emptySet();
-    }
-  }
-
   private static class TestResourceProvider implements ResourceProvider {
     private Action lastAction = null;
     private Request lastRequest = null;
@@ -502,9 +466,6 @@ public class ClusterControllerImplTest {
       for (int cnt = 0; cnt < 4; ++ cnt) {
         ResourceImpl resource = new ResourceImpl(Resource.Type.Host);
 
-        resource.setProperty(PropertyHelper.getPropertyId("Hosts", "cluster_name"), "cluster");
-        resource.setProperty(PropertyHelper.getPropertyId("Hosts", "host_name"), "host:" + cnt);
-
         resource.setProperty(PropertyHelper.getPropertyId("c1", "p1"), cnt);
         resource.setProperty(PropertyHelper.getPropertyId("c1", "p2"), cnt % 2);
         resource.setProperty(PropertyHelper.getPropertyId("c1", "p3"), "foo");
@@ -571,6 +532,7 @@ public class ClusterControllerImplTest {
       Update,
       Delete
     }
+
   }
 
 }