Package org.opennms.netmgt.flows.elastic.agg

Class AggregatedSearchQueryProvider

java.lang.Object

org.opennms.netmgt.flows.elastic.agg.AggregatedSearchQueryProvider

All Implemented Interfaces:

FilterVisitor<String>

public class AggregatedSearchQueryProvider
extends Object
implements FilterVisitor<String>

Here we store the search queries in the class-path in the form of Freemarker templates and use the templating to perform the parameter substitution. We could consider removing this in favor of using the High-level Elasticsearch client.

Constructor Summary

Constructors

Constructor	Description
AggregatedSearchQueryProvider()

Method Summary

Modifier and Type	Method	Description
String	getAllTerms(GroupedBy groupedBy, String groupedByField, int fieldSize, List<Filter> filters)
String	getFlowCountQuery(List<Filter> filters)
String	getHostname(String host, List<Filter> filters)
String	getSeriesFromTopNQuery(int N, GroupedBy groupedBy, String aggregationType, String key, long step, long start, long end, List<Filter> filters)
String	getSeriesFromTotalsQuery(GroupedBy groupedBy, long step, long start, long end, List<Filter> filters)
String	getSumQuery(GroupedBy groupedBy, List<Filter> filters)
String	getTopNQuery(int N, GroupedBy groupedBy, String aggregationType, String key, List<Filter> filters)
String	visit(DscpFilter dscpFilter)
String	visit(ExporterNodeFilter exporterNodeFilter)
String	visit(SnmpInterfaceIdFilter snmpInterfaceIdFilter)
String	visit(TimeRangeFilter timeRangeFilter)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatedSearchQueryProvider

public AggregatedSearchQueryProvider()

Method Detail

getFlowCountQuery

public String getFlowCountQuery(List<Filter> filters)

getSumQuery

public String getSumQuery(GroupedBy groupedBy,
                          List<Filter> filters)

getTopNQuery

public String getTopNQuery(int N,
                           GroupedBy groupedBy,
                           String aggregationType,
                           String key,
                           List<Filter> filters)

getSeriesFromTotalsQuery

public String getSeriesFromTotalsQuery(GroupedBy groupedBy,
                                       long step,
                                       long start,
                                       long end,
                                       List<Filter> filters)

getSeriesFromTopNQuery

public String getSeriesFromTopNQuery(int N,
                                     GroupedBy groupedBy,
                                     String aggregationType,
                                     String key,
                                     long step,
                                     long start,
                                     long end,
                                     List<Filter> filters)

getAllTerms

public String getAllTerms(GroupedBy groupedBy,
                          String groupedByField,
                          int fieldSize,
                          List<Filter> filters)

visit

public String visit(ExporterNodeFilter exporterNodeFilter)

Specified by:

visit in interface FilterVisitor<String>

visit

public String visit(TimeRangeFilter timeRangeFilter)

Specified by:

visit in interface FilterVisitor<String>

visit

public String visit(SnmpInterfaceIdFilter snmpInterfaceIdFilter)

Specified by:

visit in interface FilterVisitor<String>

getHostname

public String getHostname(String host,
                          List<Filter> filters)

visit

public String visit(DscpFilter dscpFilter)

Specified by:

visit in interface FilterVisitor<String>