org.elasticsearch.search.aggregations.AggregationBuilders.dateHistogram()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(238)

本文整理了Java中org.elasticsearch.search.aggregations.AggregationBuilders.dateHistogram()方法的一些代码示例，展示了AggregationBuilders.dateHistogram()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AggregationBuilders.dateHistogram()方法的具体详情如下：
包路径：org.elasticsearch.search.aggregations.AggregationBuilders
类名称：AggregationBuilders
方法名：dateHistogram

AggregationBuilders.dateHistogram介绍

[英]Create a new DateHistogramAggregationBuilder aggregation with the given name.
[中]使用给定名称创建新的DateHistorograMaggregationBuilder聚合。

代码示例

代码示例来源：origin: spring-projects/spring-data-elasticsearch

public AbstractAggregationBuilder getFacet() {
    Assert.notNull(getName(), "Facet name can't be a null !!!");
    Assert.isTrue(!StringUtils.isEmpty(field), "Please select field on which to build the facet !!!");
    Assert.isTrue(interval > 0, "Please provide interval as positive value greater them zero !!!");

    DateHistogramAggregationBuilder dateHistogramBuilder = AggregationBuilders.dateHistogram(getName());
    dateHistogramBuilder.field(field);

    if (timeUnit != null) {
      dateHistogramBuilder.dateHistogramInterval(timeUnit);
    } else {
      dateHistogramBuilder.interval(interval);
    }

    dateHistogramBuilder.subAggregation(AggregationBuilders.extendedStats(INTERNAL_STATS).field(field));

    return dateHistogramBuilder;
  }
}

代码示例来源：origin: NLPchina/elasticsearch-sql

