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
All Methods Instance Methods Concrete Methods 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)
-
-
-
Method Detail
-
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 interfaceFilterVisitor<String>
-
visit
public String visit(TimeRangeFilter timeRangeFilter)
- Specified by:
visit
in interfaceFilterVisitor<String>
-
visit
public String visit(SnmpInterfaceIdFilter snmpInterfaceIdFilter)
- Specified by:
visit
in interfaceFilterVisitor<String>
-
visit
public String visit(DscpFilter dscpFilter)
- Specified by:
visit
in interfaceFilterVisitor<String>
-
-