@Test(expected = MalformedQueryException.class) public void testStatsActionNullTable() throws FoxtrotException { StatsRequest request = new StatsRequest(); request.setTable(null); request.setField("battery"); request.setNesting(Lists.newArrayList("os", "version")); getQueryExecutor().execute(request); }
@Override public ActionResponse execute(StatsRequest parameter) { SearchRequestBuilder searchRequestBuilder = getRequestBuilder(parameter); try { SearchResponse response = searchRequestBuilder.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } }
StatsAction extends Action<StatsRequest> { @Override public ActionResponse execute(StatsRequest parameter) { SearchRequestBuilder searchRequestBuilder = getRequestBuilder(parameter); try { SearchResponse response = searchRequestBuilder.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } }
StatsAction extends Action<StatsRequest> { @Override public ActionResponse execute(StatsRequest parameter) { SearchRequestBuilder searchRequestBuilder = getRequestBuilder(parameter); try { SearchResponse response = searchRequestBuilder.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } StatsAction(StatsRequest parameter, AnalyticsLoader analyticsLoader); }
StatsAction extends Action<StatsRequest> { @Override public ActionResponse execute(StatsRequest parameter) { SearchRequestBuilder searchRequestBuilder = getRequestBuilder(parameter); try { SearchResponse response = searchRequestBuilder.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } StatsAction(StatsRequest parameter, AnalyticsLoader analyticsLoader); @Override void preprocess(); @Override String getMetricKey(); @Override String getRequestCacheKey(); @Override void validateImpl(StatsRequest parameter); @Override ActionResponse execute(StatsRequest parameter); @Override SearchRequestBuilder getRequestBuilder(StatsRequest parameter); @Override ActionResponse getResponse(org.elasticsearch.action.ActionResponse response, StatsRequest parameter); }
StatsAction extends Action<StatsRequest> { @Override public ActionResponse execute(StatsRequest parameter) { SearchRequestBuilder searchRequestBuilder = getRequestBuilder(parameter); try { SearchResponse response = searchRequestBuilder.execute() .actionGet(getGetQueryTimeout()); return getResponse(response, parameter); } catch (ElasticsearchException e) { throw FoxtrotExceptions.createQueryExecutionException(parameter, e); } } StatsAction(StatsRequest parameter, AnalyticsLoader analyticsLoader); @Override void preprocess(); @Override String getMetricKey(); @Override String getRequestCacheKey(); @Override void validateImpl(StatsRequest parameter); @Override ActionResponse execute(StatsRequest parameter); @Override SearchRequestBuilder getRequestBuilder(StatsRequest parameter); @Override ActionResponse getResponse(org.elasticsearch.action.ActionResponse response, StatsRequest parameter);  }