You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by fj...@apache.org on 2018/12/11 16:05:59 UTC
[incubator-druid] branch master updated: Add fail message (#6720)
This is an automated email from the ASF dual-hosted git repository.
fjy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/master by this push:
new 86e3ae5 Add fail message (#6720)
86e3ae5 is described below
commit 86e3ae5b48bca7cbb9bf05e9e66d013f34dabf16
Author: Atul Mohan <at...@gmail.com>
AuthorDate: Tue Dec 11 10:05:50 2018 -0600
Add fail message (#6720)
---
.../variance/VarianceGroupByQueryTest.java | 8 +-
.../druid/query/MultiValuedDimensionTest.java | 8 +-
.../query/groupby/GroupByQueryRunnerTest.java | 204 ++++++++++-----------
.../segment/realtime/RealtimeManagerTest.java | 16 +-
4 files changed, 118 insertions(+), 118 deletions(-)
diff --git a/extensions-core/stats/src/test/java/org/apache/druid/query/aggregation/variance/VarianceGroupByQueryTest.java b/extensions-core/stats/src/test/java/org/apache/druid/query/aggregation/variance/VarianceGroupByQueryTest.java
index 90f6112..bd19c74 100644
--- a/extensions-core/stats/src/test/java/org/apache/druid/query/aggregation/variance/VarianceGroupByQueryTest.java
+++ b/extensions-core/stats/src/test/java/org/apache/druid/query/aggregation/variance/VarianceGroupByQueryTest.java
@@ -114,7 +114,7 @@ public class VarianceGroupByQueryTest
.build();
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "variance");
}
@Test
@@ -160,7 +160,7 @@ public class VarianceGroupByQueryTest
.build();
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "groupBy");
}
@Test
@@ -198,7 +198,7 @@ public class VarianceGroupByQueryTest
.build();
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "havingSpec");
query = query.withLimitSpec(
new DefaultLimitSpec(
@@ -216,6 +216,6 @@ public class VarianceGroupByQueryTest
.build();
results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "limitSpec");
}
}
diff --git a/processing/src/test/java/org/apache/druid/query/MultiValuedDimensionTest.java b/processing/src/test/java/org/apache/druid/query/MultiValuedDimensionTest.java
index 1b49b7d..b31fda7 100644
--- a/processing/src/test/java/org/apache/druid/query/MultiValuedDimensionTest.java
+++ b/processing/src/test/java/org/apache/druid/query/MultiValuedDimensionTest.java
@@ -185,7 +185,7 @@ public class MultiValuedDimensionTest
GroupByQueryRunnerTestHelper.createExpectedRow("1970-01-01T00:00:00.000Z", "tags", "t7", "count", 2L)
);
- TestHelper.assertExpectedObjects(expectedResults, result.toList(), "");
+ TestHelper.assertExpectedObjects(expectedResults, result.toList(), "noFilter");
}
@Test
@@ -217,7 +217,7 @@ public class MultiValuedDimensionTest
GroupByQueryRunnerTestHelper.createExpectedRow("1970-01-01T00:00:00.000Z", "tags", "t5", "count", 2L)
);
- TestHelper.assertExpectedObjects(expectedResults, result.toList(), "");
+ TestHelper.assertExpectedObjects(expectedResults, result.toList(), "dimFilter");
}
@Test
@@ -245,7 +245,7 @@ public class MultiValuedDimensionTest
GroupByQueryRunnerTestHelper.createExpectedRow("1970-01-01T00:00:00.000Z", "tags", "t3", "count", 4L)
);
- TestHelper.assertExpectedObjects(expectedResults, result.toList(), "");
+ TestHelper.assertExpectedObjects(expectedResults, result.toList(), "filteredDim");
}
@Test
@@ -294,7 +294,7 @@ public class MultiValuedDimensionTest
)
)
);
- TestHelper.assertExpectedObjects(expectedResults, result.toList(), "");
+ TestHelper.assertExpectedObjects(expectedResults, result.toList(), "filteredDim");
}
}
diff --git a/processing/src/test/java/org/apache/druid/query/groupby/GroupByQueryRunnerTest.java b/processing/src/test/java/org/apache/druid/query/groupby/GroupByQueryRunnerTest.java
index 755d341..646e2d3 100644
--- a/processing/src/test/java/org/apache/druid/query/groupby/GroupByQueryRunnerTest.java
+++ b/processing/src/test/java/org/apache/druid/query/groupby/GroupByQueryRunnerTest.java
@@ -482,7 +482,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "groupBy");
}
@Test
@@ -509,7 +509,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "missing-column");
}
@Test
@@ -560,7 +560,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "string-postAgg");
}
@Test
@@ -622,7 +622,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "virtual-column");
}
@Test
@@ -660,7 +660,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "duration-granularity");
}
@Test
@@ -725,7 +725,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "sort-by-dimensions-first");
}
@Test
@@ -754,7 +754,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "chunk-period");
}
@Test
@@ -791,7 +791,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "no-aggs");
}
@Test
@@ -819,7 +819,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "multi-value-dim");
}
@Test
@@ -845,7 +845,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "two-multi-value-dims");
}
@Test
@@ -1064,7 +1064,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "one-multi-value-dim");
}
@Test
@@ -1283,7 +1283,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "one-multi-value-dim-different-order");
}
@Test
@@ -1327,7 +1327,7 @@ public class GroupByQueryRunnerTest
}
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "override-maxResults");
}
@Test
@@ -1366,7 +1366,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "override-timeout");
}
@Test
@@ -1411,7 +1411,7 @@ public class GroupByQueryRunnerTest
}
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "overide-maxOnDiskStorage");
}
@Test
@@ -1456,7 +1456,7 @@ public class GroupByQueryRunnerTest
}
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "dictionary-space");
}
@Test
@@ -1506,7 +1506,7 @@ public class GroupByQueryRunnerTest
}
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "disk-space");
}
@Test
@@ -1620,7 +1620,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "rebucket-rename");
}
@@ -1687,7 +1687,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "non-injective");
}
@@ -1754,7 +1754,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "retain-missing");
}
@@ -1821,7 +1821,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "rename-and-missing-string");
}
@Test
@@ -1887,7 +1887,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "simple-rename");
}
@Test
@@ -1912,7 +1912,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "uniques");
}
@Test(expected = IllegalArgumentException.class)
@@ -1945,7 +1945,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "unique-postagg-same-name");
}
@Test
@@ -1970,7 +1970,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "cardinality");
}
@Test
@@ -2002,7 +2002,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "first-last-aggs");
}
@Test
@@ -2075,7 +2075,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
GroupByQueryRunnerTestHelper.runQuery(factory, runner, query),
- ""
+ "null-dimextraction"
);
}
@@ -2135,7 +2135,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
GroupByQueryRunnerTestHelper.runQuery(factory, runner, query),
- ""
+ "empty-string-dimextraction"
);
}
@@ -2328,7 +2328,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "timezone");
}
@Test
@@ -3221,7 +3221,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "alphanumeric-dimension-order");
}
@Test
@@ -3276,7 +3276,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "lookup-limit");
}
@Ignore
@@ -3462,7 +3462,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
results,
- ""
+ "order-limit-havingspec"
);
}
@@ -3514,7 +3514,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
GroupByQueryRunnerTestHelper.runQuery(factory, runner, fullQuery),
- ""
+ "postagg-havingspec"
);
}
@@ -3548,7 +3548,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
GroupByQueryRunnerTestHelper.runQuery(factory, runner, fullQuery),
- ""
+ "havingspec"
);
}
@@ -3589,7 +3589,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
GroupByQueryRunnerTestHelper.runQuery(factory, runner, fullQuery),
- ""
+ "dimfilter-havingspec"
);
}
@@ -3631,7 +3631,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
GroupByQueryRunnerTestHelper.runQuery(factory, runner, fullQuery),
- ""
+ "extractionfn-havingspec"
);
}
@@ -3918,7 +3918,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
GroupByQueryRunnerTestHelper.runQuery(factory, runner, query),
- ""
+ "custom-havingspec"
);
}
@@ -4053,7 +4053,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "sub-query");
}
@Test
@@ -4116,7 +4116,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-multiple-intervals");
}
@Test
@@ -4180,7 +4180,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-multiple-intervals");
}
@Test
@@ -4227,7 +4227,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-extractionfn");
}
@Test
@@ -4262,7 +4262,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
- GroupByQueryRunnerTestHelper.runQuery(factory, runner, query), ""
+ GroupByQueryRunnerTestHelper.runQuery(factory, runner, query), "subquery"
);
subquery = new GroupByQuery.Builder(subquery)
@@ -4283,7 +4283,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
expectedResults,
- GroupByQueryRunnerTestHelper.runQuery(factory, runner, query), ""
+ GroupByQueryRunnerTestHelper.runQuery(factory, runner, query), "subquery"
);
}
@@ -4332,7 +4332,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-multiple-aggs");
}
@@ -4377,7 +4377,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-filter");
}
@Test
@@ -4405,7 +4405,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-different-intervals");
}
@Test
@@ -4752,7 +4752,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-postaggs");
}
@Test
@@ -4999,7 +4999,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-postaggs");
}
@Test
@@ -5156,7 +5156,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-multi-aggs");
}
@Test
@@ -5185,7 +5185,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("1970-01-01", "rows", 837L)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-filter-agg");
}
@Test
@@ -5224,7 +5224,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("2011-04-03", "rows", 0L)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-time-filter");
}
@Test
@@ -5251,7 +5251,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("2011-04-01", "count", 18L)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-timeout");
}
@Test
@@ -5278,7 +5278,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("2011-04-01", "count", 18L)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-virtual");
}
@Test
@@ -5312,7 +5312,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("1970-01-01", "car", QueryRunnerTestHelper.UNIQUES_9)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-cardinality");
}
@Test
@@ -5354,7 +5354,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("2011-04-01", "count", 18L)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-count-agg");
}
}
@@ -5408,7 +5408,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("2011-04-02", "quality", "travel", "js_agg", 130D)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-javascript");
}
@Test
@@ -5461,7 +5461,7 @@ public class GroupByQueryRunnerTest
GroupByQueryRunnerTestHelper.createExpectedRow("2011-04-02", "quality", "travel", "js_agg", 127D)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-javascript");
}
@Test
@@ -5593,7 +5593,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-hyperunique");
}
@Test
@@ -5647,7 +5647,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-hyperunique");
}
@Test
@@ -5683,7 +5683,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subquery-firstlast");
}
@Test
@@ -5756,7 +5756,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subtotal");
}
@Test
@@ -5831,7 +5831,7 @@ public class GroupByQueryRunnerTest
for (Row row : results) {
System.out.println(row);
}
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subtotal-long-dim");
}
@Test
@@ -5871,7 +5871,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "subtotal-order-limit");
}
@Test
@@ -5900,7 +5900,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "time");
}
@Test
@@ -6117,7 +6117,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "time-extraction");
}
@@ -6368,7 +6368,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "time-extraction");
}
@Test
@@ -6422,7 +6422,7 @@ public class GroupByQueryRunnerTest
TestHelper.assertExpectedObjects(
bySegmentResults,
theRunner.run(QueryPlus.wrap(fullQuery), new HashMap<>()),
- ""
+ "bySegment"
);
exec.shutdownNow();
}
@@ -6484,7 +6484,7 @@ public class GroupByQueryRunnerTest
)
);
- TestHelper.assertExpectedObjects(bySegmentResults, theRunner.run(QueryPlus.wrap(fullQuery), new HashMap<>()), "");
+ TestHelper.assertExpectedObjects(bySegmentResults, theRunner.run(QueryPlus.wrap(fullQuery), new HashMap<>()), "bySegment");
exec.shutdownNow();
}
@@ -6544,7 +6544,7 @@ public class GroupByQueryRunnerTest
)
);
- TestHelper.assertExpectedObjects(bySegmentResults, theRunner.run(QueryPlus.wrap(fullQuery), new HashMap<>()), "");
+ TestHelper.assertExpectedObjects(bySegmentResults, theRunner.run(QueryPlus.wrap(fullQuery), new HashMap<>()), "bySegment-dim-extraction");
exec.shutdownNow();
}
@@ -6603,7 +6603,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "dim-extraction");
}
@@ -6651,7 +6651,7 @@ public class GroupByQueryRunnerTest
}
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "dim-extraction");
}
@Test
@@ -6675,7 +6675,7 @@ public class GroupByQueryRunnerTest
List<Row> expectedResults = Collections.emptyList();
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "dim-extraction");
}
@@ -6718,7 +6718,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "dim-extraction");
}
@Test
@@ -6886,7 +6886,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "agg-filter");
}
@@ -6923,7 +6923,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "extraction-dim-filter");
}
@@ -6959,7 +6959,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "extraction-dim-filter");
}
@Test
@@ -7041,7 +7041,7 @@ public class GroupByQueryRunnerTest
)
);
- TestHelper.assertExpectedObjects(bySegmentResults, theRunner.run(QueryPlus.wrap(fullQuery), new HashMap<>()), "");
+ TestHelper.assertExpectedObjects(bySegmentResults, theRunner.run(QueryPlus.wrap(fullQuery), new HashMap<>()), "bySegment-filter");
exec.shutdownNow();
}
@@ -7086,7 +7086,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "extraction");
}
@Test
@@ -7122,7 +7122,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "cardinality-agg");
}
@Test
@@ -7154,7 +7154,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "cardinality-agg");
}
@Test
@@ -7212,7 +7212,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "long");
}
@Test
@@ -7270,7 +7270,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "long");
}
@Test
@@ -7315,7 +7315,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "long-extraction");
}
@Test
@@ -7357,7 +7357,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "long");
}
@Test
@@ -7397,7 +7397,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "long-extraction");
}
@Test
@@ -7456,7 +7456,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "float");
}
@Test
@@ -7514,7 +7514,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "float");
}
@Test
@@ -7572,7 +7572,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "double");
}
@Test
@@ -7620,7 +7620,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "float");
}
@Test
@@ -7677,7 +7677,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "havingspec-long-float");
}
@Test
@@ -7726,7 +7726,7 @@ public class GroupByQueryRunnerTest
)
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "long-float");
}
@Test
@@ -7784,7 +7784,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, outerQuery);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "numeric-string");
}
@Test
@@ -7836,7 +7836,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "numeric-string");
}
@Test
@@ -7901,7 +7901,7 @@ public class GroupByQueryRunnerTest
}
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "numeric");
}
@Test
@@ -7972,7 +7972,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, outerQuery);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "numerics");
}
@Test
@@ -8054,7 +8054,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, outerQuery);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "numerics");
}
@Test
@@ -8104,7 +8104,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "string-long");
}
@Test
@@ -8166,7 +8166,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "numeric-dims");
}
@Test
@@ -8218,7 +8218,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, outerQuery);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "extraction-fn");
}
@Test
@@ -8270,7 +8270,7 @@ public class GroupByQueryRunnerTest
);
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, outerQuery);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "extraction-fn");
}
@Test
@@ -8745,7 +8745,7 @@ public class GroupByQueryRunnerTest
// Subqueries are handled by the ToolChest
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, runner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "limit-pushdown");
}
@Test
@@ -8809,6 +8809,6 @@ public class GroupByQueryRunnerTest
QueryRunner<Row> mergingRunner = factory.mergeRunners(MoreExecutors.sameThreadExecutor(), ImmutableList.of(ceqr));
Iterable<Row> results = GroupByQueryRunnerTestHelper.runQuery(factory, mergingRunner, query);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "type-conversion");
}
}
diff --git a/server/src/test/java/org/apache/druid/segment/realtime/RealtimeManagerTest.java b/server/src/test/java/org/apache/druid/segment/realtime/RealtimeManagerTest.java
index 247d214..0ab42c8 100644
--- a/server/src/test/java/org/apache/druid/segment/realtime/RealtimeManagerTest.java
+++ b/server/src/test/java/org/apache/druid/segment/realtime/RealtimeManagerTest.java
@@ -497,7 +497,7 @@ public class RealtimeManagerTest
query
);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "interval");
}
}
@@ -574,7 +574,7 @@ public class RealtimeManagerTest
),
query
);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "segmentSpec");
results = GroupByQueryRunnerTestHelper.runQuery(
factory,
@@ -589,7 +589,7 @@ public class RealtimeManagerTest
),
query
);
- TestHelper.assertExpectedObjects(expectedResults, results, "");
+ TestHelper.assertExpectedObjects(expectedResults, results, "segmentSpec");
}
}
@@ -688,7 +688,7 @@ public class RealtimeManagerTest
query.getQuerySegmentSpec().lookup(query, realtimeManager3),
query
);
- TestHelper.assertExpectedObjects(expectedResults_both_partitions, results, "");
+ TestHelper.assertExpectedObjects(expectedResults_both_partitions, results, "multi-segmentSpec");
results = GroupByQueryRunnerTestHelper.runQuery(
factory,
@@ -699,7 +699,7 @@ public class RealtimeManagerTest
),
query
);
- TestHelper.assertExpectedObjects(expectedResults_single_partition_26_28, results, "");
+ TestHelper.assertExpectedObjects(expectedResults_single_partition_26_28, results, "multi-segmentSpec");
results = GroupByQueryRunnerTestHelper.runQuery(
factory,
@@ -710,7 +710,7 @@ public class RealtimeManagerTest
),
query
);
- TestHelper.assertExpectedObjects(expectedResults_single_partition_28_29, results, "");
+ TestHelper.assertExpectedObjects(expectedResults_single_partition_28_29, results, "multi-segmentSpec");
results = GroupByQueryRunnerTestHelper.runQuery(
factory,
@@ -721,7 +721,7 @@ public class RealtimeManagerTest
),
query
);
- TestHelper.assertExpectedObjects(expectedResults_single_partition_26_28, results, "");
+ TestHelper.assertExpectedObjects(expectedResults_single_partition_26_28, results, "multi-segmentSpec");
results = GroupByQueryRunnerTestHelper.runQuery(
factory,
@@ -732,7 +732,7 @@ public class RealtimeManagerTest
),
query
);
- TestHelper.assertExpectedObjects(expectedResults_single_partition_28_29, results, "");
+ TestHelper.assertExpectedObjects(expectedResults_single_partition_28_29, results, "multi-segmentSpec");
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org