@Test public void testGroupActionSingleFieldHavingSpecialCharactersWithFilter() throws FoxtrotException, JsonProcessingException { GroupRequest groupRequest = new GroupRequest(); groupRequest.setTable(TestUtils.TEST_TABLE_NAME); EqualsFilter equalsFilter = new EqualsFilter(); equalsFilter.setField("device"); equalsFilter.setValue("nexus"); groupRequest.setFilters(Collections.<Filter>singletonList(equalsFilter)); groupRequest.setNesting(Arrays.asList("!@#$%^&*()")); Map<String, Object> response = Maps.newHashMap(); GroupResponse actualResult = GroupResponse.class.cast(getQueryExecutor().execute(groupRequest)); assertEquals(response, actualResult.getResult()); }
@Override public ActionResponse execute(GroupRequest parameter) { SearchRequestBuilder query = getRequestBuilder(parameter); try { SearchResponse response = query.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } }
GroupAction extends Action<GroupRequest> { @Override public ActionResponse execute(GroupRequest parameter) { SearchRequestBuilder query = getRequestBuilder(parameter); try { SearchResponse response = query.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } }
GroupAction extends Action<GroupRequest> { @Override public ActionResponse execute(GroupRequest parameter) { SearchRequestBuilder query = getRequestBuilder(parameter); try { SearchResponse response = query.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } GroupAction(GroupRequest parameter, AnalyticsLoader analyticsLoader); }
GroupAction extends Action<GroupRequest> { @Override public ActionResponse execute(GroupRequest parameter) { SearchRequestBuilder query = getRequestBuilder(parameter); try { SearchResponse response = query.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } GroupAction(GroupRequest parameter, AnalyticsLoader analyticsLoader); @Override void preprocess(); @Override String getMetricKey(); @Override String getRequestCacheKey(); @Override void validateImpl(GroupRequest parameter); @Override ActionResponse execute(GroupRequest parameter); @Override SearchRequestBuilder getRequestBuilder(GroupRequest parameter); @Override ActionResponse getResponse(org.elasticsearch.action.ActionResponse response, GroupRequest parameter); }
GroupAction extends Action<GroupRequest> { @Override public ActionResponse execute(GroupRequest parameter) { SearchRequestBuilder query = getRequestBuilder(parameter); try { SearchResponse response = query.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } GroupAction(GroupRequest parameter, AnalyticsLoader analyticsLoader); @Override void preprocess(); @Override String getMetricKey(); @Override String getRequestCacheKey(); @Override void validateImpl(GroupRequest parameter); @Override ActionResponse execute(GroupRequest parameter); @Override SearchRequestBuilder getRequestBuilder(GroupRequest parameter); @Override ActionResponse getResponse(org.elasticsearch.action.ActionResponse response, GroupRequest parameter);  }