Package org.opennms.netmgt.flows.elastic

Class SmartQueryService

java.lang.Object

org.opennms.netmgt.flows.elastic.SmartQueryService

All Implemented Interfaces:

FlowQueryService

public class SmartQueryService
extends Object
implements FlowQueryService

Used to intelligently delegate to the proper FlowQueryService based on whether or not aggregated flows can be used.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SmartQueryService.QueryServiceType

Constructor Summary

Constructors

Constructor	Description
SmartQueryService(com.codahale.metrics.MetricRegistry metricRegistry, FlowQueryService rawQueryService, FlowQueryService aggQueryService)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<List<String>>	getApplications(String matchingPrefix, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getApplicationSeries(Set<String> applications, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getApplicationSummaries(Set<String> applications, boolean includeOther, List<Filter> filters)
CompletableFuture<List<String>>	getConversations(String locationPattern, String protocolPattern, String lowerIPPattern, String upperIPPattern, String applicationPattern, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>>	getConversationSeries(Set<String> conversations, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Conversation>>>	getConversationSummaries(Set<String> conversations, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getFieldSeries(LimitedCardinalityField field, long step, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getFieldSummaries(LimitedCardinalityField field, List<Filter> filters)
CompletableFuture<List<String>>	getFieldValues(LimitedCardinalityField field, List<Filter> filters)
CompletableFuture<Long>	getFlowCount(List<Filter> filters)
CompletableFuture<List<String>>	getHosts(String regex, long limit, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>>	getHostSeries(Set<String> hosts, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Host>>>	getHostSummaries(Set<String> hosts, boolean includeOther, List<Filter> filters)
long	getTimeRangeDurationAggregateThresholdMs()
long	getTimeRangeEndpointAggregateThresholdMs()
CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>>	getTopNApplicationSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<String>>>	getTopNApplicationSummaries(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>>	getTopNConversationSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Conversation>>>	getTopNConversationSummaries(int N, boolean includeOther, List<Filter> filters)
CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>>	getTopNHostSeries(int N, long step, boolean includeOther, List<Filter> filters)
CompletableFuture<List<TrafficSummary<Host>>>	getTopNHostSummaries(int N, boolean includeOther, List<Filter> filters)
boolean	isAlwaysUseAggForQueries()
boolean	isAlwaysUseRawForQueries()
void	setAlwaysUseAggForQueries(boolean alwaysUseAggForQueries)
void	setAlwaysUseRawForQueries(boolean alwaysUseRawForQueries)
void	setTimeRangeDurationAggregateThresholdMs(long timeRangeDurationAggregateThresholdMs)
void	setTimeRangeEndpointAggregateThresholdMs(long timeRangeEndpointAggregateThresholdMs)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SmartQueryService

public SmartQueryService(com.codahale.metrics.MetricRegistry metricRegistry,
                         FlowQueryService rawQueryService,
                         FlowQueryService aggQueryService)

Method Detail

getFlowCount

public CompletableFuture<Long> getFlowCount(List<Filter> filters)

Specified by:

getFlowCount in interface FlowQueryService

getApplications

public CompletableFuture<List<String>> getApplications(String matchingPrefix,
                                                       long limit,
                                                       List<Filter> filters)

Specified by:

getApplications in interface FlowQueryService

getTopNApplicationSummaries

public CompletableFuture<List<TrafficSummary<String>>> getTopNApplicationSummaries(int N,
                                                                                   boolean includeOther,
                                                                                   List<Filter> filters)

Specified by:

getTopNApplicationSummaries in interface FlowQueryService

getApplicationSummaries

public CompletableFuture<List<TrafficSummary<String>>> getApplicationSummaries(Set<String> applications,
                                                                               boolean includeOther,
                                                                               List<Filter> filters)

Specified by:

getApplicationSummaries in interface FlowQueryService

getApplicationSeries

public CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> getApplicationSeries(Set<String> applications,
                                                                                                                            long step,
                                                                                                                            boolean includeOther,
                                                                                                                            List<Filter> filters)

Specified by:

getApplicationSeries in interface FlowQueryService

getTopNApplicationSeries

public CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> getTopNApplicationSeries(int N,
                                                                                                                                long step,
                                                                                                                                boolean includeOther,
                                                                                                                                List<Filter> filters)

Specified by:

getTopNApplicationSeries in interface FlowQueryService

getConversations

public CompletableFuture<List<String>> getConversations(String locationPattern,
                                                        String protocolPattern,
                                                        String lowerIPPattern,
                                                        String upperIPPattern,
                                                        String applicationPattern,
                                                        long limit,
                                                        List<Filter> filters)

Specified by:

getConversations in interface FlowQueryService

getTopNConversationSummaries

public CompletableFuture<List<TrafficSummary<Conversation>>> getTopNConversationSummaries(int N,
                                                                                          boolean includeOther,
                                                                                          List<Filter> filters)

Specified by:

getTopNConversationSummaries in interface FlowQueryService

getConversationSummaries

public CompletableFuture<List<TrafficSummary<Conversation>>> getConversationSummaries(Set<String> conversations,
                                                                                      boolean includeOther,
                                                                                      List<Filter> filters)

Specified by:

getConversationSummaries in interface FlowQueryService

getConversationSeries

public CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> getConversationSeries(Set<String> conversations,
                                                                                                                                   long step,
                                                                                                                                   boolean includeOther,
                                                                                                                                   List<Filter> filters)

Specified by:

getConversationSeries in interface FlowQueryService

getTopNConversationSeries

public CompletableFuture<com.google.common.collect.Table<Directional<Conversation>,Long,Double>> getTopNConversationSeries(int N,
                                                                                                                                       long step,
                                                                                                                                       boolean includeOther,
                                                                                                                                       List<Filter> filters)

Specified by:

getTopNConversationSeries in interface FlowQueryService

getHosts

public CompletableFuture<List<String>> getHosts(String regex,
                                                long limit,
                                                List<Filter> filters)

Specified by:

getHosts in interface FlowQueryService

getTopNHostSummaries

public CompletableFuture<List<TrafficSummary<Host>>> getTopNHostSummaries(int N,
                                                                          boolean includeOther,
                                                                          List<Filter> filters)

Specified by:

getTopNHostSummaries in interface FlowQueryService

getHostSummaries

public CompletableFuture<List<TrafficSummary<Host>>> getHostSummaries(Set<String> hosts,
                                                                      boolean includeOther,
                                                                      List<Filter> filters)

Specified by:

getHostSummaries in interface FlowQueryService

getHostSeries

public CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> getHostSeries(Set<String> hosts,
                                                                                                                   long step,
                                                                                                                   boolean includeOther,
                                                                                                                   List<Filter> filters)

Specified by:

getHostSeries in interface FlowQueryService

getTopNHostSeries

public CompletableFuture<com.google.common.collect.Table<Directional<Host>,Long,Double>> getTopNHostSeries(int N,
                                                                                                                       long step,
                                                                                                                       boolean includeOther,
                                                                                                                       List<Filter> filters)

Specified by:

getTopNHostSeries in interface FlowQueryService

getFieldValues

public CompletableFuture<List<String>> getFieldValues(LimitedCardinalityField field,
                                                      List<Filter> filters)

Specified by:

getFieldValues in interface FlowQueryService

getFieldSummaries

public CompletableFuture<List<TrafficSummary<String>>> getFieldSummaries(LimitedCardinalityField field,
                                                                         List<Filter> filters)

Specified by:

getFieldSummaries in interface FlowQueryService

getFieldSeries

public CompletableFuture<com.google.common.collect.Table<Directional<String>,Long,Double>> getFieldSeries(LimitedCardinalityField field,
                                                                                                                      long step,
                                                                                                                      List<Filter> filters)

Specified by:

getFieldSeries in interface FlowQueryService

isAlwaysUseAggForQueries

public boolean isAlwaysUseAggForQueries()

setAlwaysUseAggForQueries

public void setAlwaysUseAggForQueries(boolean alwaysUseAggForQueries)

isAlwaysUseRawForQueries

public boolean isAlwaysUseRawForQueries()

setAlwaysUseRawForQueries

public void setAlwaysUseRawForQueries(boolean alwaysUseRawForQueries)

getTimeRangeDurationAggregateThresholdMs

public long getTimeRangeDurationAggregateThresholdMs()

setTimeRangeDurationAggregateThresholdMs

public void setTimeRangeDurationAggregateThresholdMs(long timeRangeDurationAggregateThresholdMs)

getTimeRangeEndpointAggregateThresholdMs

public long getTimeRangeEndpointAggregateThresholdMs()

setTimeRangeEndpointAggregateThresholdMs

public void setTimeRangeEndpointAggregateThresholdMs(long timeRangeEndpointAggregateThresholdMs)

toString

public String toString()

Overrides:

toString in class Object