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