Skip to content
Snippets Groups Projects
Code owners
Assign users and groups as approvers for specific file changes. Learn more.
Filters.md 2.11 KiB

Filters Aggregation

More info about filters aggregation is in the official elasticsearch docs

Defines a multi bucket aggregations where each bucket is associated with a filter. Each bucket will collect all documents that match its associated filter.

Filters can have names or be anonymous, this is controlled by setAnonymous method. By default filters are not anonymous and trying to add filter without name will result in exception.

Named example

{
  "aggregations" : {
    "agg_messages" : {
      "filters" : {
        "filters" : {
          "errors" :   { "term" : { "body" : "error"   }},
          "warnings" : { "term" : { "body" : "warning" }}
        }
      },
      "aggregations" : {
        "agg_monthly" : {
          "histogram" : {
            "field" : "timestamp",
            "interval" : "1M"
          }
        }
      }
    }
  }
}

And now the query via DSL:

$errorTermFilter = new TermFilter('body', 'error');
$warningTermFilter = new TermFilter('body', 'warning');

$histogramAggregation = new HistogramAggregation('monthly', 'timestamp');
$histogramAggregation->setInterval('1M');

$filterAggregation = new FiltersAggregation(
    'grades_stats',
    [
        'error' => $errorTermFilter,
        'warning' => $warningTermFilter,
    ]
);
$filterAggregation->addAggregation($histogramAggregation);

$search = new Search();
$search->addAggregation($filterAggregation);

$queryArray = $search->toArray();

Anonymous example

$errorTermFilter = new TermFilter('body', 'error');
$warningTermFilter = new TermFilter('body', 'warning');

$histogramAggregation = new HistogramAggregation('monthly', 'timestamp');
$histogramAggregation->setInterval('1M');

$filterAggregation = new FiltersAggregation(
    'grades_stats',
    [
        $errorTermFilter,
        $warningTermFilter,
    ],
    true
);
$filterAggregation->addAggregation($histogramAggregation);

$search = new Search();
$search->addAggregation($filterAggregation);

$queryArray = $search->toArray();