diff --git a/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractITBatchIndexTest.java b/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractITBatchIndexTest.java index 2034b602ee32..226824f476f5 100644 --- a/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractITBatchIndexTest.java +++ b/integration-tests/src/test/java/org/apache/druid/tests/indexer/AbstractITBatchIndexTest.java @@ -123,7 +123,7 @@ void doReindexTest( queryResponseTemplate = StringUtils.replace( queryResponseTemplate, "%%DATASOURCE%%", - fullBaseDatasourceName + fullReindexDatasourceName ); queryHelper.testQueriesFromString(queryResponseTemplate, 2); diff --git a/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITIndexerTest.java b/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITIndexerTest.java index 245c3dd3960d..adc0f88bf818 100644 --- a/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITIndexerTest.java +++ b/integration-tests/src/test/java/org/apache/druid/tests/indexer/ITIndexerTest.java @@ -33,6 +33,7 @@ public class ITIndexerTest extends AbstractITBatchIndexTest private static String INDEX_DATASOURCE = "wikipedia_index_test"; private static String REINDEX_TASK = "/indexer/wikipedia_reindex_task.json"; + private static String REINDEX_QUERIES_RESOURCE = "/indexer/wikipedia_reindex_queries.json"; private static String REINDEX_DATASOURCE = "wikipedia_reindex_test"; @Test @@ -52,7 +53,7 @@ public void testIndexData() throws Exception INDEX_DATASOURCE, REINDEX_DATASOURCE, REINDEX_TASK, - INDEX_QUERIES_RESOURCE + REINDEX_QUERIES_RESOURCE ); } } diff --git a/integration-tests/src/test/resources/indexer/wikipedia_reindex_queries.json b/integration-tests/src/test/resources/indexer/wikipedia_reindex_queries.json new file mode 100644 index 000000000000..572e0f1b5db0 --- /dev/null +++ b/integration-tests/src/test/resources/indexer/wikipedia_reindex_queries.json @@ -0,0 +1,66 @@ +[ + { + "description": "timeseries, 1 agg, all", + "query":{ + "queryType" : "timeBoundary", + "dataSource": "%%DATASOURCE%%" + }, + "expectedResults":[ + { + "timestamp" : "2013-08-31T01:02:33.000Z", + "result" : { + "minTime" : "2013-08-31T01:02:33.000Z", + "maxTime" : "2013-08-31T12:41:27.000Z" + } + } + ] + }, + + { + "description":"having spec on post aggregation", + "query":{ + "queryType":"groupBy", + "dataSource":"%%DATASOURCE%%", + "granularity":"day", + "dimensions":[ + "page" + ], + "filter":{ + "type":"selector", + "dimension":"language", + "value":"zh" + }, + "aggregations":[ + { + "type":"longSum", + "fieldName":"added", + "name":"added_count" + } + ], + "postAggregations": [ + { + "type":"arithmetic", + "name":"added_count_times_ten", + "fn":"*", + "fields":[ + {"type":"fieldAccess", "name":"added_count", "fieldName":"added_count"}, + {"type":"constant", "name":"const", "value":10} + ] + } + ], + "having":{"type":"greaterThan", "aggregation":"added_count_times_ten", "value":9000}, + "intervals":[ + "2013-08-31T00:00/2013-09-01T00:00" + ] + }, + "expectedResults":[ { + "version" : "v1", + "timestamp" : "2013-08-31T00:00:00.000Z", + "event" : { + "added_count_times_ten" : 9050.0, + "page" : "Crimson Typhoon", + "added_count" : 905 + } + } ] + } +]