Commit 9310e0bc by Suma Shivaprasad

Fixed constants

parent fe107bbf
...@@ -25,11 +25,8 @@ import com.sun.jersey.api.client.config.DefaultClientConfig; ...@@ -25,11 +25,8 @@ import com.sun.jersey.api.client.config.DefaultClientConfig;
import com.sun.jersey.client.urlconnection.URLConnectionClientHandler; import com.sun.jersey.client.urlconnection.URLConnectionClientHandler;
import org.apache.commons.configuration.PropertiesConfiguration; import org.apache.commons.configuration.PropertiesConfiguration;
import org.apache.hadoop.metadata.security.SecureClientUtils; import org.apache.hadoop.metadata.security.SecureClientUtils;
import org.apache.hadoop.metadata.typesystem.ITypedReferenceableInstance;
import org.apache.hadoop.metadata.typesystem.Referenceable; import org.apache.hadoop.metadata.typesystem.Referenceable;
import org.apache.hadoop.metadata.typesystem.json.InstanceSerialization; import org.apache.hadoop.metadata.typesystem.json.InstanceSerialization;
import org.apache.hadoop.metadata.typesystem.json.Serialization;
import org.apache.http.protocol.HTTP;
import org.codehaus.jettison.json.JSONArray; import org.codehaus.jettison.json.JSONArray;
import org.codehaus.jettison.json.JSONException; import org.codehaus.jettison.json.JSONException;
import org.codehaus.jettison.json.JSONObject; import org.codehaus.jettison.json.JSONObject;
...@@ -60,11 +57,14 @@ public class MetadataServiceClient { ...@@ -60,11 +57,14 @@ public class MetadataServiceClient {
public static final String COUNT = "count"; public static final String COUNT = "count";
public static final String ROWS = "rows"; public static final String ROWS = "rows";
private static final String BASE_URI = "api/metadata/"; public static final String BASE_URI = "api/metadata/";
private static final String URI_TYPES = "types"; public static final String URI_TYPES = "types";
private static final String URI_ENTITIES = "entities"; public static final String URI_ENTITIES = "entities";
private static final String URI_TRAITS = "traits"; public static final String URI_TRAITS = "traits";
private static final String URI_SEARCH = "discovery/search"; public static final String URI_SEARCH = "discovery/search";
public static final String QUERY = "query";
public static final String QUERY_TYPE = "queryType";
private WebResource service; private WebResource service;
...@@ -204,7 +204,7 @@ public class MetadataServiceClient { ...@@ -204,7 +204,7 @@ public class MetadataServiceClient {
public JSONObject searchEntity(String searchQuery) throws MetadataServiceException { public JSONObject searchEntity(String searchQuery) throws MetadataServiceException {
WebResource resource = getResource(API.SEARCH); WebResource resource = getResource(API.SEARCH);
resource = resource.queryParam("query", searchQuery); resource = resource.queryParam(QUERY, searchQuery);
return callAPIWithResource(API.SEARCH, resource); return callAPIWithResource(API.SEARCH, resource);
} }
...@@ -234,7 +234,7 @@ public class MetadataServiceClient { ...@@ -234,7 +234,7 @@ public class MetadataServiceClient {
*/ */
public JSONArray searchByDSL(String query) throws MetadataServiceException { public JSONArray searchByDSL(String query) throws MetadataServiceException {
WebResource resource = getResource(API.SEARCH_DSL); WebResource resource = getResource(API.SEARCH_DSL);
resource = resource.queryParam("query", query); resource = resource.queryParam(QUERY, query);
JSONObject result = callAPIWithResource(API.SEARCH_DSL, resource); JSONObject result = callAPIWithResource(API.SEARCH_DSL, resource);
try { try {
return result.getJSONObject(RESULTS).getJSONArray(ROWS); return result.getJSONObject(RESULTS).getJSONArray(ROWS);
...@@ -251,7 +251,7 @@ public class MetadataServiceClient { ...@@ -251,7 +251,7 @@ public class MetadataServiceClient {
*/ */
public JSONObject searchByGremlin(String gremlinQuery) throws MetadataServiceException { public JSONObject searchByGremlin(String gremlinQuery) throws MetadataServiceException {
WebResource resource = getResource(API.SEARCH_GREMLIN); WebResource resource = getResource(API.SEARCH_GREMLIN);
resource = resource.queryParam("query", gremlinQuery); resource = resource.queryParam(QUERY, gremlinQuery);
return callAPIWithResource(API.SEARCH_GREMLIN, resource); return callAPIWithResource(API.SEARCH_GREMLIN, resource);
} }
...@@ -263,7 +263,7 @@ public class MetadataServiceClient { ...@@ -263,7 +263,7 @@ public class MetadataServiceClient {
*/ */
public JSONObject searchByFullText(String query) throws MetadataServiceException { public JSONObject searchByFullText(String query) throws MetadataServiceException {
WebResource resource = getResource(API.SEARCH_FULL_TEXT); WebResource resource = getResource(API.SEARCH_FULL_TEXT);
resource = resource.queryParam("query", query); resource = resource.queryParam(QUERY, query);
return callAPIWithResource(API.SEARCH_FULL_TEXT, resource); return callAPIWithResource(API.SEARCH_FULL_TEXT, resource);
} }
......
...@@ -49,8 +49,6 @@ import java.util.Map; ...@@ -49,8 +49,6 @@ import java.util.Map;
public class MetadataDiscoveryResource { public class MetadataDiscoveryResource {
private static final Logger LOG = LoggerFactory.getLogger(EntityResource.class); private static final Logger LOG = LoggerFactory.getLogger(EntityResource.class);
private static final String QUERY = "query";
private static final String QUERY_TYPE = "queryType";
private static final String QUERY_TYPE_DSL = "dsl"; private static final String QUERY_TYPE_DSL = "dsl";
private static final String QUERY_TYPE_GREMLIN = "gremlin"; private static final String QUERY_TYPE_GREMLIN = "gremlin";
private static final String QUERY_TYPE_FULLTEXT = "full-text"; private static final String QUERY_TYPE_FULLTEXT = "full-text";
...@@ -166,8 +164,8 @@ public class MetadataDiscoveryResource { ...@@ -166,8 +164,8 @@ public class MetadataDiscoveryResource {
JSONObject response = new JSONObject(); JSONObject response = new JSONObject();
response.put(MetadataServiceClient.REQUEST_ID, Servlets.getRequestId()); response.put(MetadataServiceClient.REQUEST_ID, Servlets.getRequestId());
response.put(QUERY, gremlinQuery); response.put(MetadataServiceClient.QUERY, gremlinQuery);
response.put(QUERY_TYPE, QUERY_TYPE_GREMLIN); response.put(MetadataServiceClient.QUERY_TYPE, QUERY_TYPE_GREMLIN);
JSONArray list = new JSONArray(); JSONArray list = new JSONArray();
for (Map<String, String> result : results) { for (Map<String, String> result : results) {
...@@ -252,8 +250,8 @@ public class MetadataDiscoveryResource { ...@@ -252,8 +250,8 @@ public class MetadataDiscoveryResource {
Preconditions.checkArgument(count >= 0, "Search Result count should be > 0"); Preconditions.checkArgument(count >= 0, "Search Result count should be > 0");
response.put(MetadataServiceClient.REQUEST_ID, Servlets.getRequestId()); response.put(MetadataServiceClient.REQUEST_ID, Servlets.getRequestId());
response.put(QUERY, query); response.put(MetadataServiceClient.QUERY, query);
response.put(QUERY_TYPE, queryType); response.put(MetadataServiceClient.QUERY_TYPE, queryType);
response.put(MetadataServiceClient.COUNT, count); response.put(MetadataServiceClient.COUNT, count);
return response; return response;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment