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 and Description
AggregatedSearchQueryProvider()

Method Summary

Modifier and Type	Method and Description
String	getFlowCountQuery(List<Filter> filters)
String	getHostname(String host, List<Filter> filters)
String	getSeriesFromTopNQuery(int N, GroupedBy groupedBy, 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 key, List<Filter> filters)
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 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 key,
                                     long step,
                                     long start,
                                     long end,
                                     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)