Skip to content

Commit

Permalink
fixed issue 149
Browse files Browse the repository at this point in the history
  • Loading branch information
zhuang16384 committed Jan 5, 2018
1 parent 2db6739 commit 4aca79f
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -163,9 +163,10 @@ private void queryDistinct(UAVHttpMessage data) {

try {
String ipport = data.getRequest("ipport");
AggregationBuilder agg = AggregationBuilders.terms("unique_time").field("time")
// TODO ES aggregation 默认最多查10条, 这里暂时改到1000,待refine
AggregationBuilder agg = AggregationBuilders.terms("unique_time").field("time").size(1000)
.order(Terms.Order.term(false))
.subAggregation(AggregationBuilders.terms("unique_user").field("user"));
.subAggregation(AggregationBuilders.terms("unique_user").field("user").size(1000));

String date = data.getRequest("indexdate");
String currentIndex;
Expand Down

0 comments on commit 4aca79f

Please sign in to comment.