Skip to content

Commit

Permalink
fix align by device
Browse files Browse the repository at this point in the history
  • Loading branch information
qiaojialin committed Feb 26, 2020
1 parent ae560a9 commit 4627079
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -226,13 +226,13 @@ private QueryDataSet processDataQuery(QueryPlan queryPlan, QueryContext context)
throws StorageEngineException, QueryFilterOptimizationException, QueryProcessException,
IOException {
QueryDataSet queryDataSet;
if (queryPlan.getPaths().isEmpty()) {
// no time series are selected, return EmptyDataSet
queryDataSet = new EmptyDataSet();
} else if (queryPlan instanceof AlignByDevicePlan) {
if (queryPlan instanceof AlignByDevicePlan) {
queryDataSet = new AlignByDeviceDataSet((AlignByDevicePlan) queryPlan, context, queryRouter);
} else {
if (queryPlan instanceof GroupByPlan) {
if (queryPlan.getPaths() == null || queryPlan.getPaths().isEmpty()) {
// no time series are selected, return EmptyDataSet
queryDataSet = new EmptyDataSet();
} else if (queryPlan instanceof GroupByPlan) {
GroupByPlan groupByPlan = (GroupByPlan) queryPlan;
return queryRouter.groupBy(groupByPlan, context);
} else if (queryPlan instanceof AggregationPlan) {
Expand Down

0 comments on commit 4627079

Please sign in to comment.