Skip to content

Commit ca710da

Browse files
committed
Use correct constant from API for compactedList string. Remove intervals from checked scan request expectation, since it can differ depending on env serializing timestamps.
1 parent c397c28 commit ca710da

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/test/java/com/simplaex/clients/druid/DruidClientTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ public void shouldExecuteAScanQuery() throws IOException {
189189
final ScanQuery query = new ScanQuery.ScanQueryBuilder()
190190
.dataSource("player_explorer_s3")
191191
.filters(DimFilters.dimEquals("version", "All"))
192-
.resultFormat("compactList")
192+
.resultFormat(ScanQuery.RESULT_FORMAT_COMPACTED_LIST)
193193
.columns(Arrays.asList("__time", "sessionCount", "deviceType"))
194194
.intervals(new MultipleIntervalSegmentSpec(
195195
Collections.singletonList(new Interval(from, to))))
@@ -217,6 +217,7 @@ public void shouldExecuteAScanQuery() throws IOException {
217217
"sessionCount",
218218
scanResult.getColumns().get(1));
219219

220+
@SuppressWarnings("unchecked")
220221
final List<List<Object>> events = (List<List<Object>>) scanResult.getEvents();
221222
Assert.assertEquals("should have 2 events", 2, events.size());
222223

Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
{
22
"queryType": "scan",
33
"filter": {"type": "selector", "dimension": "version", "value": "All"},
4-
"resultFormat": "compactList",
5-
"intervals":{"type":"intervals","intervals":["2017-06-30T00:00:00.000Z/2020-10-02T00:00:00.000Z"]},
4+
"resultFormat": "compactedList",
65
"columns": ["__time", "sessionCount", "deviceType"]
76
}

0 commit comments

Comments
 (0)