Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Change benchmark

This commit is contained in:
Justin Borromeo 2019-02-04 10:55:56 -08:00
parent 989bd2d50e
commit ad731a362b
2 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
benchmarks/src/main/java/org/apache/druid/benchmark/query/ScanBenchmark.java
View File

@ -177,7 +177,8 @@ public class ScanBenchmark
return Druids.newScanQueryBuilder() return Druids.newScanQueryBuilder()
.dataSource("blah") .dataSource("blah")
.intervals(intervalSpec); .intervals(intervalSpec)
.timeOrder("none");
} }
@ -203,7 +204,8 @@ public class ScanBenchmark
return Druids.newScanQueryBuilder() return Druids.newScanQueryBuilder()
.filters(filter) .filters(filter)
.intervals(intervalSpec); .intervals(intervalSpec)
.timeOrder("none");
} }
private static Druids.ScanQueryBuilder basicC(final BenchmarkSchemaInfo basicSchema) private static Druids.ScanQueryBuilder basicC(final BenchmarkSchemaInfo basicSchema)
@ -220,7 +222,8 @@ public class ScanBenchmark
final String dimName = "dimUniform"; final String dimName = "dimUniform";
return Druids.newScanQueryBuilder() return Druids.newScanQueryBuilder()
.filters(new SelectorDimFilter(dimName, "3", StrlenExtractionFn.instance())) .filters(new SelectorDimFilter(dimName, "3", StrlenExtractionFn.instance()))
.intervals(intervalSpec); // TODO .intervals(intervalSpec)
.timeOrder("none");
} }
private static Druids.ScanQueryBuilder basicD(final BenchmarkSchemaInfo basicSchema) private static Druids.ScanQueryBuilder basicD(final BenchmarkSchemaInfo basicSchema)
@ -241,7 +244,8 @@ public class ScanBenchmark
return Druids.newScanQueryBuilder() return Druids.newScanQueryBuilder()
.filters(new BoundDimFilter(dimName, "100", "10000", true, true, true, null, null)) .filters(new BoundDimFilter(dimName, "100", "10000", true, true, true, null, null))
.intervals(intervalSpec); // TODO .intervals(intervalSpec)
.timeOrder("none");
} }
@Setup @Setup

14
processing/src/main/java/org/apache/druid/query/Druids.java
View File

@ -924,6 +924,7 @@ public class Druids
private DimFilter dimFilter; private DimFilter dimFilter;
private List<String> columns; private List<String> columns;
private Boolean legacy; private Boolean legacy;
private String timeOrder;
public ScanQueryBuilder() public ScanQueryBuilder()
{ {
@ -937,6 +938,7 @@ public class Druids
dimFilter = null; dimFilter = null;
columns = new ArrayList<>(); columns = new ArrayList<>();
legacy = null; legacy = null;
timeOrder = null;
} }
public ScanQuery build() public ScanQuery build()
@ -951,7 +953,8 @@ public class Druids
dimFilter, dimFilter,
columns, columns,
legacy, legacy,
context context,
timeOrder
); );
} }
@ -967,7 +970,8 @@ public class Druids
.filters(query.getFilter()) .filters(query.getFilter())
.columns(query.getColumns()) .columns(query.getColumns())
.legacy(query.isLegacy()) .legacy(query.isLegacy())
.context(query.getContext()); .context(query.getContext())
.timeOrder(query.getTimeOrder());
} }
public ScanQueryBuilder dataSource(String ds) public ScanQueryBuilder dataSource(String ds)
@ -1046,6 +1050,12 @@ public class Druids
this.legacy = legacy; this.legacy = legacy;
return this; return this;
} }
public ScanQueryBuilder timeOrder(String timeOrder)
{
this.timeOrder = timeOrder;
return this;
}
} }
public static ScanQueryBuilder newScanQueryBuilder() public static ScanQueryBuilder newScanQueryBuilder()