Package org.graylog.events.processor.aggregation

Class PivotAggregationSearch

java.lang.Object

org.graylog.events.processor.aggregation.PivotAggregationSearch

All Implemented Interfaces:

AggregationSearch

public class PivotAggregationSearch
extends Object
implements AggregationSearch

Nested Class Summary

Nested classes/interfaces inherited from interface org.graylog.events.processor.aggregation.AggregationSearch

AggregationSearch.Factory, AggregationSearch.User

Constructor Summary

Constructors

Constructor

Description

PivotAggregationSearch(AggregationEventProcessorConfig config, AggregationEventProcessorParameters parameters, AggregationSearch.User searchOwner, EventDefinition eventDefinition, List<SearchType> additionalSearchTypes, SearchJobService searchJobService, QueryEngine queryEngine, EventsConfigurationProvider configProvider, MoreSearch moreSearch, PermittedStreams permittedStreams, NotificationService notificationService, QueryStringDecorators queryStringDecorators, SearchNormalization searchNormalization)

Method Summary

Modifier and Type	Method	Description
AggregationResult	doSearch()
protected Query	getAggregationQuery(AggregationEventProcessorParameters parameters, long searchWithinMs, long executeEveryMs)	Returns the query to compute the aggregation.
protected SearchJob	getSearchJob(AggregationEventProcessorParameters parameters, AggregationSearch.User user, long searchWithinMs, long executeEveryMs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PivotAggregationSearch

@Inject
public PivotAggregationSearch(AggregationEventProcessorConfig config,
 AggregationEventProcessorParameters parameters,
 AggregationSearch.User searchOwner,
 EventDefinition eventDefinition,
 List<SearchType> additionalSearchTypes,
 SearchJobService searchJobService,
 QueryEngine queryEngine,
 EventsConfigurationProvider configProvider,
 MoreSearch moreSearch,
 PermittedStreams permittedStreams,
 NotificationService notificationService,
 QueryStringDecorators queryStringDecorators,
 SearchNormalization searchNormalization)

Method Details

doSearch

public AggregationResult doSearch()
                           throws EventProcessorException

Specified by:

doSearch in interface AggregationSearch

Throws:

EventProcessorException

getSearchJob

protected SearchJob getSearchJob(AggregationEventProcessorParameters parameters,
 AggregationSearch.User user,
 long searchWithinMs,
 long executeEveryMs)
                          throws EventProcessorException

Throws:

EventProcessorException

getAggregationQuery

protected Query getAggregationQuery(AggregationEventProcessorParameters parameters,
 long searchWithinMs,
 long executeEveryMs)

Returns the query to compute the aggregation.

Parameters:

parameters - processor parameters

searchWithinMs - processor search within period. Used to build the date range buckets

executeEveryMs -

Returns:

aggregation query