DateHistogramAggregationBuilder dateHistogram = AggregationBuilders.dateHistogram(alias).format(TIME_FARMAT);
String value = null;
for (KVValue kv : field.getParams()) {

代码示例来源：origin: loklak/loklak_server

public LinkedHashMap<String, Long> fullDateHistogram(final String indexName, int timezoneOffset, String histogram_timefield) {
  // prepare request
  SearchRequestBuilder request = elasticsearchClient.prepareSearch(indexName)
      .setSearchType(SearchType.QUERY_THEN_FETCH)
      .setQuery(QueryBuilders.constantScoreQuery(QueryBuilders.matchAllQuery()))
      .setFrom(0)
      .setSize(0);
  request.clearRescorers();
  request.addAggregation(AggregationBuilders.dateHistogram(histogram_timefield).field(histogram_timefield).timeZone("UTC").minDocCount(1).interval(DateHistogramInterval.DAY));
  // get response
  SearchResponse response = request.execute().actionGet();
  // evaluate date histogram:
  InternalHistogram<InternalHistogram.Bucket> dateCounts = response.getAggregations().get(histogram_timefield);
  LinkedHashMap<String, Long> list = new LinkedHashMap<>();
  for (InternalHistogram.Bucket bucket : dateCounts.getBuckets()) {
    Calendar cal = Calendar.getInstance(DateParser.UTCtimeZone);
    org.joda.time.DateTime k = (org.joda.time.DateTime) bucket.getKey();
    cal.setTime(k.toDate());
    cal.add(Calendar.MINUTE, -timezoneOffset);
    long docCount = bucket.getDocCount();
    list.put(DateParser.dayDateFormat.format(cal.getTime()), docCount);
  }
  return list;
}

代码示例来源：origin: loklak/loklak_server

if (field.equals(histogram_timefield)) {
  addTimeHistogram = true;
  request.addAggregation(AggregationBuilders.dateHistogram(histogram_timefield).field(histogram_timefield).timeZone("UTC").minDocCount(0).interval(dateHistogrammInterval));
} else {
  request.addAggregation(AggregationBuilders.terms(field).field(field).minDocCount(1).size(aggregationLimit));

代码示例来源：origin: SonarSource/sonarqube

AggregationBuilder dateHistogram = AggregationBuilders.dateHistogram(CREATED_AT.getName())
 .field(CREATED_AT.getFieldName())
 .dateHistogramInterval(bucketSize)

代码示例来源：origin: Graylog2/graylog2-server

final Terms.Order termsOrder = sorting == Sorting.Direction.DESC ? Terms.Order.count(false) : Terms.Order.count(true);
final DateHistogramAggregationBuilder histogramBuilder = AggregationBuilders.dateHistogram(AGG_HISTOGRAM)
    .field(Message.FIELD_TIMESTAMP)
    .dateHistogramInterval(interval.toESInterval())

代码示例来源：origin: Graylog2/graylog2-server

public HistogramResult histogram(String query, DateHistogramInterval interval, String filter, TimeRange range) {
  final DateHistogramAggregationBuilder histogramBuilder = AggregationBuilders.dateHistogram(AGG_HISTOGRAM)
      .field(Message.FIELD_TIMESTAMP)
      .dateHistogramInterval(interval.toESInterval());
  final SearchSourceBuilder searchSourceBuilder = filteredSearchRequest(query, filter, range)
    .aggregation(histogramBuilder);
  final Set<String> affectedIndices = determineAffectedIndices(range, filter);
  if (affectedIndices.isEmpty()) {
    return DateHistogramResult.empty(query, searchSourceBuilder.toString(), interval);
  }
  final Search.Builder searchBuilder = new Search.Builder(searchSourceBuilder.toString())
    .addType(IndexMapping.TYPE_MESSAGE)
    .addIndex(affectedIndices)
    .ignoreUnavailable(true)
    .allowNoIndices(true);
  final io.searchbox.core.SearchResult searchResult = wrapInMultiSearch(searchBuilder.build(), () -> "Unable to retrieve histogram");
  recordEsMetrics(searchResult, range);
  final HistogramAggregation histogramAggregation = searchResult.getAggregations().getHistogramAggregation(AGG_HISTOGRAM);
  return new DateHistogramResult(
    histogramAggregation,
    query,
    searchSourceBuilder.toString(),
    interval,
    tookMsFromSearchResult(searchResult)
  );
}

代码示例来源：origin: Graylog2/graylog2-server

boolean includeStats,
                 boolean includeCardinality) {
final DateHistogramAggregationBuilder dateHistogramBuilder = AggregationBuilders.dateHistogram(AGG_HISTOGRAM)
    .field(Message.FIELD_TIMESTAMP)
    .dateHistogramInterval(interval.toESInterval());

代码示例来源：origin: org.nuxeo.elasticsearch/nuxeo-elasticsearch-core

@JsonIgnore
@Override
public DateHistogramAggregationBuilder getEsAggregate() {
  DateHistogramAggregationBuilder ret = AggregationBuilders.dateHistogram(getId())
                               .field(getField())
                               .timeZone(DateTimeZone.getDefault());

代码示例来源：origin: judasn/Elasticsearch-Tutorial-zh-CN

.subAggregation(AggregationBuilders.dateHistogram("product_group_by_created_date_time").field("created_date_time")
    .dateHistogramInterval(DateHistogramInterval.YEAR)
    .subAggregation(AggregationBuilders.avg("product_avg_price").field("price")))

代码示例来源：origin: org.sonarsource.sonarqube/sonar-server

AggregationBuilder dateHistogram = AggregationBuilders.dateHistogram(PARAM_CREATED_AT)
 .field(IssueIndexDefinition.FIELD_ISSUE_FUNC_CREATED_AT)
 .dateHistogramInterval(bucketSize)

代码示例来源：origin: mbok/logsniffer

final DateHistogramInterval interval = getInterval(timeRange, maxHistogramIntervalSlots,
    histogram);
requestBuilder.addAggregation(AggregationBuilders.dateHistogram("eventsCount")
    .interval(interval).field(Event.FIELD_TIMESTAMP).order(Order.KEY_ASC));

代码示例来源：origin: org.graylog2/graylog2-server

final Terms.Order termsOrder = sorting == Sorting.Direction.DESC ? Terms.Order.count(false) : Terms.Order.count(true);
final DateHistogramBuilder histogramBuilder = AggregationBuilders.dateHistogram(AGG_HISTOGRAM)
    .field(Message.FIELD_TIMESTAMP)
    .interval(interval.toESInterval())

代码示例来源：origin: com.blossom-project/blossom-core-common

.addAggregation(AggregationBuilders.terms("flop_uris").field("request.uri")
 .order(Terms.Order.aggregation("_count", true)).size(10))
.addAggregation(AggregationBuilders.dateHistogram("request_histogram").field("timestamp")
 .interval(new DateHistogramInterval(precision))
 .subAggregation(AggregationBuilders.terms("methods").field("request.method")));

代码示例来源：origin: org.securegraph/securegraph-elasticsearch

DateHistogramBuilder agg = AggregationBuilders.dateHistogram(histogramQueryItem.getAggregationName());
agg.field(histogramQueryItem.getFieldName());
agg.interval(Long.parseLong(histogramQueryItem.getInterval()));

代码示例来源：origin: org.neolumin.vertexium/vertexium-elasticsearch

DateHistogramBuilder agg = AggregationBuilders.dateHistogram(histogramQueryItem.getAggregationName());
agg.field(histogramQueryItem.getFieldName());
agg.interval(Long.parseLong(histogramQueryItem.getInterval()));

代码示例来源：origin: org.vertexium/vertexium-elasticsearch

DateHistogramBuilder agg = AggregationBuilders.dateHistogram(histogramQueryItem.getAggregationName());
agg.field(histogramQueryItem.getFieldName());
agg.interval(Long.parseLong(histogramQueryItem.getInterval()));

代码示例来源：origin: lumifyio/securegraph

DateHistogramBuilder agg = AggregationBuilders.dateHistogram(histogramQueryItem.getAggregationName());
agg.field(histogramQueryItem.getFieldName());
agg.interval(Long.parseLong(histogramQueryItem.getInterval()));

代码示例来源：origin: org.graylog2/graylog2-server

public HistogramResult histogram(String query, DateHistogramInterval interval, String filter, TimeRange range) {
  final DateHistogramBuilder histogramBuilder = AggregationBuilders.dateHistogram(AGG_HISTOGRAM)
      .field(Message.FIELD_TIMESTAMP)
      .interval(interval.toESInterval());
  final SearchSourceBuilder searchSourceBuilder = filteredSearchRequest(query, filter, range)
    .aggregation(histogramBuilder);
  final Set<String> affectedIndices = determineAffectedIndices(range, filter);
  if (affectedIndices.isEmpty()) {
    return DateHistogramResult.empty(query, searchSourceBuilder.toString(), interval);
  }
  final Search.Builder searchBuilder = new Search.Builder(searchSourceBuilder.toString())
    .addType(IndexMapping.TYPE_MESSAGE)
    .addIndex(affectedIndices)
    .ignoreUnavailable(true)
    .allowNoIndices(true);
  final io.searchbox.core.SearchResult searchResult = wrapInMultiSearch(searchBuilder.build(), () -> "Unable to retrieve histogram");
  recordEsMetrics(searchResult, range);
  final HistogramAggregation histogramAggregation = searchResult.getAggregations().getHistogramAggregation(AGG_HISTOGRAM);
  return new DateHistogramResult(
    histogramAggregation,
    query,
    searchSourceBuilder.toString(),
    interval,
    tookMsFromSearchResult(searchResult)
  );
}

代码示例来源：origin: org.graylog2/graylog2-server

boolean includeStats,
                 boolean includeCardinality) {
final DateHistogramBuilder dateHistogramBuilder = AggregationBuilders.dateHistogram(AGG_HISTOGRAM)
    .field(Message.FIELD_TIMESTAMP)
    .interval(interval.toESInterval());

内容来源于网络，如有侵权，请联系作者删除！

AggregationBuilders

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com